可靠消息系统移动网络的论文

可靠消息系统移动网络的论文

1.1系统基础架构

基于不行靠移动网络的消息系统，是目前移动互联网准时通讯讨论的热点，无论是消息推送，还是IM等准时通讯应用都涉及这个方面的问题，如何保证消息准时有效地送到用户是讨论的关键。从技术上，消息的送达主要有2类技术，一类是客户端轮询，即客户端不断地发送恳求猎取新内容;另一类是推送，即服务端在有消息内容时将消息推送到客户端。轮询实现比较简洁，即客户端在肯定的时间间隔内向服务端恳求，猎取新的数据，目前这种方式在当前互联网上的消息应用中较为普遍。但这种方式在移动网络下存在较多问题，假如设置时间间隔太长，会造成消息的准时性不够，假如设置太短，会造成较大的数据流量，移动网络目前的流量成本还比较高，另外对移动设备的电量消耗较大。而推送方式采纳长连接的方式，有效地避开了上述问题，但是，由于移动网络的不稳定性，在长连接状况下没有传统网络稳定，客户端时有掉线。因此笔者在参考推送模式和XMPP(ExtensibleMessagingandPresenceProtocol，可扩展消息与出席协议)的基础上，借用轮询恳求的方式，实现消息的有效回执，同时采纳重试链接的方式回避长连接的不稳定，在传统的推送基础上加了重发机制。该消息系统在架构上由客户端、服务端和数据层构成，各层由不同子功能模块组成。客户端主要为用户供应交互操作的界面，包含消息回执、消息显示等模块，其核心是客户端收到消息后，依据消息体的相关属性打算消息是否需要回执，采纳何种模板进行消息体的展现。服务端由多台基于Openfire的IM服务器集群、Zookeeper集群以及消息待发队列和重发队列组成，用于处理、转发及重发客户端消息、接收客户端消息回执、监听客户端状态等。此外，还包含统一的数据访问接口，用于访问缓存数据库。数据层用于存储来自应用系统的相关数据和用户状态，其中缓存数据库主要存储用户信息及离线消息等，Zookeeper集群主要存储IM服务器集群的共享数据。

1.2各模块功能

1)客户端消息回执模块用于构造并发送客户端消息回执。当客户端胜利接收在线消息或离线消息时，立即向服务端发送“胜利接收在线消息”或“胜利接收离线消息”的回执，告知服务器客户端已胜利接收到消息，不用重复向其发送此消息，服务端的业务层依据回执的状况对消息进行相应的业务处理。

2)客户端消息显示模块依据消息类型对消息予以不同的显示。消息主要分为一般消息、多媒体消息、联动消息3类，客户端消息显示模块依据上述的类型，从消息弹出方式、消息字体颜色、消息的联动等方面进行不同的.处理。比如消息是否需要弹出、客户端收到消息的声音模式以及该消息内容是否进行下一步联动操作。

3)服务端消息处理模块主要负责接收客户端的消息回执，当该模块接收到客户端的消息回执时，表示客户端已经收到该消息，后续对该消息进行完整的事务处理，把该消息从待发队列移除，同时置该消息状态位为已发送。

4)服务端消息处理推送模块主要依据消息接收者的状态实行不同的消息发送策略，同时依据消息的内容和形式组成不同的消息体，便于客户端进行消息的显示，同时供应其他应用服务器能够通过IM服务器向客户端推送消息接口。

5)服务端消息重发模块用于重新发送未胜利送达客户端的消息。服务器端维护一个重发队列保存其发送过的消息，当收到回执时则从队列删除相应消息，若未收到回执，则在计时器周期遍历重发队列时重发此消息，以此来提高服务器端向客户端发送消息的牢靠性。服务器端依据消息的重要程度采纳不同级别的重发策略，越重要的消息重发的频率和次数越高，多级别的重发策略便于定制，更为敏捷。

6)服务端状态管理模块主要是维护客户端的长连接状态，如客户端上线、离线、临时不接受某类消息等，该模块对消息推送策略的制定至关重要。

7)数据层的数据存储模块主要是对消息内容的保存和用户连接状态的存储，由于消息的量比较大，文件大小较小，采纳缓存机制可以有效降低磁盘IO吞吐消耗，缓存机制的读取和存储速度较快，有效地提升系统的响应速度。

1.3重发策略分析

保障客户端的消息接收是本文的关键，难点在重发策略。消息重发策略包括服务端消息重发策略及客户端消息回执策略。为支持服务端消息重发功能，IM服务器需要维护一个消息重发队列，当IM服务器推送完成一条消息后，将该消息从待发队列中移到重发队列，IM服务器检测客户端的在线状态，假如在线，则马上发送，同时待胜利收到客户端的回执时从重发队列删除相应的消息，假如不在线，则将消息存为离线消息，标识消息的发送时间和已发送次数。IM服务器采纳集群方式，各个IM服务器需要共享同一个消息重发队列，本文借助Zookeeper实现消息队列的共享与同步。Zookeeper是通过选举产生leader和follower，其算法正确执行的前提是有一半以上机器正常工作，每台机器部署一个IM服务器及一个Zookeeper服务器，各IM服务器之间进行负载平衡，各Zookeeper之间进行数据同步，IM服务器优先从本地Zookeeper存取数据。各机器中只有一台机器作为主服务器，其余作为从属服务器，主服务器负责消息的重发。计时器掌握消息重发，要求重发队列中的消息至少包含消息体、已重发次数、上一次发送时间等数据。当执行计时器任务遍历重发队列时，若某消息距上次发送时间超过阈值则重发此消息，并修改消息最终一次发送时间以及已发送次数，当某消息发送次数达到设定的上限时就将其存为离线消息，待用户登录以后再接收此消息。

2消息系统实现

本系统在完成设计后，笔者搭建了一套测试系统，该系统服务端采纳4台2CPU/4G内存机器做IM服务器和3个Zookeeper集群，1台2CPU/8G内存的服务器作为数据存储的redis服务器。同时选取了目前市场比较主流的中国移动2GAndroid手机1台，中国联通的3GAndroid手机终端1台。在应用搭建完成后，分别在2G、3G网络下，通过服务端进行了100、1000、1000、10000条消息向客户端推送，一种状况是消息没有重发和回执策略，另一种状况实行5次的重发策略和消息回执策略，特殊是2G(不稳定)的网络，通过提升重试次数，大大增加了消息的投达力量，消息到达率由80%多平均提升到96%左右，而在3G网络下，消息的到达率也平均有90%提升到98%左右。同时由于有了消息回执机制，服务端显示的消息到达条数和客户端实际收到的消息条数是全都的。而没有采纳消息回执策略的，客户端实际收到的消息也许是95%左右，有5%的特别状况。进一步分析各种失败的消息状况，可以看到重试间隔时间越长，消息的失败率越高。从测试报告可以看出，系统的重试间隔时间在肯定范围内，胜利率比较高，随着时间越长，胜利率显著下降。因此重试间隔也有肯定的限制。

3结束语

随着从传统的互联网时代步入移