You need to enable JavaScript to run this app.
优惠活动
大模型
产品
解决方案
定价
更多

能否通过列表启动多个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

相关产品推荐
方舟 Agent Plan

超全模态模型 × Harness 升级,最新支持 Deepseek-V4.1-Flash、GLM-5.3 系列、Doubao-Seedream-5.0-pro、Kimi-K3 (部分), 限时 9.9 元起

最近更新时间:2026.08.08 04:20:19