cloudpush是我对于springcloud微服务框架的一个学习实践,旨在学习微服务架构的同时,实现一个基于websocket协议,可平滑水平拓展的分布式推送产品。
目前核心的技术栈采用的是SpringBoot2.0.1.RELEASE
管理台页面待开发。。
后端的主要架构是基于springboot.
- SpringCloud
- Netty
- Nacos
- Redis
- RocketMQ
| tools 工具包 | 压缩包 | 项目,或者测试中需要用的到中间件包,直接用docker更方便。。 |
|---|---|---|
| cloudpush-api 公共组件部分 | jar | 公共组件,很多地方都有引用 |
| cloudpush-eureka 注册中心 | web项目 | 为啥有了nacos还要eureka:通过@EventListener额外增加对websocket服务状态的监听,从而动态地将websocket服务中额外启动的netty服务的ip、port维护进redis(用zk来维护这个地址也一样) |
| cloudpush-portal 接口服务 | web项目 | 提供http接口服务 |
| cloudpush-task 后台计算服务 | web项目 | 现仅仅根据各个websocket的连接数计算路由权重存进redis,不是运行系统的必要条件 |
| cloudpush-websocket 推送服务 | web项目 | 由springboot启动的一个netty服务,启动的netty端口提供websocket的握手,消息的收发服务 |
| cloudpush-gateway 统一网关 | web项目 | 统一入口,便于未来鉴权,现在用作根据redis中的websocket路由权重,生成ws连接的动态路由规则(优先分配给连接数较少的实例) |
- 项目在批量推送的功能中,出于性能考虑,用到了redis的管道特性(一次查询出多个客户端所属的websocket节点),遂无法使用cluster分片集群,所以。。要么哨兵一个master处理写操作,要么使用Codis作代理,实现redis集群多个master处理写操作。
- 推送功能(根据客户端的连接时的标识参数,以http请求或者websocket消息的形式,给一个或者多个客户端推送指定内容的websocket消息)
- 踢出过期客户端功能(客户端上报心跳,ping消息或者封装心跳格式的websocket消息,会刷新所在的websocket节点所维护的客户端的活跃时间)
- 提供管理后台页面
- 接入监控组件对应用所在服务器的cpu、网卡、内存等健康指标的监控
- 结合客户端收到消息的回执和在推送流程中的埋点,接入ELK组件实现对消息送达率,客户端会话时长的统计
{ "to": ["1607080309668","1607071389121"], "msg": { "key1": "value", "key2": "value2" }, "sendToAll": false }
{"activeTime":1607080644685,"from":"system","messageId":"725cf41a5798474fb31a1258bed2d5d8","msg":{"key1":"value","key2":"value2"},"requestId":"f231012a-b2ed-40b1-841a-45538dc48ee1","sessionId":"172.31.236.11:9000_1607080309668_20201204191140","to":"1607080309668","trigger":1,"msgType":1}
| 值 | 意义 |
|---|---|
| activeTime | 发生时间 |
| from | 消息来源 |
| messageId | 唯一消息id,用于回执重发保证送达率(暂未实现) |
| requestId | 请求id,以http形式触发的时候会存在,用于写es统计 |
| sessionId | 会话id,在一次连接中保持一致,用于写es统计 |
| msg | 具体推送的消息内容 |
| to | 推送的目的地(客户端标识) |
| trigger | 消息触发方式(http或者websocket) |
| msgType | //错误代码ERROR(-1,"error"),//连接类型消息CONNECTION(0,"connection"),//发送的业务类型消息BUSSINESS(1,"bussiness"),//发送的业务类型消息的回执BUSSINESS_ACK(2,"bussiness_ack"),//心跳类型HEARTBEAT(3,"heartbeat"),//心跳类型回执HEARTBEAT_ACK(4,"heartbeat_ack"); |
项目对你有帮助或者启发的话
- 老哥点个star
- 提个issue或者pr参与开发
- 甚至打赏瓶水也ok O(∩_∩)O
wx
- 微信号:
wx+
申请表明来意
