本文實例為大家分享了python socket實現聊天室的具體代碼，供大家參考，具體內容如下

server端

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)

client端

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)

以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持好吧啦網。