自学教程：python socket实现聊天室

import socketimport json,structfrom concurrent.futures import ThreadPoolExecutordebug = Trues = socket.socket()s.bind(("127.0.0.1",8848))s.listen()clients = {}pool = ThreadPoolExecutor(100)def send_msg(soc, msg):    l = len(msg.encode("utf-8"))    soc.send(struct.pack("q",l))    # 发数据    soc.send(msg.encode("utf-8"))'''用于监听已经建立连接的客户端发来的消息'''def task(ip,c):    while True:        l = c.recv(8)        ls = struct.unpack("q",l)[0]        data = json.loads(c.recv(ls).decode("utf-8"))   #接收到来自客户端的消息。 eg:    data = {'to_addr':'msg':''}        print('来自%s的消息：%s'%(ip,data['msg']))        # 客户端发过来的数据        # 数据有两种情况 一种是发给所有人的 另一种单独发给某一个人的        if data.get('to_addr'): #传过来一个json格式的字典，如果这个to_addr不是空的话，就私发给目标客户            target_ip = data["to_addr"]        #从data字典里中获取目标ip            target_conn = clients.get(target_ip)   #获取目标客户的conn链接            send_msg(target_conn,data['msg'])    #发送讯息        else:            for ip,conn in clients.items():                # if c != target_conn:                send_msg(conn,data['msg'])#data['msg']        #     # 从所有客户端列表中找到这一个  发给它        #     to_addr = data["to_addr"]        #     # print(data["to_addr"],"_______________")        #     soc = clients.get(to_addr)        #     send_msg(soc,data["msg"])        # else:        #     # 遍历所有客户端 发给每一个人        #     for k,soc in clients.items():        #         # if soc != c:        #             send_msg(soc,data["msg"])while True:    '''以下代码用于检测是否有客户端连接'''    c,add = s.accept()    print("%s" % add[0],"连接到服务器!")    clients[add[0]] = c  # 把ip地址作为key，conn作为value存入clients字典中 ,clients = {'192.188.3.4':conn链接}    if debug:        print('clients=%s'%clients)    '''以下代码用于监听已经建立连接的客户端发来的消息'''    pool.submit(task,add,c)

import socket,json,structfrom threading import Threadc = socket.socket()c.connect(("127.0.0.1",8848))print("连接服务器成功!")def recver():    while True:        lens_bytes = c.recv(8)        lens = struct.unpack("q", lens_bytes)[0]        recv_msg = c.recv(lens).decode("utf-8")        print(recv_msg)# 开启线程处理接收数据Thread(target=recver).start()while True:    msg = input(">>>>:").strip() # 阻塞    if "@" in msg:        info = {"msg":msg.split("@")[0],"to_addr":msg.split("@")[1]}    else:        info = {"msg": msg}    data = json.dumps(info).encode("utf-8")    c.send(struct.pack("q",len(data)))    c.send(data)