RabbitMQ学习(四)：Routing

末蓝、 2022-03-16 13:24 168阅读 0赞

# 说明 #

通过前一篇教程，我们对RabbitMQ的消息传递模型有了初步的认识，了解了Exchange这一强大的组件，并通过fanout类型的交换机创建了一个简单的日志系统，实现了发布-订阅的消息发送模式。本篇博文将继续翻译官方第四篇教程[Routing][]，通过本篇教程我们将加深对Exchange的了解，初步学习它的一个强大功能—消息路由，通过Direct类型的交换机使得我们发送消息更具有灵活性。

# 正文 #

在前一篇教程中，我们创建了一个简单的日志系统，它可以将日志消息广播发送到多个接收者。

在本篇教程中，我们将为日志系统增加一个功能----使得它可以让接收者只订阅部分消息。举个例子，我们可以只将重要的错误日志信息写到日志文件，同时可以把所有的日志信息都输出到屏幕。

## Bindings ##

在之前的教程中我们已经创建了绑定关系，你可能会想到以下代码：

channel.queueBind(queueName, EXCHANGE_NAME, "");

我们已经知道**绑定是队列和交换机之间的关系描述，也可以理解为：某个队列对来自于某个交换机的消息感兴趣。**

**绑定时我们可以携带一个称为路由关键字（routingKey）的参数，为了避免和basic\_publish的参数混淆，我们将称它为绑定关键字（binding Key）**,以下代码展示 如何使用一个指定的关键字创建绑定关系：

channel.queueBind(queueName, EXCHANGE_NAME, "black");

绑定关键字的意义依赖于交换机的类型。例如，之前教程中我们使用的fanout交换机，它将忽略所有的binding key的值。

## Direct exchange ##

在之前的教程中，我们的日志系统将所有的日志消息广播发送到所有的消费者。本节教程中我们希望对它进行扩展，使它能够根据消息的严重级别进行过滤。例如，我们希望一个程序只接收严重的错误日志信息，并将其写入硬盘中，避免在warn和info类型的日志上浪费硬盘空间。

我们之前使用的fanout交换机，它只能盲目地广播消息，无法给我们带来更多的灵活性。

在本节教程中，我们将使用direct类型交换机代替它，direct类型交换机的路由算法是一个消息只被发送到 **队列绑定关键字与消息携带的路由关键字完全匹配** 的队列中。

通过以下设置来解释它：  
![在这里插入图片描述][20190228223139535.PNG]

在这个设置中，我们可以看到有两个队列绑定到了一个direct类型的交换机X, 第一个队列使用orange关键字进行绑定，第二个队列有两个绑定关系，第一个使用black关键字，另一个使用green关键字。

这样当携带orange关键字的消息被发送到这个交换机时，它将被路由到Q1队列。携带black或green关键字的消息将被路由到Q2队列，其他所有的消息将会被丢弃。

## Multiple bindings ##

![在这里插入图片描述][20190228223317843.PNG]  
direct类型的交换机允许**使用相同的关键字绑定多个队列**。在我们的例子中，我们可以使用black关键字将x和Q1进行绑定，**此时这个direct类型交换机将和fanout类型交换机的功能相似**，它将广播所有的消息到与之匹配的所有队列中，所以一个携带black关键字的消息将被发送到Q1和Q2队列。

## Emitting logs ##

我们将在日志系统中使用这种模式，使用direct交换机代替fanout交换机，同时以日志级别作为routing key。这样接收程序就可以根据日志级别来选择需要的消息。

首先，我们需要创建一个交换机

channel.exchangeDeclare(EXCHANGE_NAME, "direct");

使用创建好的交换机发送消息：

channel.basicPublish(EXCHANGE_NAME, severity, null, message.getBytes("UTF-8"));

为了方便起见，我们假设日志级别可以是info warn和error

## Subscribing ##

接收程序与之前教程中的程序基本一样，不同的是我们需要对每一个感兴趣的日志级别创建一个绑定关系。  
这里我们使用“error”创建一个绑定关系：

String queueName = channel.queueDeclare().getQueue();
    channel.queueBind(queueName, EXCHANGE_NAME, "error");

## Putting it all together ##

![在这里插入图片描述][20190228224120711.PNG]  
EmitLogDirect.java:

public class EmitLogDirect {
    
        public static final String EXCHANGE_NAME = "direct_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, "direct");
    
                String severity = "error";
                String message = "runtimeException";
    
                channel.basicPublish(EXCHANGE_NAME, severity, null, message.getBytes("UTF-8"));
                System.out.println(" [x] Sent ' " + severity + "':'" + message + "'");
            }
        }
    }

ReceiveLogsDirect.java:

public class ReceiveLogsDirect {
    
        public static final String EXCHANGE_NAME = "direct_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, "direct");
            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]

[Routing]: http://www.rabbitmq.com/tutorials/tutorial-four-java.html
[20190228223139535.PNG]: /images/20220316/52889528fed14fcfb2cf709a04d2b5d3.png
[20190228223317843.PNG]: /images/20220316/b9eb0e0a00c34f35a1ee5e532f52ccbe.png
[20190228224120711.PNG]: /images/20220316/afb68e962e1f4b7890f380b6ff256a3a.png
[https_github.com_Edenwds_rabbitmq_study_tree_master_routing]: https://github.com/Edenwds/rabbitmq_study/tree/master/routing