如何构建一套高可用的移动消息推送平台？

为了解决以上问题,我们考虑基于第三方消息推送服务构建一套移动消息推送中间件平台,该消息平台采用了低耦合的分层架构设计(如图 2 所示),分为三层：接入层、传输层和应用层.其中接入层是业务方调用的入口,我们采用异步消息队列的方式提供了较高的业务系统发送消息的速度,并且具备了消息缓冲功能,即使高峰期的海量消息推送对整个平台冲击较少,保护了推送系统；

传输层会从接入层接收消息并进行解析,对推送消息进行合法性检查校验,如果消息不合法直接丢弃,同时将合法的消息进行协议转换并发送到对应的第三方推送平台；应用层主要是提供统一的 SDK 供业务使用,封装适配第三方推送平台的 SDK 接口到统一的接口 SDK 中,这样业务 APP 使用方只关注统一封装的 SDK 即可实现业务消息的操作,而不需要考虑各种滤重、校验等通用操作.主要功能包括：

• 屏蔽推送接口,实现业务与推送服务解耦,提供一套通用的客户端 SDK,简化客户端接入.
• 实现多点接入,可同时接入多套推送服务,根据历史推送成功率动态选择最优推送路径,当一条路径失效可选择备用路径进行推送,保证消息推送万无一失.
• 引入消息持久化机制,方便追溯和统计.
• 引入消息的 ACK 机制和重传机制,提高消息的到达率.
• 实现数据监控和统计机制,提供相关数据的统计分析,和报警预警功能.
• 提供 web 管理后台,便于进行 APP 设置、推送设置、查看数据报表,提高系统维护的工作效率.

整个系统设计由三部分组成：移动推送平台、客户端 SDK、应用管理界面(第三方推送服务和自建推送服务统称为推送服务).

图 2：系统架构

移动推送平台提供统一的服务,对于应用层屏蔽推送服务接口,且实现推送服务可动态轮替.推送平台将接收到的消息持久化到数据库中,方便进行消息推送失败后的重发,以及后续数据的统计分析.

客户端 SDK 对 App 提供统一的使用接口,屏蔽推送服务 SDK 使用细节,且实现多种推送 SDK 可替换,隐藏 SDK 复杂的接入过程,方便使用.

应用管理系统面向 App 开发人员,实现应用申请,推送服务配置,消息查询与管理,数据统计与分析.

主要流程

消息推送涉及的主要模块是消息推送平台和客户端 SDK,主要流程如下图所示：

图 3：消息推送中间件核心流程

正常情况下,消息推送过程如下：

• 系统接收到业务方的推送请求后,首先进行权限的验证,这包括应用 appKey 的验证、接口参数的验证、黑名单验证等.
• 验证不通过,返回错误信息；验证通过后,为此条消息分配一个唯一 id(uuid),将消息内容持久化到数据库中,此时消息的状态为待发送.
• 消息进入推送队列中,将之后推送接口请求的响应返回给业务方.
• 推送队列的消费者从队列中取出待发送的消息,标记该条消息的状态为发送中,然后调用第三方推送服务接口进行发送.
• 如果调用成功,那么标记该消息的状态为发送成功客户端未收到.
• 客户端 SDK 在收到推送后,回调服务端接口,发送收到推送的回执；服务端收到客户端回执后,标记消息状态为发送成功客户端已收到.

（编辑：网站开发网_盐城站长网 ）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!