消息中心系统架构

1.WebSocket连接

3.推送业务数据

UserMap

MessageCache

Netty1

小程序

本地消息缓存，缓存2个心跳周期后失效当用户重连后，可以获取到未接收的消息

2.建立长连接

8.消息推送

Netty0

MQ

广播层

4.消息入库

用户channel关系表

消息中心系统架构图

REST API

Nginx

5.发送数据到MQ

业务层

通道层

7.查询UserMap，推送数据

Biz Service2

Biz Service1

Netty2

6.广播消息消费

H5

cassandra 

应用层

App