Python使用socket模块，实现服务器和客户端进行数据交互（聊天室功能）

Python中的socket模块提供了一个强大的网络通信框架，可以用于创建服务器和客户端之间的连接。要实现一个简单的聊天室功能，你需要做以下几个步骤：

1. **导入必要的库**：
首先，需要导入`socket`、`threading`（用于线程处理）、`queue`（队列操作，如消息缓冲）等模块。

2. **创建服务器端**：
- 创建一个TCP套接字（`socket.socket(socket.AF_INET, socket.SOCK_STREAM)`）。
- 绑定地址（`server.bind((host, port))`）并监听连接（`server.listen()`）。
- 使用`while True`循环接受新客户端的连接请求，并为每个新连接创建一个新的线程。

3. **处理客户端连接**：
- 当有新客户端连接时，从队列中获取一条待发送的消息，然后通过`client.send()`将消息发送给客户端。
- 接收客户端的数据（例如使用`recv()`函数），并将其添加到队列中供其他客户端接收。

4. **创建客户端**：
- 客户端也需要创建一个TCP套接字，然后连接到服务器。
- 发送用户名和其他初始化信息，然后进入一个无限循环，不断读取用户输入，打包成消息并发送给服务器，同时接收并显示来自服务器的消息。

5. **关闭连接**：
在完成交流后，确保客户端和服务器都正确关闭套接字连接。

这里是一个简化版的示例代码片段：

import socket
import threading
import queue

# 服务器部分
def handle_client(client_socket):
    message_queue = queue.Queue()
    client_socket.send(b"欢迎来到聊天室!")
    
    while True:
        try:
            data = client_socket.recv(1024)
            if not data:
                break
            # 将收到的数据添加到队列
            message_queue.put(data.decode())
        except Exception as e:
            print(f"客户端异常：{e}")
            client_socket.close()

    client_socket.close()

# 主函数
def server():
    host = 'localhost'
    port = 12345
    server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    server_socket.bind((host, port))
    server_socket.listen()

    print(f"服务器正在监听 {port} 端口...")
    while True:
        client, addr = server_socket.accept()
        print(f"新连接来自: {addr[0]}:{addr[1]}")
        thread = threading.Thread(target=handle_client, args=(client,))
        thread.start()

# 客户端部分省略，类似地建立连接并发送/接收数据

# 启动服务器
server()