cloudpush- 分布式推送产品

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组件实现对消息送达率，客户端会话时长的统计

效果图

以http形式触发的推送

以websocket形式触发的推送

消息解析

http

{ "to": ["1607080309668","1607071389121"], "msg": { "key1": "value", "key2": "value2" }, "sendToAll": false }

websocket

{"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}

客户端收到的websocket消息详解

值	意义
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

技术交流及问题解答

微信号:

申请表明来意

qdx123 / cloudpush Goto Github PK

cloudpush's Introduction