socket server实现多并发

简单实现

server

import socketserver

class MyServer(socketserver.BaseRequestHandler):

    def handle(self):
        print("客户端 %s 连接成功" % self.client_address[0])
        while True:
            self.data = self.request.recv(1024).strip()
            print("{} {} wrote:".format(self.client_address[0],self.client_address[1]))
            print(self.data)
            if not self.data:
                print(self.client_address,"断开了")
                break
            self.request.send(self.data.upper())


if __name__ == '__main__':
    HOST,PORT = '127.0.0.1',60006
    server = socketserver.ThreadingTCPServer((HOST,PORT),MyServer)
    print("等待客户端...")
    server.serve_forever()

client

import socket

client = socket.socket()

client.connect(('127.0.0.1',60006))

while True:
    message = input(">> ").strip()

    client.send(message.encode())
    up = client.recv(1024)
    print(up.decode())