wueasy-websocket 产品介绍

wueasy-websocket 是一款高性能、轻量、可扩展的 WebSocket 推送服务，适配企业级实时通知、IM、在线协作、物联网告警等场景。它专注于稳定连接管理、灵活消息分发与安全治理，并在大并发场景下保持可预测的资源占用与低延迟。

核心定位

• 高并发连接管理：面向百万人群的长连接场景
• 灵活消息分发：支持广播、按用户、按频道推送
• 安全与治理：来源域校验、鉴权、慢客户端策略
• 易扩展：MQ集成实现跨实例广播与上行消费

典型应用场景

• 实时通知与告警：订单状态、物流更新、系统告警
• 即时通讯与协作：群聊、频道公告、协作事件同步
• 物联网设备：设备状态上报与指令下发
• 游戏与互动：房间事件、排行榜、活动推送

核心能力

连接管理

• 最大连接数与消息大小限制（max-connections、max-message-size）
• 心跳与超时管理（heartbeat-content、pong-timeout）
• 来源域白名单（allowed-origins）
• 慢客户端策略（slow-client-strategy: drop 或 disconnect）

消息分发

• 广播、按用户、按频道的三类目标模型
• /publish 接口统一推送入口（HTTP）
• 上行消费可写入 MQ（accept-client-message）

鉴权与治理

• 升级前 HTTP 鉴权（verify-uri，支持 lb://）
• 鉴权超时与错误处理（verify-timeout）
• 可选 Nacos 服务发现集成

集群与 MQ

• cluster-enabled: true 开启后通过 MQ 进行跨实例广播
• 支持 Kafka 与 RabbitMQ 两种集成模式
• 上行与下行主题/路由键分离，保证隔离与可靠性

性能与可靠性

• 可配置的发送队列长度（send-queue-size）保证拥塞可控
• 慢客户端断开策略确保整体吞吐与内存可预测
• MQ 持久化可按需开启（RabbitMQ delivery-mode / Kafka acks）

系统与部署

• 单机模式：迅速落地、低成本维护
• 集群模式：通过 MQ 水平扩展、跨实例推送
• 服务发现：可选 Nacos 集成，简化内网服务接入

技术栈

• 语言：Go
• MQ：Kafka / RabbitMQ（可选）
• 配置中心/发现：Nacos（可选）

下一步

• 5分钟上手请查看《快速开始》
• 完整配置项说明请查看《配置说明》