文章目录

• RabbitMQ第四个实操小案例——DirectExchange

RabbitMQ第四个实操小案例——DirectExchange

DirectExchange：这种交换机的模式跟前面的Fouout（广播）不太一样，DirectExchange 会将接收到的消息根据规则路由到指定的Queue，因此也被称之为 路由模式（routes）。

他的模型如下所示：

我们先说一下上面这个图吧：

• 每一个Queue都与Exchange绑定一个或多个bingingKey。（上面queue1与exchange绑定的bindingKey有red和blue，queue2与exchange绑定的bindingKey有red和yellow。）
• Publisher发送消息时，指定消息的bindingKey。
• Exchange根据消息的bindingKey，将消息转发到对应的Queue。
  • 假如现在发送的消息的bindingKey为blue，那么消息将被queue1接收。
  • 假如现在发送的消息的bindingKey为yellow，那么消息将被queue2接收。
  • 假如现在发送的消息的bindingKey为red，那么消息将被queue1和queue2同时接收。

OK，废话少说，老规矩，咱们代码来一波：
实现思路：

步骤一、配置我们的配置类。
步骤二、在Consumer服务中，编写两个消费者方法，分别监听direct.queue1和direct.queue2。
步骤三、在Publisher服务中，编写测试方法，向交换机exchange.direct发送消息。

步骤一、使用我们的@RabbitListener注解声明我们的Exchange、Queue、RoutingKey，编写两个消费者方法。

@RabbitListener(bindings = @QueueBinding(value = @Queue(name = "direct.queue1"),exchange = @Exchange(name = "exchange.direct", type = ExchangeTypes.DIRECT),key = {"red", "blue"}
))
public void listenerDirectQueue1(String msg){System.out.println("监听到 direct.queue1 的消息为：【"+ msg +"】");
}@RabbitListener(bindings = @QueueBinding(value = @Queue(name = "direct.queue2"),exchange = @Exchange(name = "exchange.direct", type = ExchangeTypes.DIRECT),key = {"red", "yellow"}
))
public void listenerDirectQueue2(String msg){System.err.println("监听到 direct.queue2 的消息为：【"+ msg +"】");
}

编写完代码，我们重启一下我们的消费者服务，然后我们看一下我们的RabbitMQ。可以看到，此时我们的交换机中，绑定的有两个queue，其中queue1监听的RoutingKey有blue和red、queue2监听的RoutingKey有yellow和red。

我们也可以看看我们的queue，确实也多了俩，一个叫direct.queue1，一个叫direct.queue2。

步骤二、在Publisher服务中，编写测试方法，向交换机exchange.direct发送消息。

    @Testpublic void testDirectExchange(){//交换机的名称String exchangeName = "exchange.direct";//消息String blueMsg = "Hello, Blue.";String redMsg = "Hello, Red.";String yellowMsg = "Hello, Yellow.";//发送消息for (int i = 0; i < 10; i++){if (i % 3 == 0){rabbitTemplate.convertAndSend(exchangeName, "blue", blueMsg);}else if (i % 3 == 1){rabbitTemplate.convertAndSend(exchangeName, "yellow", yellowMsg);}else {rabbitTemplate.convertAndSend(exchangeName, "red", redMsg);}}}

运行我们的测试方法后，我们看一下Consumer服务的控制台打印消息：

可以看到，direct.queue1 监听到的消息有 Hello, Red 和 Hello, Blue，而direct.queue2 监听到的消息有 Hello, Red 和 Hello, Yellow.