Node.js使用Bitfinex API WebSocket重连后无法接收事件问题

兄弟，我之前也踩过bitfinex-api-node这个WebSocket静默断开+重连后收不到数据的大坑！折腾了好几天才搞明白问题出在哪——这个包的WebSocket实例断开后会残留一些内部状态，手动调用close再重连时，旧的订阅绑定和实例状态会干扰新连接，导致收不到事件。给你分享一套我亲测有效的解决方案：

核心思路 #

每次重连都创建全新的WebSocket实例，并重新执行订阅逻辑，彻底抛弃旧实例的残留状态，避免状态污染导致的事件丢失。同时加上重连退避策略，防止频繁连接被交易所限制。

完整代码实现 #

const { WSv2 } = require('bitfinex-api-node');

let wsInstance = null;
let reconnectAttempts = 0;
const MAX_RECONNECT_ATTEMPTS = 10; // 最大重连次数，可根据需求调整

// 封装连接+订阅的核心逻辑，每次重连都调用这个函数
function setupBitfinexConnection() {
  // 先安全销毁旧实例（如果存在）
  if (wsInstance) {
    try {
      wsInstance.close();
    } catch (err) {
      console.error('清理旧WebSocket实例出错:', err);
    }
    wsInstance = null;
  }

  // 创建全新的WS实例
  wsInstance = new WSv2({
    transform: true, // 自动转换数据为友好格式，可选
    // 如需认证接口，在这里配置密钥
    // apiKey: '你的API密钥',
    // apiSecret: '你的API密钥'
  });

  // 连接成功后立即订阅数据
  wsInstance.on('open', () => {
    console.log('WebSocket连接成功！');
    reconnectAttempts = 0; // 重置重连次数
    // 订阅BTC/USD的1分钟K线，可根据需求修改交易对和时间框架
    wsInstance.subscribeCandles('tBTCUSD', '1m');
  });

  // 接收蜡烛数据的核心逻辑
  wsInstance.on('candle', (candle) => {
    console.log('收到K线数据:', candle);
    // 在这里写你的业务处理代码
  });

  // 监听错误事件，方便排查问题
  wsInstance.on('error', (err) => {
    console.error('WebSocket错误:', err);
  });

  // 连接断开时触发重连逻辑
  wsInstance.on('close', () => {
    console.log('WebSocket连接断开，准备重连...');
    if (reconnectAttempts < MAX_RECONNECT_ATTEMPTS) {
      reconnectAttempts++;
      // 退避策略：重连间隔随次数递增，避免频繁请求被限制
      const delay = 5000 * reconnectAttempts;
      console.log(`等待${delay/1000}秒后重连（第${reconnectAttempts}次）`);
      setTimeout(setupBitfinexConnection, delay);
    } else {
      console.error('已达到最大重连次数，停止尝试');
    }
  });

  // 启动连接
  wsInstance.open();
}

// 初始化第一次连接
setupBitfinexConnection();

// 测试手动重连（可选，注释掉即可）
// setTimeout(() => {
//   console.log('手动触发断开连接测试');
//   wsInstance.close();
// }, 10000);

关键细节说明 #

• 抛弃旧实例：每次重连都创建新的WSv2实例，彻底避免旧实例的状态残留问题——这是解决你手动重连后收不到事件的核心。
• 重新订阅：必须在open事件里重新执行订阅操作，因为订阅是绑定到当前WebSocket实例的，旧实例的订阅不会自动迁移到新实例。
• 退避策略：重连间隔随尝试次数递增，既保证尽快恢复连接，又不会因为频繁请求被Bitfinex的风控系统限制。
• 错误处理：加上error事件监听，方便排查连接过程中出现的异常。

亲测这套逻辑可以解决静默断开和手动重连后无事件的问题，已经在生产环境稳定运行好几个月了。

内容的提问来源于stack exchange，提问作者oystersauce