切换主题
版本更新日志 🚀
0.1.0 版本
未发布
· 首个版本发布
初始功能 🎯
- WebSocket 服务与
/ws
接入:支持用户、临时链接 - 鉴权与临时验证:
verify-uri
/verify-timeout
与temp-verify-*
- 心跳与超时控制:
heartbeat-content
、pong-timeout
- 推送接口:
/feign/publish
支持all
、user
、channel
、temp_user
- 在线用户查询:
GET /feign/getOnlineUsers
- 集群模式:Kafka / RabbitMQ 跨实例广播与定向推送
- 慢客户端策略与队列:
slow-client-strategy
、send-queue-size
- 客户端上行消息:
accept-client-message
,写入 MQclient-topic
/client-routing-key
- 来源校验:
allowed-origins
支持跨域白名单
兼容性与注意事项 ⚠️
- 运行环境:Go 1.20+,支持 Windows / Linux / Mac
- MQ 配置:启用集群需正确配置 Kafka/RabbitMQ,确保每实例独立消费以实现广播
- 临时链接:
temp_user
仅投递至临时链接,不计入在线用户统计 - 顺序语义:Kafka 同分区内有序;RabbitMQ 不保证全局顺序,必要时降低并发保障局部顺序
- 慢客户端:
drop
更适合大规模广播,disconnect
更强调系统可预测性