切换主题
版本更新日志 🚀
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更强调系统可预测性