使用Python做一个聊天室

lixiangyv

使用 Socket 做的一个聊天室，分为客户端和服务端。

废话不多说，直接上代码：
客户端（ Client.py ）:

1. import socket
   
2. import threading as td
   
3. 
   
4. outString = ''
   
5. inString = ''
   
6. 
   
7. def client_send(client):
   
8.     global outString
   
9.     while True:
   
10.         string = '%s : %s' % (nick, input())
    
11.         client.send(string.encode('utf-8'))
    
12. 
    
13. def client_accept(client):
    
14.     global inString
    
15.     while True:
    
16.         try:
    
17.             inString = client.recv(1024)
    
18.             if not inString:
    
19.                 break
    
20.             if outString != inString:
    
21.                 print(outString)
    
22. 
    
23.         except:
    
24.             break
    
25. 
    
26. 
    
27. nick = input('请输入你的昵称:')
    
28. ip = input('请输入您的 IP:')
    
29. port= 8888
    
30. 
    
31. client = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    
32. client.connect((ip, port))
    
33. client.send(nick.encode('utf-8'))
    
34. 
    
35. 
    
36. td.Thread(target=client_send, args=(client, )).start()
    
37. 
    
38. td.Thread(target=client_accept, args=(client, )).start()
    
39. 
    

复制代码

服务端（ Server.py ）:

1. import socket
   
2. import threading as td
   
3. 
   
4. people = 0
   
5. 
   
6. # 接受
   
7. def clientIn(conn, nick):
   
8.     global data, people
   
9. 
   
10.     while True:
    
11.         try:
    
12.             temp = conn.recv(1024)
    
13.             if not temp:
    
14.                 conn.close()
    
15.                 return
    
16.             NotifyAll(temp)
    
17.             print(data.decode('utf-8'))
    
18.         except:
    
19.             NotifyAll(nick.decode('utf-8') + '断开连接！')
    
20.             people -= 1
    
21.             print(data)
    
22.             return
    
23. 
    
24. def NotifyAll(ss):
    
25.     global data
    
26. 
    
27.     if con.acquire():
    
28.         data = ss
    
29.         con.release()
    
30. 
    
31. con = td.Condition()
    
32. host = input('请输入服务器的IP地址:')
    
33. port = 8888
    
34. data = ''
    
35. 
    
36. server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    
37. server.bind((host, port))
    
38. server.listen(1)
    
39. 
    
40. print('服务器已创建')
    
41.    
    
42. 
    
43. 
    
44. while True:
    
45.     conn, addr = server.accept()
    
46.     nick = conn.recv(1024)
    
47.     NotifyAll('欢迎' + nick.decode('utf-8') + ' 到聊天群！')
    
48.     people += 1
    
49.     print(data)
    
50.     print('当前房间有' + str(people) + '人')
    
51. 
    
52.     conn.send(data.encode('utf-8'))
    
53. 
    
54.     td.Thread(target=clientIn, args=(conn, nick)).start()
    

复制代码

演示：

hjc757

为什么客户之间不能聊天？服务器上有所有客户端消息，客户端之间没有消息

lixiangyv

hjc757 发表于 2020-3-15 02:36
为什么客户之间不能聊天？服务器上有所有客户端消息，客户端之间没有消息

正在改进中...