Analysis And Implementation Of RocketMQ Oriented Load Balancing Technology

Improving the modularity of distributed systems can improve the communication performance and scalability among services,which makes high performance and high reliability message middleware more important.As a new message middleware,RocketMQ is widely used because of its powerful function,outstanding balance ability and supporting distributed transactions.Based on the analysis of the status quo of RocketMQ and Message Queuing service technology,this Master's thesis studies the load balancing technology of message middleware,and designs and implements a load balancing system for RocketMQ according to the load balancing requirements of enterprise services in a loan system.The main work of this paper is as follows:(1)RocketMQ Distributed Service Cluster and Message Characteristics Analysis.RocketMQ Broker cluster construction and nameServer cluster configuration and construction,message characteristics analysis,including sequential messages,repetitive messages,and distributed transaction messages.(2)Implementation of load balancing.The realization of RocketMQ load balancing is analyzed.The load balancing strategies of RocketMQ are analyzed one by one,including average allocation strategy,polling strategy,computer room configuration strategy,manual configuration strategy and consistency hash strategy.(3)Design and Implementation of Load Degradation for Local Message Stacking in RocketMQ Load Balancing System.Based on RocketMQ load balancing,integrating redis cluster technology and quartz,a distributed timed task scheduler,the load degradation of RocketMQ load balancing system is realized,and the throughput of RocketMQ load balancing system is improved.(4)Design and implementation of concurrent message distributed access control in RocketMQ load balancing system.This thesis mainly uses RocketMQ load balancing system to integrate Zookeeper-based distributed component curator to control concurrent processing logic of business messages.At the end of this thesis,the RocketMQ-based load balancing system is tested for function and performance.The test results show that the platform improves the service message throughput of RocketMQ load balancing and achieves the desired results.