WebSocket 连接 60 秒后意外关闭（1006 错误）的完整解决方案-js教程-PHP中文网

WebSocket 连接 60 秒后意外关闭（1006 错误）的完整解决方案

WebSocket 在浏览器中运行 60 秒后触发 1006 错误（连接异常终止），即使已实现每 5 秒 Ping-Pong 心跳，根本原因在于 Node.js http.Server 默认超时机制与 ws 库 noServer: true 模式不兼容，导致底层 TCP 连接被静默关闭。

websocket 在浏览器中运行 60 秒后触发 1006 错误（连接异常终止），即使已实现每 5 秒 ping-pong 心跳，根本原因在于 node.js `http.server` 默认超时机制与 `ws` 库 `noserver: true` 模式不兼容，导致底层 tcp 连接被静默关闭。

WebSocket 1006 错误是客户端常见的“连接异常关闭”状态码，它不表示协议级错误（如 1002/1003），而是表明 TCP 连接在未正常发送 close frame 的情况下突然中断——典型表现为浏览器控制台仅显示 Closed 1006 :（空 reason），且 onerror 事件完全不触发。在您的代码中，问题根源并非心跳缺失，而是服务端架构设计缺陷：createServer().handleUpgrade(...) 配合 noServer: true 时，Node.js 内置的 http.Server 仍会为每个 upgrade 请求创建一个 socket，但因未被 http 模块“接管”，该 socket 会受默认 server.timeout（60 秒）和 server.headersTimeout（也常为 60 秒）双重约束，最终被内核强制断连。

✅ 正确的服务端初始化方式（推荐两种）

方案一：使用 ws.Server({ server })（最简健壮）

const { createServer } = require('http');
const WebSocket = require('ws');

const server = createServer(); // 创建标准 HTTP 服务器
const wss = new WebSocket.Server({ server }); // 自动绑定 upgrade 事件

wss.on('connection', (ws, req) => {
  console.log('Client connected:', req.socket.remoteAddress);

  ws.on('message', (data) => {
    const message = data.toString();
    if (message === 'Ping') ws.send('Pong');
    console.log('Received:', message);
  });

  ws.on('close', () => console.log('Connection closed'));
  ws.on('error', (err) => console.error('WS error:', err));
});

server.listen(8000, '127.0.0.1', () => {
  console.log('Server running on http://127.0.0.1:8000');
});

✅ 优势：ws 自动处理 upgrade 事件并禁用相关超时；无需手动调用 handleUpgrade；天然支持 HTTPS（只需传入 https.Server）。

方案二：显式监听 upgrade 并手动分发（高阶可控）

const { createServer } = require('http');
const WebSocket = require('ws');

const server = createServer();
const wss = new WebSocket.Server({ noServer: true });

// 关键：禁用 HTTP 超时，避免 socket 被误杀
server.setTimeout(0); // 禁用 socket 超时（单位 ms）
server.keepAliveTimeout = 0; // 禁用 keep-alive 超时（Node.js ≥ 18.0.0）

server.on('upgrade', (req, socket, head) => {
  // 手动验证并升级（可加入鉴权逻辑）
  if (req.headers.upgrade !== 'websocket') {
    socket.destroy();
    return;
  }
  wss.handleUpgrade(req, socket, head, (ws) => {
    wss.emit('connection', ws, req);
  });
});

wss.on('connection', (ws) => {
  // 同上：处理消息、心跳、关闭等
  ws.on('message', (data) => {
    if (data.toString() === 'Ping') ws.send('Pong');
  });
  ws.on('close', () => console.log('Client disconnected'));
});

server.listen(8000, '127.0.0.1');

⚠️ 注意：若选用此方案，必须显式设置 server.setTimeout(0)，否则 60 秒超时无法规避。

WebSocket 8.18.2

WebSocket 8.18.2 是该协议规范的一个重要迭代版本，主要优化了连接稳定性与数据传输效率。它通过全双工通信机制，允许客户端与服务器在单一长连接上实时交换数据，大幅降低传统 HTTP 轮询的开销。该版本增强了心跳保活、自动重连及二进制帧传输能力，适用于即时通讯、在线游戏及金融行情推送等低延迟场景，为开发者提供更可靠的实时网络交互基础。

下载

? 客户端补充建议（增强健壮性）

虽然服务端修复是关键，但客户端也应完善容错：

let ws;
function connect() {
  ws = new WebSocket('ws://127.0.0.1:8000');

  ws.onopen = () => {
    console.log('Connected');
    sendPing();
  };

  ws.onmessage = (e) => console.log('Received:', e.data);

  ws.onclose = (e) => {
    console.warn(`Disconnected: ${e.code} - ${e.reason || 'No reason'}`);
    if (e.code !== 1000) setTimeout(connect, 1000); // 非正常关闭自动重连
  };

  ws.onerror = (err) => console.error('WebSocket error:', err);

  function sendPing() {
    if (ws.readyState === WebSocket.OPEN) {
      ws.send('Ping');
      setTimeout(sendPing, 5000);
    }
  }
}
connect();