群聊服务端

服务端Server.py代码如下：

1. 
   
2. # -*- coding: utf-8 -*-
3. #!/usr/bin/env python
4. # @Time : 2018/5/18 16:05
5. # @Desc : 群聊服务端
6. # @File : Server.py
7. # @Software: PyCharm
8. import socket, select
9. host = socket.gethostname()
10. port = 5999
11. addr = (host, port)
12. inputs = []
13. fd_name = {}
15. """
16. 遍历群成员
17. """
18. def who_in_room(w):
19. name_list = []
20. for k in w:
21. name_list.append(w[k])
22. return name_list
24. """
25. 连接
26. """
27. def conn():
28. print "服务端开始运行"
29. ss = socket.socket()
30. ss.bind(addr)
31. ss.listen(5)
32. return ss
34. """
35. 添加新的群成员
36. """
37. def new_coming(ss):
38. client, add = ss.accept()
39. print '欢迎 %s %s' % (client, add)
40. wel = '''欢迎进入聊天室 . 请输入你的名字:'''
41. try:
42. client.send(wel)
43. name = client.recv(1024)
44. inputs.append(client)
45. fd_name[client] = name
46. nameList = "已在线聊天的群成员是 %s" % (who_in_room(fd_name))
47. client.send(nameList)
48. except Exception, e:
49. print e
51. """
52. 遍历聊天信息
53. """
54. def server_run():
55. ss = conn()
56. inputs.append(ss)
57. while True:
58. r, w, e = select.select(inputs, [], [])
59. for temp in r:
60. if temp is ss:
61. new_coming(ss)
62. else:
63. disconnect = False
64. try:
65. data = temp.recv(1024)
66. data = fd_name[temp] + " 说 : "+ data
67. except socket.error:
68. data = fd_name[temp] + "离开聊天室"
69. disconnect = True
70. if disconnect:
71. inputs.remove(temp)
72. print data
73. for other in inputs:
74. if other != ss and other != temp:
75. try:
76. other.send(data)
77. except Exception, e:
78. print e
79. del fd_name[temp]
80. else:
81. print data
82. for other in inputs:
83. if other != ss and other != temp:
84. try:
85. other.send(data)
86. except Exception, e:
87. print e
90. if __name__ == '__main__':
91. server_run()

群聊客户端

客户端Client.py代码如下：

1. 
   
2. # -*- coding: utf-8 -*-
3. #!/usr/bin/env python
4. # @Time : 2018/5/18 16:06
5. # @Desc : 群聊客户端
6. # @File : Client.py
7. # @Software: PyCharm
9. import socket, select, threading
10. host = socket.gethostname()
11. addr = (host, 5999)
13. """
14. 连接
15. """
16. def conn():
17. s = socket.socket()
18. s.connect(addr)
19. return s
21. """
22. 获取群成员
23. """
24. def lis(s):
25. my = [s]
26. while True:
27. r, w, e = select.select(my, [], [])
28. if s in r:
29. try:
30. print s.recv(1024)
31. except socket.error:
32. print "通信出现异常"
33. exit()
35. """
36. 输入聊天
37. """
38. def talk(s):
39. while True:
40. try:
41. info = raw_input()
42. except Exception, e:
43. print 'can\'t input'
44. exit()
45. try:
46. s.send(info)
47. except Exception, e:
48. print e
49. exit()
51. """
52. 主函数，创建聊天和获取群成员线程
53. """
54. def main():
55. ss = conn()
56. t = threading.Thread(target=lis, args=(ss,))
57. t.start()
58. t1 = threading.Thread(target=talk, args=(ss,))
59. t1.start()
62. if __name__ == '__main__':
63. main()

先启动服务端代码，后启动客户端（启动一个，代表一个群成员，可多个）代码，执行结果如下：