035server端并发聊天

import socketserver

class MyServer(socketserver.BaseRequestHandler):
    def handle(self):    #  里面是每个客户端连接执行的过程
        print('服务器启动')
        while True:
            conn = self.request
            print(self.client_address)
            while True:
                client_data = conn.recv(1024)
                print(str(client_data,'utf8'))
                print('waiting...')
                conn.sendall(client_data)
            conn.close()

if __name__ == '__main__':
    server = socketserver.ThreadingTCPServer(('127.0.0.1',8888),MyServer)
    server.serve_forever()       # 激活这个服务器对象

import  socket

def connect_server():
    sk = socket.socket()
    server_address = ('127.0.0.1',8888)
    sk.connect(server_address)
    return sk

if __name__ == '__main__':
    sk = connect_server()
    while True:
        inp = input('>>>')
        if inp == 'exit':
            break
        sk.send(bytes(inp,'utf8'))
        print('waiting...')
        data = sk.recv(1024)
        print(str(data,'utf8'))
    sk.close()

实现并发聊天：
1、继承socketserver.BaseRequestHandler
2、使用socketserver.ThreadingTCPServer(('127.0.0.1',8888),MyServer)拿到一个服务器对象

要相互发送信息，可以在handle方法里面改成这个，这里的聊天还是有很多缺憾

自己调式一下这个执行过程，看python的实现源码