服务器套接字上的客户端-服务器聊天程序问题

以下是一个简单的客户端-服务器聊天程序的示例代码：

服务器端代码：

import socket
import threading

def handle_client(client_socket):
    while True:
        # 接收客户端消息
        data = client_socket.recv(1024).decode()
        if not data:
            break
        print("收到客户端消息：", data)
        
        # 发送回复给客户端
        response = "收到您的消息：" + data
        client_socket.send(response.encode())
    
    # 关闭客户端连接
    client_socket.close()

def start_server():
    server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    server_socket.bind(('localhost', 8888))
    server_socket.listen(5)
    
    print("服务器已启动，等待客户端连接...")
    
    while True:
        # 接受客户端连接
        client_socket, addr = server_socket.accept()
        print("客户端已连接：", addr)
        
        # 创建一个线程用于处理客户端连接
        client_thread = threading.Thread(target=handle_client, args=(client_socket,))
        client_thread.start()

start_server()

客户端代码：

import socket

def start_client():
    client_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    client_socket.connect(('localhost', 8888))
    
    while True:
        # 发送消息给服务器
        message = input("请输入消息：")
        client_socket.send(message.encode())
        
        # 接收服务器回复
        response = client_socket.recv(1024).decode()
        print("收到服务器回复：", response)

start_client()

在这个示例中，服务器通过 socket 模块创建了一个套接字并绑定到本地地址和端口。然后，它使用 listen() 方法开始监听来自客户端的连接请求。服务器在一个无限循环中等待客户端连接，并为每个连接创建一个新的线程来处理。

客户端也使用 socket 模块创建了一个套接字，并通过 connect() 方法连接到服务器的地址和端口。然后，它在一个无限循环中等待用户输入消息，并将消息发送给服务器。接下来，它接收服务器的回复，并将其打印出来。

请注意，这只是一个简单的示例，没有考虑到并发性和错误处理。在实际应用中，您可能需要更完善的代码来处理多个并发连接、异常情况等。