能否通过列表启动多个TCP Socket服务器?求示例及代码验证
多TCP Socket服务器实现验证与示例
你的实现思路是可行的,但有个核心细节需要注意:socketserver.TCPServer的serve_forever()是阻塞方法,如果直接遍历列表调用它,第一个服务器会独占主线程,后续的服务器永远没有启动机会。解决这个问题的关键是给每个服务器分配独立的线程(或进程)来运行。
以下是可运行的示例代码:
1. 自定义请求处理器
首先定义处理客户端请求的逻辑:
from socketserver import TCPServer, StreamRequestHandler import threading class MyRequestHandler(StreamRequestHandler): def handle(self): # 读取客户端发送的数据 client_data = self.request.recv(1024).strip() print(f"[{self.client_address}] 收到数据: {client_data.decode('utf-8')}") # 向客户端发送响应 self.wfile.write(b"Server received your message")
2. 创建并启动多服务器
# 模拟设备配置列表,每个元素对应一个服务器的(主机, 端口) devices = [("127.0.0.1", 8001), ("127.0.0.1", 8002), ("127.0.0.1", 8003)] server_list = [] # 初始化所有服务器实例 for host, port in devices: try: server = TCPServer((host, port), MyRequestHandler) server_list.append(server) print(f"已初始化服务器: {host}:{port}") except OSError as e: print(f"启动服务器 {host}:{port} 失败: {e}") # 用线程启动每个服务器 for server in server_list: # 设置守护线程,确保主线程退出时服务器线程随之结束 threading.Thread(target=server.serve_forever, daemon=True).start() print(f"服务器 {server.server_address} 已启动") # 主线程保持存活,避免程序直接退出 try: while True: input("按Ctrl+C关闭所有服务器\n") except KeyboardInterrupt: # 优雅关闭所有服务器 print("\n开始关闭所有服务器...") for server in server_list: server.shutdown() server.server_close() print(f"服务器 {server.server_address} 已关闭")
关键说明
- 每个服务器必须绑定唯一且未被占用的端口,否则会抛出端口占用错误
- 使用守护线程启动服务器,避免主线程退出后服务器线程残留
- 捕获
KeyboardInterrupt信号可以实现优雅关闭,避免强制终止导致的资源泄漏 - 你提到的设备数量控制逻辑可以正常保留,只要确保端口不冲突即可
内容的提问来源于stack exchange,提问作者Jose Cintron
相关产品推荐
相关产品推荐

