import threading
from socketserver import ThreadingTCPServer, StreamRequestHandler


class ClientHandler(StreamRequestHandler):
    def handle(self):
        while True:
            msg = self.request.recv(1024).decode("utf-8")
            print("\n@%s>>>\n收到客户端%s消息：%s" % (threading.current_thread().name, self.client_address[1], msg))

            # mmsg = input("@%s>>>\n你对%s说：" % (threading.current_thread().name, self.client_address[1]))
            if msg == "呵呵":
                mmsg = "fuck off"
            else:
                mmsg = "已阅：" + msg

            self.request.send(("=>" + mmsg).encode("utf-8"))
            if mmsg == "fuck off":
                self.request.close()
                print("已断开与客户端%s的连接" % (self.client_address[1]))
                break


host = "127.0.0.1"
port = 1234

if __name__ == "__main__":
    server = ThreadingTCPServer((host, port), ClientHandler)
    server.serve_forever()
    print("main over")