The Research And Implementation Of High-serviceable Message Oriented Middleware Based On Netty

Since the origination of message oriented middleware technology in 1990’s, it has experienced many evolutions, from the rising up, to productization, standardization and protocolization. Now, it has become an indispensable part of distributed application architecture. Major characteristics such as buffering flow pressure, decoupling, system sync/async communication, uniform interface etc. are main reasons of the continuously applying of the message oriented middleware technology.However, with the popularity of Internet, scenarios like ticket booking and electronic commerce sales promotion with large number participation, massive message flow and high-concurrence turned up. Common message middleware without special design and optimization are very likely to be crashed by suddenly increased visits and orders. And it often confronts with risks like slow response, loss of message and even crash. So how to deal with the high-concurrence requests, how to ensure the reliability of messages? These points need to be urgently worked out in the internet age.This thesis mainly focused on message middleware technology in the internet age. With the purpose of high-serviceable,this thesis putting forward a set of message oriented middleware solution with high concurrence, high flow capacity, reliable and manageable characters. The main work and contributions of this thesis are:To design and implement the Publish/Subscribe model message middleware, including low-level network communication, message server, message client and the management module. 1. To achieve the high concurrence goal, using event-driven network applicationframework Netty to design and implement the network communication module. 2. To achieve the high flow capacity goal, the server and subscriber can be deployed incluster way. And creatively supports 4 ways of subscriptions which defined inadvanced message queue protocol. 3. To achieve the message reliable goal, the message server using data persistencemodule. 4. To achieve manageable goal, implement a standalone management module.