怎么用Python打造一个多人聊天室

python

小亿

119

2024-03-18 20:59:39

栏目: 编程语言

要使用Python创建一个多人聊天室，可以借助Socket模块来实现网络通信功能。以下是一个简单的示例代码：

创建服务器端代码：

import socket
import threading

# 服务器端IP和端口
SERVER_HOST = '0.0.0.0'
SERVER_PORT = 8888

# 用于存储客户端连接
clients = []

def handle_client(client_socket):
    while True:
        try:
            message = client_socket.recv(1024).decode()
            print(message)
            broadcast(message, client_socket)
        except:
            clients.remove(client_socket)
            client_socket.close()
            break

def broadcast(message, client_socket):
    for client in clients:
        if client != client_socket:
            try:
                client.send(message.encode())
            except:
                client.close()
                clients.remove(client)

# 创建服务器Socket
server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
server_socket.bind((SERVER_HOST, SERVER_PORT))
server_socket.listen(5)

print(f"Server is running on {SERVER_HOST}:{SERVER_PORT}")

while True:
    client_socket, client_address = server_socket.accept()
    clients.append(client_socket)
    print(f"{client_address} connected")

    client_thread = threading.Thread(target=handle_client, args=(client_socket,))
    client_thread.start()

创建客户端代码：

import socket
import threading

# 服务器端IP和端口
SERVER_HOST = '127.0.0.1'
SERVER_PORT = 8888

def receive_messages(client_socket):
    while True:
        try:
            message = client_socket.recv(1024).decode()
            print(message)
        except:
            break

# 创建客户端Socket
client_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
client_socket.connect((SERVER_HOST, SERVER_PORT))

print("Connected to the server")

receive_thread = threading.Thread(target=receive_messages, args=(client_socket,))
receive_thread.start()

while True:
    message = input()
    client_socket.send(message.encode())

通过运行以上代码，就可以创建一个简单的多人聊天室。用户可以通过客户端连接到服务器，并发送消息给其他所有用户。在服务器端，所有接入的客户端都会被存储起来，并在接收到消息时广播给所有客户端。

怎么用Python打造一个多人聊天室

最新问答

相关标签