Design And Implementation Of A High-availability Distributed Convergence Communication Message System Based On RocketMQ

In recent years,the development of mobile Internet has become increasingly faster.Information push is an important part of mobile Internet.The timely release and delivery of information on mobile phone client requires a message push service.Based on this background,MQTT agreement came into being which has small protocol package,expends low power consumption and run on all Operating System.At the same time,it can provide three different quality messaging levels,which greatly enhances practicality and has been applied in many areas.As a distributed message queue,RocketMQ is high-performance,distributed and has other characteristics,making it a great advantage in distributed deployment of servers.The main purpose of this paper is to design and implement a distributed message push system based on RocketMQ and using MQTT as the transmission protocol.This article first introduces the research status of domestic and foreign research and the background of the project.In the following part,this paper briefly introduces and researches the RocketMQ message queue technology and MQTT protocol.Subsequently,the system is analyzed and the system's functional structure and flow are designed.The entire system is divided into several modules icluding service processing,message forwarding,load distribution,and server status monitoring.Then these modules are implemented one by one,using open source projects such as Mosquitto and RocketMQ.At the same time,a distributed deployment solution for highly available servers is designed.The entire system is developed based on the Linux platform and Java is used as the system development language.After the development is completed,the system is tested for related indicators.The test results show that the message push server designed and implemented in this paper can fulfill the basic requirements of the system and perform well in distributed deployment and maintaining high availability under abnormal conditions,and is also superior in performance.