随着近些年来,企业为了提高公司不同业务中的数据共享,协调不同部门之间的办公效率,对数据进行持久化存储来挖掘其背后价值,对消息通信系统越来越重视。不同业务系统之间的联系越来越紧密,对通信质量要求也越来越高和严格。企业内部通信系统对数据传输的可靠性,高效性,安全性,低延迟性等条件有着极其严格的规定,而RocketMQ作为一种分布式消息中间件,它具有高可靠性,分布式,易隔离,易定制化等特点,能有效解决数据持久化存储,对数据进行可视化监控和分析,保证消息在传输过程中的安全性,可靠性等问题。目前主流的消息中间件有ActiveMQ、RabbitMQ、Kafaka、RocketMQ等。为了选择一款较为合适的消息中间件,对各个消息中间件吞吐量、处理消息能力、国产化等做了相关实验,实验表明RocketMQ相对较好。由于RocketMQ未提供消息优先级接口,因此通过间接方式设计了一个消息优先级模块,来满足企业中对紧急业务的处理。为了保证企业中消息顺序发送,消息重试功能,设计了与之相对应的模块。为了能够对消息发生或失败后快速定位失败原因以及消息持久化后的可视化展现工作,设计了web界面进行展示消息,集群,Topic等。为了测试消息通信的可靠性,搭建双主双从的集群环境,实验结果表明非常稳定可靠,在机器断电的情况下也能保持较少的消息丢失,改变刷盘策略可以保证消息不丢失。综合考虑高吞吐量、低延迟、处理消息能力强、系统可靠性、丢失消息情况、国产化等因素,选择RocketMQ作为消息通信系统的决策是正确的。