WebSocket 进阶：广播、限额与慢客户端

本章导读

22.1 引入

WS 服务的规模问题有个共同根源：一条连接的状态会影响所有连接——一个发大消息的客户端吃内存、一个不收数据的客户端堆积发送缓冲、一个僵死连接占着注册表。宿主提供了限额与回收的机制（ws_message_limit、idle 处理），广播策略与注册表治理是应用的责任——本章就是这两块。

22.2 广播模式

static void BroadcastText(xstrview tMsg)
{
    xmapiter it;
    xrtMutexLock(&G_WsLock);
    /* 遍历注册表：每个连接发送一份拷贝 */
    for ( it = First(G_WsConns); !AtEnd(G_WsConns, it); Next(G_WsConns, &it) ) {
        xwsstream* pWs = KeyOf(it);
        (void)xrtWsStreamText(pWs, tMsg);  /* 拷贝版：消息缓冲可立即复用 */
    }
    xrtMutexUnlock(&G_WsLock);
}

刚才发生了什么——三个工程决策藏在里面：

• 锁内遍历：防止遍历中连接建立/关闭改表结构（锁粒度按你的注册表操作裁剪）
• 拷贝发送：广播后消息缓冲立即复用，不必等所有连接的异步发送完成
• 失败容忍：单个连接发送失败不断广播——失败连接由其 Close 终态自然出表

按频道广播（聊天分组）就是把注册表换成 频道 → 连接集 的两级结构——模式完全同构。

22.3 限额与子协议

1009 的语义是"客户端侧应停止发大消息"——限额值 = 你的业务单消息合理上限（如聊天 64KB、行情推送 1MB），不要用默认值猜。

22.4 慢客户端与背压

• WS 层的发送是异步缓冲：客户端收得慢，数据在发送侧排队——内存防线是消息上限与你的广播频率控制
• 治理策略由应用定：超过 N 条未发的连接降级（跳过非关键推送）或直接关闭——注册表里记"降级位"
• 空闲回收：idle_timeout 到点由驱动用跨线程安全的 Abort 关闭（不是 Close——空闲扫描可能发生在任意 worker，Abort 才是线程安全终态）
• 你的注册表配合：WsClose 终态回调里出表，无论连接因何而死（客户端断、限额、空闲、你主动）都走同一条清理路径

22.5 契约

• 广播线：锁内遍历、拷贝发送、失败容忍；清理统一走 WsClose 终态。
• 限额线：1009/1011 由宿主发；限额值按业务设定并文档化。
• 回收线：空闲回收用 Abort（跨线程安全）；你的注册表只信任 Close 终态。

常见错误

编程练习