websocket-engineer

用途

本技能提供实时通信领域的专业能力，专注于 WebSocket 架构、Socket.IO 与事件驱动系统，用于构建低延迟、双向通信系统，并可扩展至百万级并发连接。

适用场景

构建聊天应用、实时仪表盘或多人游戏
水平扩展 WebSocket 服务器（Redis Adapter）
实现 Server-Sent Events（SSE）用于单向更新
排查连接掉线、心跳失败或 CORS 问题
设计有状态连接架构
从轮询迁移到推送技术

主要能力与示例

资料给出三个示例场景：

实时聊天应用：使用 Socket.IO 设计 WebSocket 架构，实现 Redis Adapter 水平扩展、基于房间的消息路由、消息持久化与历史记录、在线状态系统（在线/离线）。资料称结果为支持 100,000+ 并发连接、平均消息投递 50ms、99.99% 连接稳定性、无缝水平扩展。
实时仪表盘系统：实现低延迟 WebSocket 服务器、高效消息批处理策略、Redis pub/sub 多服务器支持、客户端更新合并、大负载压缩。资料称结果为仪表盘更新低于 100ms、支持 10,000 并发仪表盘视图、相比轮询服务器负载降低 80%、重连期间零数据丢失。
多人游戏后端：实现二进制协议 WebSocket 服务器、权威服务器架构、客户端预测与和解、延迟补偿算法、服务端物理与碰撞检测。资料称结果为端到端延迟 30ms、每服务器支持 1000 并发玩家、网络波动下流畅游戏、抗作弊的服务器权威。

使用方式（核心工作流）

可扩展的 Socket.IO 服务器（Node.js）

目标：可跨多核/多实例扩展的聊天服务器。

安装依赖：

npm install socket.io redis @socket.io/redis-adapter

实现（server.js）：

const { Server } = require("socket.io");
const { createClient } = require("redis");
const { createAdapter } = require("@socket.io/redis-adapter");

const pubClient = createClient({ url: "redis://localhost:6379" });
const subClient = pubClient.duplicate();

Promise.all([pubClient.connect(), subClient.connect()]).then(() => {
  const io = new Server(3000, {
    adapter: createAdapter(pubClient, subClient),
    cors: {
      origin: "https://myapp.com",
      methods: ["GET", "POST"]
    }
  });

  io.on("connection", (socket) => {
    // User joins a room (e.g., "chat-123")
    socket.on("join", (room) => {
      socket.join(room);
    });

    // Send message to room (propagates via Redis to all nodes)
    socket.on("message", (data) => {
      io.to(data.room).emit("chat", data.text);
    });
  });
});

生产环境调优（Linux）

目标：单服务器处理 50k 并发连接。

文件描述符：提高限制 ulimit -n 65535，编辑 /etc/security/limits.conf。
临时端口：扩大范围 sysctl -w net.ipv4.ip_local_port_range="1024 65535"。
内存优化：若不需要相关特性，使用更轻量的 ws 替代 Socket.IO；若 CPU 高，禁用 Per-Message Deflate（压缩）。

协议选择决策框架

双向（聊天/游戏）：需要低延迟 → WebSockets（原生）；需要回退/自动重连 → Socket.IO；P2P 视频/音频 → WebRTC。
单向（服务器 → 客户端）：股票行情/通知 → Server-Sent Events（SSE）；大文件下载 → HTTP Stream。
高频（IoT）：受限设备 → MQTT（over TCP/WS）。

扩展策略

< 10k 用户：单体 Node.js，单实例。
10k - 100k：集群，Node.js Cluster + Redis Adapter。
100k - 1M：微服务，Go/Elixir/Rust + NATS/Kafka。
全球：边缘，Cloudflare Workers / PubNub / Pusher。

负载均衡配置：Socket.IO 握手阶段需要粘性会话（Sticky Sessions）；增加空闲超时（如 60s+）；设置头部 Upgrade: websocket、Connection: Upgrade。

最佳实践

连接管理：心跳（ping/pong 检测连接健康）、自动重连与退避、断开时正确清理状态、限制连接数防止资源耗尽。

扩展：使用 Redis Adapter 实现多服务器水平扩展、正确配置负载均衡粘性会话、高效广播/单播消息路由、限流防止滥用与过载。

性能：适当批处理消息、压缩消息（permessage-deflate）、性能关键数据使用二进制协议、高效复用客户端连接。

安全：握手时验证身份、始终使用 WSS、验证所有传入消息、限制连接/消息速率。

反模式与注意事项

有状态单体：在 Node.js 内存中存储 users = [] 数组。扩展到 2 台服务器后，服务器 1 上的用户 A 无法与服务器 2 上的用户 B 通信；内存泄漏会崩溃进程。正确做法：使用 Redis 作为状态存储（Adapter），服务器无状态、后端有状态（Redis）。
惊群效应：服务器重启后 100,000 客户端立即重连，导致 CPU 峰值再次崩溃。正确做法：随机抖动（客户端等待 random(0, 10s) 后重连）、指数退避（1s、2s、4s……）。
阻塞事件循环：socket.on('message', () => { heavyCalculation(); })。Node.js 单线程，一个重任务阻塞所有 10,000 连接。正确做法：将工作卸载到 Worker Thread 或消息队列（RabbitMQ/Bull）。

其他反模式：无心跳、内存泄漏、无限重连、未设计无状态；单服务器、无负载均衡、广播风暴、连接饱和；消息臃肿、无限流、阻塞操作、无监控；无 TLS、弱认证、无限流、CORS 暴露。

安全升级信号

以下情况应升级至 security-engineer：接受来自任意 Origin（*）且带凭据的连接；连接请求无限流（DoS 风险）；在 URL 查询参数中发送 JWT（会被代理日志记录）——应改用 Cookie 或初始消息。

质量检查清单

可扩展性：多节点配置 Redis/NATS Adapter；使用轮询回退时启用粘性会话；提高文件描述符限制。

韧性：实现指数退避 + 抖动重连；配置 Ping/Pong 间隔（小于负载均衡超时）；启用/测试 Socket.IO 回退（HTTP 长轮询）。

安全：启用 TLS（WSS）；握手正确验证凭据；启用连接速率限制。

限制

资料未提供该技能的安装方式、收费模式、支持平台或具体版本要求等信息。