目前核心的技术栈采用的是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连接的动态路由规则（优先分配给连接数较少的实例） |
{
"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"); |