为保证及时性和到达率,使用两种推送方案并行,现实现一套消息处理去重机制
概述
+ 封装消息体,每条消息有唯一消息ID
+ 每个终端只订阅对应的一个mqtt主题
+ 不使用eclipse提供的mqtt service包,只使用mqtt client包
+ 实现一套消息去重机制
要求
实现jpush和mqtt消息订阅与接收,处理重复消息,分发消息给业务代码,要求可以随时替换jpush为其他方案,并保证该机制稳定可靠。
JPush接入
使用JPush Android SDK v2.1.7,使用默认配置,接入餐时间后台服务器
Mqtt接入
使用eclipse.paho.client.mqttv3的1.1.0版本,mqtt协议版本3.1.1,每十分钟主动断开一次并重连和重新订阅。
消息格式
__待定__
消息去重
利用队列和LruCache存储消息,使用生产者和消费者模型,具体流程如下图:
消息分发
消息利用android广播发送给业务逻辑代码处理
代码
暂无