接收[接入]连接通知

调用lua

开始随便写写...

最新通知返回连接数,旧通知返回0

接入携带当前用户连接数以及时间戳

清除本地guava缓存

发送mq通知

(用于通知其它rs实例清除本地缓存)

判断

创建线程异步推送

lua返回大于0

结束

lua返回0

推送线程

开始

查询redis获取时间戳(new)

时间戳判断

结束

current<new

请求DS获取推送信息

判断响应内容

开始推送流程

无推送数据

有推送数据

再次跑流程

携带subAccId+timestamp(current)

每日22点推送

查询推送失败表获取子账户ID列表

遍历子账户调用RS接口

判断用户是否在线

在线

结束

不在线

RS处理逻辑

TASK处理逻辑

1.TCP协议推送包括两部分推送逻辑:

      1)接收接入通知进行推送;

      2)接收TASK模块通知进行推送;(避免RS未收到上线通知导致有未推送的消息在表中)

推送

推送

2019-11-28 14:26:36 0 93
这里是评论

相关推荐