并发服务器的实现

封面图 • 2023-10-23 • 嵌入式

并发服务器的实现

并发服务器是一种能够同时处理多个客户端请求的服务器。这种服务器通常使用多线程、多进程或异步I/O等技术，以实现同时处理多个连接。下面是一个简单的并发服务器的实现示例，使用 Python 的 socket 库和多线程：

python
```
import socket
import threading

def handle_client(client_socket):
    # 处理客户端请求的函数
    request = client_socket.recv(1024)
    print("Received:", request.decode())
    
    # 在这里添加处理客户端请求的业务逻辑
    
    # 发送响应
    response = "Hello, client!"
    client_socket.send(response.encode())
    
    # 关闭客户端套接字
    client_socket.close()

def run_server():
    # 创建TCP套接字
    server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    
    # 允许地址重用
    server_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
    
    # 绑定地址和端口
    server_address = ('localhost', 8888)
    server_socket.bind(server_address)
    
    # 监听连接
    server_socket.listen(5)
    print("Server listening on", server_address)

try:
        while True:
            # 等待客户端连接
            client_socket, client_address = server_socket.accept()
            print("Accepted connection from", client_address)

# 创建线程处理客户端请求
            client_handler = threading.Thread(target=handle_client, args=(client_socket,))
            client_handler.start()

except KeyboardInterrupt:
        # 在收到中断信号时关闭服务器
        print("Server shutting down.")
        server_socket.close()

if __name__ == "__main__":
    run_server()
```
在这个示例中：

run_server 函数创建了一个 TCP 套接字，绑定到指定地址和端口，并开始监听连接。
handle_client 函数用于处理单个客户端的请求，你可以在这里添加自己的业务逻辑。
主循环中使用 server_socket.accept() 等待客户端连接，一旦有连接，就创建一个新线程（client_handler）来处理客户端的请求。
这是一个简单的例子，实际生产环境中可能需要更多的安全性和错误处理。并发服务器的实现还可以使用其他技术，如多进程、异步I/O等，具体选择取决于应用程序的需求和性能要求。