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发送消息。

    @Test
    public 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);
            }
        }
    }