消息推送小组件,常用于“我的消息”功能。该组件依赖消息队列中间间实现消息的生产与监听消费,同时借助netty框架搭建websocket服务,实现消息的实时推送。该组件包含以下特性:
- 支持rabbitmq、rocketmq、kafka三种消息队列的切换
- 支持websocket心跳检测
- 支持消息历史记录、已读记录查询
- 支持消息订阅主题的自定义配置
- 支持消息幂等处理
本人负责整个组件的技术调研、架构设计、技术实现
主要难题:如何保证服务端与客户端保持实时消息通知并维持心跳。解决办法是使用netty框架采用websocket协议并自定义心跳数据包
点击空白处退出提示













评论