TCP多线程聊天

• 服务器端

from socket import *
from threading import Thread
sockets = []
def main():
    #创建server_socket套接字对象
    server_socket = socket(AF_INET,SOCK_STREAM)
    #绑定端口
    server_socket.bind(('',8889))
    #监听
    server_socket.listen()
    #接收客户端的请求
    while True:
        client_socket,client_info = server_socket.accept()
        sockets.append(client_socket)
        #开启线程处理当前客户端的请求
        t = Thread(target=readMsg,args=(client_socket,))
        t.start()
def readMsg(client_socket):
    #读取客户端发送过来的消息 
    while True: 
        recv_data = client_socket.recv(1024)
        #将消息发送给所有在线客户端
        #遍历所有在线客户端列表
        for socket in sockets:
            socket.send(recv_data)
if __name__ == '__main__':
    main()

• 客户端

from sock import *
from threading import Thread
def readMsg(client_socket):
    while True: 
        recv_data = client_socket.recv(1024)
        print('收到：',recv_data.decode('utf-8'))
def writeMsg(client_socket):
    while True:
        msg = input('>')
        client_socket.sent(msg.encode('utf-8'))
#创建客户端套接字对象
client_socket = socket(AF_INET,SOCK_STREAM)
#调用connect()连接服务器
client_socket.connect(('192.168.0.107',8888))
#开启一个线程处理客户端的读取消息
t = Thread(target=readMsg,args=(client_socket,))
t.start()
#开启一个线程处理客户端的发送消息
t = Thread(target=writeMsg,args=(client_socket,))
t.start()