MESSAGE QUEUING SYSTEM AND METHOD OF REALIZING MESSAGE COMMUNICATION

摘要

Provided are a message queuing system and a method of realizing message communication. The system comprises: a first buffer area (21), a second buffer area (22) and a persistent storage (23). The first buffer area (21) and the second buffer area (22) are located in a memory of a server in which a message producer and a message consumer are located. The second buffer area (22) comprises a primary buffer area (221) and a secondary buffer area (222). The first buffer area (21) is configured to buffer a message pushed by the message producer, store the message in the persistent storage (23), and send the message stored in the persistent storage (23) to the second buffer area (22). The persistent storage (23) is configured to persistently store the message sent by the first buffer area (21). The secondary buffer area (222) is configured to buffer the message sent by the first buffer area (21). The primary buffer area (221) is configured to deliver the message therein to the message consumer, and after all of the messages is delivered to the message consumer, perform primary-secondary switching with the secondary buffer area (222). The system improves the real-time performance of message transmission in the message queuing system.