如何维持区块链WebSocket连接存活？现有代码出现连接异常问题

我来帮你搞定这个头疼的问题！readyState 3说明连接已经被关闭了，结合你的代码和现象，大概率是心跳机制不匹配服务端要求或者缺少必要的错误处理与重连逻辑，咱们一步步来修复：

可能的问题分析 #

• 你当前的ping是固定10秒发送一次，但可能服务端的超时阈值变了，或者连接已经断开后还在发ping，导致报错
• 缺少错误监听和自动重连逻辑，一旦连接意外断开，无法自动恢复
• 手写的JSON字符串虽然看起来没问题，但用规范方式生成能避免潜在的格式错误

具体解决方案 #

1. 增加错误监听与自动重连机制 #

给WebSocket加上error和close事件监听，一旦连接断开，自动尝试重新连接，不用手动重启服务。

2. 优化心跳逻辑 #

每次发送ping前先检查连接状态，只有当连接处于OPEN状态（readyState === 1）时才发送；同时在连接关闭时清除定时器，避免无效的ping请求触发报错。

3. 规范JSON消息格式 #

用JSON.stringify生成消息字符串，比手写更可靠，能避免拼写或语法错误。

修改后的完整代码 #

class WebSocketClient {
  constructor() {
    this.ws = null;
    this.heartbeatTimer = null;
    this.connect();
  }

  connect() {
    // 创建新连接
    this.ws = new WebSocket('wss://ws.blockchain.info/inv');

    this.ws.on('open', () => {
      console.log('WebSocket连接已建立');
      // 发送订阅请求
      this.ws.send(JSON.stringify({ op: 'unconfirmed_sub' }));
      // 启动心跳
      this.startHeartbeat();
    });

    this.ws.on('message', (data) => {
      // 这里可以添加业务消息处理逻辑
      console.log('收到消息:', data);
    });

    this.ws.on('error', (error) => {
      console.error('WebSocket错误:', error);
    });

    this.ws.on('close', (code, reason) => {
      console.log(`WebSocket连接关闭，代码: ${code}, 原因: ${reason}`);
      // 清除心跳定时器
      this.stopHeartbeat();
      // 延迟3秒后尝试重连
      setTimeout(() => {
        console.log('尝试重新连接...');
        this.connect();
      }, 3000);
    });
  }

  startHeartbeat() {
    // 每10秒发送一次ping，先检查连接状态
    this.heartbeatTimer = setInterval(() => {
      if (this.ws && this.ws.readyState === WebSocket.OPEN) {
        this.ws.send(JSON.stringify({ op: 'ping' }));
        console.log('发送ping心跳');
      }
    }, 10000);
  }

  stopHeartbeat() {
    if (this.heartbeatTimer) {
      clearInterval(this.heartbeatTimer);
      this.heartbeatTimer = null;
    }
  }
}

// 初始化客户端
const client = new WebSocketClient();

额外说明 #

• 如果调整后还是会断，可以尝试缩短ping间隔（比如5秒），或者留意服务端是否有公开的心跳频率要求
• 生产环境中可以给重连逻辑增加重试次数限制，避免无限重连浪费资源
• 可以添加更详细的日志，方便后续排查连接异常问题

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