WebSocket连接异常close code=1008解析：如何解决gateway token缺失问题

1次阅读

没有评论

共计 2233 个字符，预计需要花费 6 分钟才能阅读完成。

WebSocket 协议在 RFC6455 中定义了 1008 状态码，表示 ”Policy Violation”（策略违反），常见于以下场景：

服务端要求身份验证但客户端未提供有效凭证
提供的 token 过期或格式错误
权限系统拒绝连接请求

在微服务架构中，gateway token 通常作为服务间通信的 ” 通行证 ”，其核心作用包括：

身份鉴别 ：确认连接发起方的合法身份
权限控制 ：限制不同服务 / 用户的访问范围
安全审计 ：为后续的日志追踪提供依据

传统 Cookie/Session
优点：兼容性好，浏览器自动管理
缺点：有状态服务增加架构复杂度，跨域限制多
Token-Based 认证
优点：无状态、跨域友好、适合分布式系统
缺点：需要自行处理 token 刷新逻辑

以下是使用 HMAC-SHA256 签名的 JWT 生成代码（Node.js 环境）：

const crypto = require('crypto');

function generateToken(payload, secret) {
  const header = {
    alg: 'HS256',
    typ: 'JWT'
  };

  const encodedHeader = Buffer.from(JSON.stringify(header)).toString('base64');
  const encodedPayload = Buffer.from(JSON.stringify(payload)).toString('base64');

  const signature = crypto
    .createHmac('sha256', secret)
    .update(`${encodedHeader}.${encodedPayload}`)
    .digest('base64');

  return `${encodedHeader}.${encodedPayload}.${signature}`;
}

服务端应在 upgrade 阶段验证 Authorization 头：

GET /chat HTTP/1.1
Host: server.example.com
Upgrade: websocket
Connection: Upgrade
Authorization: Bearer <token>

const WebSocket = require('ws');
const {verifyToken} = require('./auth');

const wss = new WebSocket.Server({port: 8080});

wss.on('connection', (ws, request) => {
  try {const token = request.headers['authorization']?.split(' ')[1];
    if (!token || !verifyToken(token)) {ws.close(1008, 'Unauthorized: gateway token missing');
      return;
    }

    // 认证通过后的业务逻辑
    ws.on('message', (message) => {console.log(`Received: ${message}`);
    });

  } catch (error) {ws.close(1011, 'Server error');
  }
});

const connectWebSocket = (retryCount = 0) => {const ws = new WebSocket('wss://api.example.com');

  ws.onopen = () => {
    ws.send(JSON.stringify({token: localStorage.getItem('jwt_token') 
    }));
  };

  ws.onclose = (event) => {if (event.code === 1008 && retryCount < 3) {
      // 获取新 token 后重连
      refreshToken().then(() => {connectWebSocket(retryCount + 1);
      });
    }
  };
};