Shulou(Shulou.com)05/31 Report--

This article will explain in detail how rabbitmq message queues use tags to achieve message filtering. The content of the article is of high quality, so the editor shares it for you as a reference. I hope you will have some understanding of the relevant knowledge after reading this article.

Scene introduction

Messages stored in a message queue (MQ) can contain different practical uses. If these messages are not distinguished, the consumer will pull the messages sequentially each time they consume until the consumption of all messages is completed. If consumers are only interested in a certain type of message, consuming all the messages at once will inevitably affect the efficiency of consumer processing.

Solution

Distributed message service DMS is a stable and reliable message queuing service, which provides ordinary queues, ordered queues, Kafka, ActiveMQ, RabbitMQ, compatible with HTTP, TCP and AMQP protocols, and is used in scenarios such as system decoupling, asynchronous communication, traffic peaking and valleys, and third-party integration. DMS provides the ability to label messages, enabling producers to provide one or more tags (tag) for each message. Tag is used to distinguish the message classification under a message queue (MQ) Topic. Usually, tag can be used to distinguish the interrelated messages under the same Topic, just like the relationship between the whole set and the subset and the sequence of the process. Consumers filter messages according to the contents of the tag to ensure that each consumer will eventually consume only the types of messages that he or she is interested in, and improve the efficiency of message consumption.

Take the financial transaction scenario as an example, many types of messages may be generated in a transaction, such as stock (stock), fund (fund), loan and so on. These messages are sent to the queue (MQ) of business_Topic through the business Topic and transmitted to different processing systems, such as stock system, fund system, loan system, real-time analysis system, etc. However, the fund system is only concerned with fund type messages, while the real-time analysis system may need to obtain all types of messages, as shown in the following figure:

When producing a message, the producer tag each message, and when pulling the message, the consumer decides whether to obtain only the message with a certain label (tag), and the message without a specified label (tag) will not be obtained, thus greatly improving the efficiency of message consumption.

Both DMS normal queue and FIFO queue support message label (tag) function. Using DMS service, it is easy to use message label to filter messages. To learn more about the other features and functions of DMS, please click on the distributed messaging service DMS.

About rabbitmq message queue how to use tags to achieve message filtering is shared here, I hope the above content can be of some help to you, can learn more knowledge. If you think the article is good, you can share it for more people to see.

Welcome to subscribe "Shulou Technology Information " to get latest news, interesting things and hot topics in the IT industry, and controls the hottest and latest Internet news, technology news and IT industry trends.