socket 多线程通讯模型

多线程处理Socket并发
server

#!/usr/bin/env python
import socket
import threading

server = socket.socket()
server.bind(('', 9999))
server.listen(5)

def readThread(conn, addr):
    """
    创建一个新的线程，负责和一个客户端通讯
    :param conn:
    :param addr:
    :return:
    """
    while True:
        data = conn.recv(1024)
        if data:
            print('{}:{}'.format(addr, data))
        else:
            print("客户端{}已关闭".format(addr))
            break
    conn.close()

while True:
    print('------主线程，等待客户端连接------')
    conn, addr = server.accept()
    print('创建一个新的线程，和客户端{}通讯'.format(addr))
    # 创建一个子线程，负责消息收发
    client = threading.Thread(target=readThread, args=(conn, addr))
    # 启动线程