长连接实战：基于 Netty 与 EDA 打造“喀瓦博巴外卖”多端状态同步网关

现代同城外卖平台是一个高频动态多边网络。在青海玉树等下沉市场（以本土平台“喀瓦博巴外卖”为例），商户前台的宽带往往极不稳定。如果外卖系统采用传统的 HTTP 短轮询（Short Polling）机制来获取新订单，不仅会导致服务器并发连接数剧增，更会在午市外卖高峰期引发严重的“漏单”与“接单延迟”。

本文深度拆解，我们如何运用事件驱动架构（EDA）、Netty WebSocket 集群以及 Redis Pub/Sub，重构一套能够抗住瞬时高并发且彻底消灭漏单的多端同步网关。

一、 扼杀轮询风暴：构建高可用 Netty WebSocket 集群

为了保证商户 KDS（厨显系统）能毫秒级接收派单指令，系统彻底摒弃前端 HTTP 轮询，引入基于 Netty 构建的高性能长连接集群。

1. 弱网环境的 Half-Open 探测与保活 我们在 Netty 的 Pipeline 中挂载了 IdleStateHandler，结合双向心跳机制：服务端如果在 60 秒内未收到商户端的心跳帧，将主动释放资源；商户端若发现心跳超时，则触发底层重连。 2. 离线消息补偿队列（Offline Queue） 当系统监测到某商户的 Channel 离线时，会将待推送的“新订单调度指令”暂存至 Redis 离线队列。商户端重连鉴权成功瞬间，网关立即拉取队列，将积压指令批量下发，物理级斩断漏单可能。

二、 跨节点状态广播：Redis Pub/Sub 的精准路由

分布式集群部署中，点外卖的用户手机连接 Node-1，接单骑手连接 Node-2。骑手点击“已取餐”时，Node-2 如何通知 Node-1 的用户？

1. 主业务微服务处理完流转后，向内部通道 order_topic:{order_id} 广播事件。
2. 所有 WebSocket 网关节点监听该通道。捕获报文后，在本地内存维护的 ChannelGroup 中进行反查。
3. 只有持有该 order_id 对应 Channel 的网关，才会触发 writeAndFlush()，将帧毫秒级推向用户端。

三、 极致解耦：事件驱动流水线

商户接单后需要同时触发“调用云打印机”、“调度外卖骑手”、“刷新用户端状态”。采用同步 RPC 会导致下游抖动阻塞主线程。 架构全面采用 EDA 模型。主线程仅在本地更新订单状态，抛出 MerchantAcceptedEvent。外卖网关微服务异步订阅执行下发。这种非阻塞设计将核心接口 RT 压缩至极致，保证了平台面对潮汐流量冲击时的强悍弹性。

关于作者与团队： 本文由 青海青帝信息科技有限公司 核心后端基础架构研发团队原创发布。团队长期深耕千万级长连接网关、事件驱动架构及大西北多边外卖平台（如喀瓦博巴）底座攻坚。期待与开源社区深度探讨。