RabbitMQ学习(五)：Topics

迷南。 2022-03-15 12:50 175阅读 0赞

# 说明 #

在之前的教程中，我们已经对Exchange有了更深的了解，学习了Fanout和Direct类型的交换机，学习了交换机根据规则对消息灵活路由的强大功能特性。通过简单的程序练习，对RabbitMQ的消息传递模型有了深入的认识。本篇博文将继续翻译官方第五篇教程[Topics][],通过本篇教程我们将继续学习另一种Topic交换机，该类型交换机比Direct交换机的功能更强大，消息路由更加灵活。

# 正文 #

在[前一篇][Link 1]教程中，我们升级了日志系统，使用direct交换机代替了fanout交换机，让消息路由更具有灵活性，使得消费者可以选择地接收消息，不在依靠fanout广播所有消息。

**虽然使用direct交换机提升了我们的系统，但是它仍然有限制，它不能根据多个条件进行路由。**

在我们的日志系统中，我们希望不仅可以根据日志的级别进行订阅，也可以根据日志的来源进行订阅。你可能从unix的工具syslog中了解过这种概念，它可以根据日志级别和来源进行路由。

这将给我们带来更大的灵活性，我们可能希望监听来自cron的关键错误日志和来自kern的所有日志消息。

为了在我们的日志系统中实现这个功能，我么需要学习一种更复杂的topic类型交换机。

## Topic exchange ##

消息被发送到topic交换机不能携带一个任意的路由关键字，关键字必须是由符号 **点**（**.**）分隔的单词列表。可以是任意单词，但是通常情况下单词都跟消息内容有关。几个有效的路由关键字示例：“stock.usd.nyse”, “nyse.vmv”, “quick.orange.rabbit”。路由关键字可以根据喜好包含多个单词，但是它的**长度不能超过255个字节**。

绑定关键字和路由关键字一样，topic交换机背后的路由算法和direct交换机类似，一个携带路由关键字的消息将被发送到与队列绑定关键字匹配的所有队列中。但是绑定关键字这里有两种特殊的情况：

*  **\***（start）只能代替一个单词
 *  **\#**（hash）能代替零个或多个单词

用一个例子很容易解释：  
![在这里插入图片描述][20190302195225225.PNG]  
在这个例子中，我们将发送有关描述动物的消息，这些消息将携带一个路由关键字，这个关键字将包含三个单词（两个点）。第一个单词描述的速度，第二个是颜色，第三个是种类："<speed>.<colour>.<species>"。

我们创建了三个绑定关系，Q1使用"\*.orange.\*“进行绑定，Q2使用”\*.\*.rabbit"和"lazy.\#"进行绑定。

这些绑定关系可以被描述为：

*  Q1队列对所有的橙色动物感兴趣
 *  Q2想要监听有关兔子和懒惰动物相关的所有消息

一个携带"quick.orange.rabbit"或"lazy.orange.elephant"路由关键字的消息将被传递到所有的队列，换句话说，携带"quick.orange.fox"关键字的消息将只被传递到第一个队列，携带"lazy.brown.fox"的消息只被传递到第二个队列。携带"lazy.pink.rabbit"关键字的消息即使匹配了两个绑定关键字，也将只被传递到第二个队列一次。携带"quick.brown.fox"的消息不能匹配任何的绑定关键字，所以将会被丢弃。

如果我们不按照规则，发送一个携带一个或四个单词的关键字，如"orange"或"lazy.orange.male.rabbit"的消息将会发生什么？结果是我们的消息都会被丢弃，因为他们携带的路由关键字不能匹配任何的绑定关键字。

然而路由关键字为"lazy.orange.male.rabbit"的消息，它虽然是四个单词，但是它能匹配最后一个绑定关键字，所以这个消息将被传递到第二个队列。

**Topic exchange**  
topic交换机的功能十分强大，并且它可以**实现其他交换机的功能**。

当队列使用"\#"关键字进行绑定时，它将接收所有的消息，像fanout交换机一样，忽略所有的路由关键字。

当对列使用**不含特殊符号**"\*“和”\#"的关键字进行绑定时，此时的topic交换机的功能就与direct交换机一样。

## Putting it all together ##

我们将在之前的日志系统中使用topic交换机，我们首先假设日志的路由关键字有两个单词"<facility>.<serverity>"。

**EmitLogTopic.java**

public class EmitLogTopic {
    
        public static final String EXCHANGE_NAME = "topic_logs";
    
        public static void main(String[] args) throws Exception{
            ConnectionFactory factory = new ConnectionFactory();
            factory.setHost("localhost");
            try (Connection connection = factory.newConnection();
                 Channel channel = connection.createChannel()) {
                channel.exchangeDeclare(EXCHANGE_NAME, "topic");
    
                String severity = "error";
                String message = "runtimeException";
    
                channel.basicPublish(EXCHANGE_NAME, severity, null, message.getBytes("UTF-8"));
                System.out.println(" [x] Sent ' " + severity + "':'" + message + "'");
            }
        }
    }

**ReceiveLogsTopic.java**

public class ReceiveLogsTopic {
    
        public static final String EXCHANGE_NAME = "topic_logs";
    
        public static void main(String[] args) throws Exception{
            ConnectionFactory factory = new ConnectionFactory();
            factory.setHost("localhost");
            Connection connection = factory.newConnection();
            Channel channel = connection.createChannel();
    
            channel.exchangeDeclare(EXCHANGE_NAME, "topic");
            String queueName = channel.queueDeclare().getQueue();
    
            channel.queueBind(queueName, EXCHANGE_NAME, "error.#");
    
            System.out.println(" [*] Waiting for error messages.");
    
            DeliverCallback deliverCallback = (consumerTag, delivery) -> {
                String message = new String(delivery.getBody(), "UTF-8");
                System.out.println(" [x] Received '" + delivery.getEnvelope().getRoutingKey() + "':'" + message + "'");
            };
    
            channel.basicConsume(queueName, true, deliverCallback, consumerTag -> {});
        }
    }

源码地址：[https://github.com/Edenwds/rabbitmq\_study/tree/master/routing][https_github.com_Edenwds_rabbitmq_study_tree_master_routing]

[Topics]: http://www.rabbitmq.com/tutorials/tutorial-five-java.html
[Link 1]: https://blog.csdn.net/sinat_36553913/article/details/87996192
[20190302195225225.PNG]: /images/20220315/6e061db6d46347d7b8af904d4204e096.png
[https_github.com_Edenwds_rabbitmq_study_tree_master_routing]: https://github.com/Edenwds/rabbitmq_study/tree/master/routing