python socket實現(xiàn)聊天室
更新時間:2021年07月08日 08:41:08 作者:不會玩csdn
這篇文章主要為大家詳細(xì)介紹了python socket實現(xiàn)聊天室,文中示例代碼介紹的非常詳細(xì),具有一定的參考價值,感興趣的小伙伴們可以參考一下
本文實例為大家分享了python socket實現(xiàn)聊天室的具體代碼,供大家參考,具體內(nèi)容如下
server端
import socket import json,struct from concurrent.futures import ThreadPoolExecutor debug = True s = 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)) # 發(fā)數(shù)據(jù) soc.send(msg.encode("utf-8")) '''用于監(jiān)聽已經(jīng)建立連接的客戶端發(fā)來的消息''' 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'])) # 客戶端發(fā)過來的數(shù)據(jù) # 數(shù)據(jù)有兩種情況 一種是發(fā)給所有人的 另一種單獨發(fā)給某一個人的 if data.get('to_addr'): #傳過來一個json格式的字典,如果這個to_addr不是空的話,就私發(fā)給目標(biāo)客戶 target_ip = data["to_addr"] #從data字典里中獲取目標(biāo)ip target_conn = clients.get(target_ip) #獲取目標(biāo)客戶的conn鏈接 send_msg(target_conn,data['msg']) #發(fā)送訊息 else: for ip,conn in clients.items(): # if c != target_conn: send_msg(conn,data['msg'])#data['msg'] # # 從所有客戶端列表中找到這一個 發(fā)給它 # to_addr = data["to_addr"] # # print(data["to_addr"],"_______________") # soc = clients.get(to_addr) # send_msg(soc,data["msg"]) # else: # # 遍歷所有客戶端 發(fā)給每一個人 # for k,soc in clients.items(): # # if soc != c: # send_msg(soc,data["msg"]) while True: '''以下代碼用于檢測是否有客戶端連接''' c,add = s.accept() print("%s" % add[0],"連接到服務(wù)器!") clients[add[0]] = c # 把ip地址作為key,conn作為value存入clients字典中 ,clients = {'192.188.3.4':conn鏈接} if debug: print('clients=%s'%clients) '''以下代碼用于監(jiān)聽已經(jīng)建立連接的客戶端發(fā)來的消息''' pool.submit(task,add,c)
client端
import socket,json,struct from threading import Thread c = socket.socket() c.connect(("127.0.0.1",8848)) print("連接服務(wù)器成功!") 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) # 開啟線程處理接收數(shù)據(jù) 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)
以上就是本文的全部內(nèi)容,希望對大家的學(xué)習(xí)有所幫助,也希望大家多多支持腳本之家。
相關(guān)文章
pymongo實現(xiàn)控制mongodb中數(shù)字字段做加法的方法
這篇文章主要介紹了pymongo實現(xiàn)控制mongodb中數(shù)字字段做加法的方法,涉及Python使用pymongo模塊操作mongodb數(shù)據(jù)庫字段的技巧,具有一定參考借鑒價值,需要的朋友可以參考下2015-03-03Python使用sqlite3模塊內(nèi)置數(shù)據(jù)庫
這篇文章主要介紹了Python使用sqlite3模塊內(nèi)置數(shù)據(jù)庫,文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友可以參考下2020-05-05樸素貝葉斯分類算法原理與Python實現(xiàn)與使用方法案例
這篇文章主要介紹了樸素貝葉斯分類算法原理與Python實現(xiàn)與使用方法,結(jié)合具體實例形式分析了樸素貝葉斯分類算法的概念、原理、實現(xiàn)流程與相關(guān)操作技巧,需要的朋友可以參考下2018-06-06基于Python+tkinter實現(xiàn)簡易計算器桌面軟件
tkinter是Python的標(biāo)準(zhǔn)GUI庫,對于初學(xué)者來說,它非常友好,因為它提供了大量的預(yù)制部件,本文小編就來帶大家詳細(xì)一下如何利用tkinter制作一個簡易計算器吧2023-09-09