The research and design of Pub/Sub Communication Based on Subscription Aging

The large-scale distributed systems usually use publish/subscribe to implement asynchronous and loosely-coupled communication, which well satisfies the requirements for resource sharing and work coordination between distributed applications. When a large number of messages are transmitted in traditional pub/sub communication system, the message server often suffers from performance bottlenecks and single point of failure. Hence this article proposes a pub/sub communication model based on subscription aging, which is an improvement over the traditional pub/sub model. It sets the priority of subscribers according to the timeliness of subscription conditions, introduces subscriber groups to classify the subscribers, and then adopts multicast transmission method to send data to the sub_group. The way improves the efficiency and performance of the pub/sub system. Multiple priority cache queues were designed based on the mapping relationship between priority and hot topics. According to experimental tests, this method has good communication performance when the number of subscribers gradually increase, and the caching mechanism ensures the reliability of the system.