Design And Implementation Of Message Middleware Based On AMQP

With the rapid development of distributed technologies,message middleware has been widely used in various distributed systems.Message middleware achieves time,space,and process decoupling between distributed applications.The producers and consumers are completely independent and integrated in a loosely-coupled form.With message middleware,developers don't have to pay attention to the specifics of messaging,just focus on their own business logic.It reduces the difficulty of development while meeting the messaging needs.This thesis designs and implements a message middleware based on the advanced message Queuing protocol.The main work of this thesis includes:(1)Based on the advanced message Queuing protocol,the message broker and middleware client are designed and implemented.The middleware client provides an interface for producer and consumer.The message broker receives and routes the message,and finally dispatch the message to the corresponding consumers.(2)Design the reliability of the middleware.This thesis designs the message transmission process,and introduces a clearly message acknowledgement mechanism based on the advanced message Queuing protocol to achieve the reliability of the message production process and message consumption process.In addition,data synchronization between message brokers is implemented to achieve redundancy of data in multiple nodes,thus achieving the reliability of the storage process.(3)Design the high availability of middleware.In order to eliminate the impact of single-node failure,this thesis introduces master-slave mode and active-active mode as high-availability architectures.Combined with the data synchronization mechanism and the automatic failover mechanism,the message middleware achieves high availability.In addition,the flow control mechanism implemented by the token bucket algorithm and prefetch limit strategy ensures the stable throughput of the system and further improves the high availability.The message middleware has been put into use.It works well and fully meets the expected design goals.It also meets the company's demand for high reliability of messaging.The implementation of message middleware provides a powerful guarantee for communication between modules.