基于socket和C/S模型的聊天室 功能要求实现单个server与多个client互发消息2

基于socket和C/S模型的聊天室，实现单个server与多个client互发消息的功能需要以下步骤：

1. 服务器端需要创建一个socket，绑定IP地址和端口号，并监听客户端的连接请求。

2. 客户端需要创建一个socket，并连接服务器端。

3. 服务器端接收客户端的连接请求后，需要创建一个子线程来处理该客户端的消息。

4. 子线程需要不断接收客户端发送的消息，然后转发给其他客户端。

5. 客户端需要不断接收服务器端发送的消息。

6. 当客户端发送消息时，需要将消息发送给服务器端。

7. 服务器端接收到客户端发送的消息后，需要转发给其他客户端。

下面是一个简单的示例代码，其中服务器端监听的端口号为8888：

服务器端代码：

import socket
import threading

# 存储所有客户端socket的列表
clients = []

def handle_client(client_socket):
    # 将客户端socket添加到列表中
    clients.append(client_socket)
    while True:
        # 接收客户端发送的消息
        data = client_socket.recv(1024)
        if not data:
            break
        # 将消息转发给其他客户端
        for c in clients:
            if c != client_socket:
                c.send(data)
    # 将客户端socket从列表中移除
    clients.remove(client_socket)
    client_socket.close()

def main():
    # 创建一个socket
    server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    # 绑定IP地址和端口号
    server_socket.bind(('127.0.0.1', 8888))
    # 监听客户端连接请求
    server_socket.listen(5)
    print('Server started, listening on port 8888...')
    while True:
        # 接收客户端连接请求
        client_socket, client_address = server_socket.accept()
        print('Client {} connected.'.format(client_address))
        # 创建一个子线程来处理客户端消息
        t = threading.Thread(target=handle_client, args=(client_socket,))
        t.start()

if __name__ == '__main__':
    main()

客户端代码：

import socket
import threading

def receive_msg(client_socket):
    while True:
        # 接收服务器端发送的消息
        data = client_socket.recv(1024)
        if not data:
            break
        print(data.decode('utf-8'))

def main():
    # 创建一个socket
    client_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    # 连接服务器端
    client_socket.connect(('127.0.0.1', 8888))
    # 创建一个子线程来接收服务器端消息
    t = threading.Thread(target=receive_msg, args=(client_socket,))
    t.start()
    while True:
        # 发送消息给服务器端
        data = input()
        client_socket.send(data.encode('utf-8'))

if __name__ == '__main__':
    main()

运行以上代码，可以启动一个聊天室，并在多个客户端之间互发消息。