本文實(shí)例為大家分享了python socket實(shí)現(xiàn)聊天室的具體代碼，供大家參考，具體內(nèi)容如下
server端
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
|
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)) # 發(fā)數(shù)據(jù) soc.send(msg.encode("utf-8"))'''用于監(jiān)聽(tīng)已經(jīng)建立連接的客戶端發(fā)來(lái)的消息'''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")) #接收到來(lái)自客戶端的消息。 eg: data = {'to_addr':'msg':''} print('來(lái)自%s的消息：%s'%(ip,data['msg'])) # 客戶端發(fā)過(guò)來(lái)的數(shù)據(jù) # 數(shù)據(jù)有兩種情況 一種是發(fā)給所有人的 另一種單獨(dú)發(fā)給某一個(gè)人的 if data.get('to_addr'): #傳過(guò)來(lái)一個(gè)json格式的字典，如果這個(gè)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'] # # 從所有客戶端列表中找到這一個(gè) 發(fā)給它 # to_addr = data["to_addr"] # # print(data["to_addr"],"_______________") # soc = clients.get(to_addr) # send_msg(soc,data["msg"]) # else: # # 遍歷所有客戶端 發(fā)給每一個(gè)人 # for k,soc in clients.items(): # # if soc != c: # send_msg(soc,data["msg"])while True: '''以下代碼用于檢測(cè)是否有客戶端連接''' 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)聽(tīng)已經(jīng)建立連接的客戶端發(fā)來(lái)的消息''' pool.submit(task,add,c) |
client端
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
|
import socket,json,structfrom threading import Threadc = 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) |
以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持服務(wù)器之家。
原文鏈接：https://blog.csdn.net/qq_36019490/article/details/88853021
