The Design And Implementation Of Private Cloud Platform Message Service Based On AMQP Protocol

H3 Cloud is a private cloud management system provided infrastructure as a service for businesses, groups or organizations. Private cloud platform consists of server, portal and many back-end services deployed in different network nodes, through collaboration between the internal components to provide virtualization services. With the expansion of business, the system has been unable to meet the increasingly sophisticated information exchange between the different components of the cloud platform. It is necessary to provide a service that will decompose different components and meanwhile, to complete information exchange between different components. In this paper, a message-based service is provided to solve the complex information communication among different components of cloud platform.Server and portal of the cloud platform are developed by Java language and provide the way of web accessing to create and manage hosts, mirror, hard disk, network, router and other cloud resources for cloud users. In these virtualized services, different cloud resource modules will interact with various back-end services developed by different languages. Meanwhile, the server as the center of cloud initialization and resource allocation, the portal modules also need to interact with the server. In order to unify the communications between different components, improve the scalability of cloud platform, the system need to provide a layer to integrate the different components. The AMQP-based message oriented middleware provides options to meet this demand. The AMQP only defines the data transmission format, the two sides of client can successfully complete message exchange only in accordance with the established format. Message service is on this basis to build up.In this paper, we first analyze the principle of AMQP message routing and buffering, determine the routing algorithm used and plan the exchanges of different modules defined in the middleware, design a summary model of message communication between different components through message oriented middleware in distributed deployment. In a centralized deployment, server shared a compilation environment with portal, if the system still use the messaging middleware for message communication, will result in a tremendous waste of network resources and is not easy to manage the exchanges and message queues declared in the message oriented middleware. Under the inspiration of the message publish/subscribe model, this article offer the model, which is, the cloud platform messaging bus service.The bus provides such services, when each modules in portal and server need to communicate, simply publishing the encapsulated message to the bus, and the bus will push this message to the subscribers subscribed this type of message, to achieve the purposes that any module in portal and server can use asynchronous message communication. When the server and portal centralized deployment, just build a bus, the communication between them to pass the message is completed through the bus. And in distributed deployment, server and portal build their own bus separately, the message interaction between the internal modules via the local bus, when they interact message each other, simply register a subscriber to the local bus, who receives message sent to the peer, when the subscriber receives corresponding message, it calls the middleware communication interface to send out the message, the message is forwarded to peer receiving thread by routing messaging middleware, the recipient will publish the message to the local bus after receiving the message, the bus will push the message to true subscribers. This interaction is completely transparent to the calling module. To send a message, simply publish messages to the bus, when want to receive a message, simply register a subscriber to the bus.And then use the spring AMQP jar to connect the messaging middleware, define the exchanges and message queues in the middleware, develop messaging interface. Further, use the akka framework to develop highly available message bus service.Finally, through functional test, code quality test and performance test to ensure the availability and stability of messaging services, providing a complete scalable and efficient message service for cloud platform.