请用python写一个基于TCP的多人聊天室
时间: 2023-12-03 13:04:28 浏览: 103
基于Python Tkiner、thread与socket实现的简单多人聊天室,在Python中创建TCP服务器与客户端进行通信
5星 · 资源好评率100%
好的,以下是一个简单的基于TCP的多人聊天室的Python代码:
```python
import socket
import threading
# 设置服务器IP和端口号
SERVER_HOST = '0.0.0.0'
SERVER_PORT = 8000
# 设置客户端最大连接数
MAX_CLIENTS = 100
# 存储所有客户端的socket对象
clients = []
# 初始化服务器socket
server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
server_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
server_socket.bind((SERVER_HOST, SERVER_PORT))
server_socket.listen(MAX_CLIENTS)
print(f'Server started on {SERVER_HOST}:{SERVER_PORT}')
def handle_client(client_socket):
# 将新客户端添加到存储列表中
clients.append(client_socket)
while True:
try:
# 接收来自客户端的消息
message = client_socket.recv(1024).decode('utf-8')
if message:
# 向所有客户端广播消息
broadcast(f'{message}', client_socket)
else:
# 移除断开连接的客户端
remove(client_socket)
except:
# 移除断开连接的客户端
remove(client_socket)
def broadcast(message, sender):
for client in clients:
if client != sender:
try:
# 发送消息给客户端
client.send(message.encode('utf-8'))
except:
# 移除断开连接的客户端
remove(client)
def remove(client_socket):
if client_socket in clients:
clients.remove(client_socket)
client_socket.close()
while True:
# 接收新连接
client_socket, client_address = server_socket.accept()
print(f'{client_address[0]}:{client_address[1]} connected')
# 为新连接创建一个线程
client_thread = threading.Thread(target=handle_client, args=(client_socket,))
client_thread.start()
```
这是一个简单的多人聊天室,可以同时处理多个客户端连接。当新的客户端连接到服务器时,服务器会将其添加到存储列表中,然后启动一个新的线程来处理该客户端的消息。当客户端发送消息时,服务器将该消息广播到所有其他客户端。如果客户端断开连接,服务器将从存储列表中删除该客户端并关闭其socket连接。
阅读全文