第4章连接管理

4、连接管理：连接池设计、自动重连机制、连接状态监控

连接管理这事儿，说白了就是让你的交易系统跟交易所之间保持「心跳同步」。我见过太多新手，代码写得挺漂亮，结果一遇到网络抖动，整个系统就崩了。嗯，今天咱们就把这块硬骨头啃下来。

4.1 连接池设计：别让每次握手都从头来过

你想想看，每次跟交易所建立连接，都要经历TCP三次握手、SSL/TLS握手、鉴权、会话建立……这一套流程下来，少说几百毫秒。如果行情来了，你还在握手，黄花菜都凉了。

连接池的核心思想：提前创建一批连接，放在池子里备用。用的时候直接拿，用完归还，别销毁。

我个人习惯：每个交易所维护一个独立的连接池，池子大小根据行情通道数来定。比如币安有20个行情通道，我就开25个连接，留5个冗余。

来看一个简单的连接池设计：

class ConnectionPool:
    def __init__(self, exchange, min_size=5, max_size=20):
        self.exchange = exchange
        self.min_size = min_size
        self.max_size = max_size
        self._idle = []      # 空闲连接
        self._active = set() # 活跃连接
        self._lock = threading.Lock()
        
        # 预热：创建最小连接数
        for _ in range(min_size):
            conn = self._create_connection()
            self._idle.append(conn)
    
    def acquire(self):
        """从池中获取一个连接"""
        with self._lock:
            if self._idle:
                conn = self._idle.pop()
            elif len(self._active) < self.max_size:
                conn = self._create_connection()
            else:
                # 池子满了，等待归还
                return self._wait_for_connection()
            
            self._active.add(conn)
            return conn
    
    def release(self, conn):
        """归还连接到池中"""
        with self._lock:
            self._active.discard(conn)
            if conn.is_alive():
                self._idle.append(conn)
            else:
                conn.close()
                # 补充一个新连接
                self._idle.append(self._create_connection())

避坑指南：我曾经在连接池里犯过一个低级错误——忘记检查连接是否还活着。结果拿到的连接已经断开了，发出去的订单全丢了。从那以后，我每次从池子里拿连接，都会先发一个ping包确认一下。

4.2 自动重连机制：断了就接，别犹豫

网络不可能100%稳定。交易所的服务器也会重启，你的网络也会波动。关键是断了之后怎么办。

重连策略，我总结了三层：

快速重连：断开后立即尝试，间隔1秒、2秒、4秒……指数退避
慢速重连：连续失败5次后，改为30秒一次，防止打爆交易所
人工介入：连续失败30分钟，发告警，等人来处理

来看一个带指数退避的重连器：

class Reconnector:
    def __init__(self, max_retries=10, base_delay=1.0):
        self.max_retries = max_retries
        self.base_delay = base_delay
        self.retry_count = 0
        self._stop_event = threading.Event()
    
    def run(self, connect_func):
        """持续尝试重连，直到成功或放弃"""
        while not self._stop_event.is_set():
            try:
                connect_func()
                self.retry_count = 0  # 连接成功，重置计数
                return True
            except Exception as e:
                self.retry_count += 1
                if self.retry_count > self.max_retries:
                    # 彻底放弃，发告警
                    self._send_alert(f"重连失败{self.max_retries}次，请人工介入")
                    return False
                
                # 指数退避 + 随机抖动
                delay = self.base_delay * (2 ** self.retry_count)
                delay += random.uniform(0, 0.5)  # 防止所有客户端同时重连
                time.sleep(min(delay, 60))  # 最大不超过60秒

注意：重连时一定要带上鉴权信息。我见过有人重连后忘了重新登录，结果行情数据收到了，但下单接口一直报401。嗯，这种bug排查起来特别痛苦。

4.3 连接状态监控：你得知道它活着还是死了

连接池有了，重连机制也有了，但你怎么知道当前连接的状态？总不能等用户投诉了才发现吧。

我建议：每个连接维护一个状态机，实时上报状态变化。

连接状态一般有这几种：

状态	含义	触发条件
INIT	初始化中	连接刚创建
CONNECTED	已连接	TCP握手成功
AUTHENTICATED	已鉴权	登录成功
SUBSCRIBED	已订阅	行情通道订阅成功
DISCONNECTED	已断开	网络异常或主动关闭
RECONNECTING	重连中	自动重连触发
DEAD	已死亡	重连失败次数超限

监控的核心指标，我一般关注三个：

连接存活率：当前活跃连接数 / 总连接数，低于80%就要报警
重连次数：单个连接在1小时内重连超过3次，说明网络不稳定
消息延迟：从交易所发出到我们收到的时间差，超过500ms就要排查

实战经验：我曾经在监控面板上放过一个「心跳灯」，每个交易所一个绿灯/红灯。绿灯亮着说明连接正常，红灯闪烁说明在重连。运维同事一看就懂，不用翻日志。

4.4 整体架构图

说了这么多，咱们用一张图把整个连接管理体系串起来：

这张图其实就三层：最下面是交易所，中间是连接池，上面是重连和监控。每一层各司其职，出了问题也能快速定位。

核心要点：连接管理不是写个重连循环就完事了。你得考虑池化复用、状态监控、告警通知，这三者缺一不可。我见过太多系统，重连写了但没监控，结果断了三天都没人知道。

好了，连接管理这块就聊到这儿。记住一句话：连接池保性能，重连保可用，监控保安心。这三板斧砍下去，你的行情聚合系统至少能扛住99%的网络问题。

公众号:蓝海资料掘金营，微信deep3321

📚 课程目录

4、连接管理：连接池设计、自动重连机制、连接状态监控

4.1 连接池设计：别让每次握手都从头来过

4.2 自动重连机制：断了就接，别犹豫

4.3 连接状态监控：你得知道它活着还是死了

4.4 整体架构图