SpringBoot实现RabbitMQ的定向交换机(SpringAMQP 实现Direct定向交换机)

news2025/4/19 7:58:39

文章目录

Direct 交换机特点
实战
- 声明交换及其队列(以注解方式)
- 发消息
应用

在这里插入图片描述

上一篇文章中的 Fanout 模式，一条消息，会被所有订阅其交换机的队列都消费。

但是，在某些场景下，我们希望不同的消息被不同的队列消费。这时就要用到 Direct类型的交换机。

Direct 交换机特点

在Direct模型下：

队列与交换机的绑定，不能是任意绑定了，而是要指定一个RoutingKey（路由key）
消息的发送方在向 Exchange发送消息时，也必须指定消息的 RoutingKey。
Exchange不再把消息交给每一个绑定的队列，而是根据消息的Routing Key进行判断，只有队列的Routingkey与消息的 Routing key完全一致，才会接收到消息

实战

我们定义一个定向交换机( Direct Exchange )
再定义两个队列,让这两个队列绑定到该交换机上,并且按照如下图 key 的规则绑定.

在这里插入图片描述

声明交换及其队列(以注解方式)

上篇文章是按照基于@Bean的方式声明队列和交换机比较麻烦，Spring还提供了基于注解方式来声明。

在consumer的 SpringRabbitListener 中添加两个消费者，同时基于注解来声明队列和交换机：

 /** 基于注解的来声明交换机和队列及其绑定关系 */
@RabbitListener( bindings = @QueueBinding(
        exchange = @Exchange(name = "test2024.direct", type = ExchangeTypes.DIRECT),
        value = @Queue(name = "test2024.direct.redOrBlueOrYellow"),
        key = {"red", "yellow", "blue"}
))
public void rabbitListener5(String message) {
    System.out.println("红黄蓝: " + message);
}

@RabbitListener( bindings = @QueueBinding(
        exchange = @Exchange(name = "test2024.direct", type = ExchangeTypes.DIRECT),
        value = @Queue(name = "test2024.direct.WhiteOrBlack"),
        key = {"white", "black"}
))
public void rabbitListener6(String message) {
    System.out.println("黑白: " + message);
}
/** 基于注解的来声明交换机和队列及其绑定关系 */

启动上面的服务后我们发现指定的交换机和队列都创建好了

在这里插入图片描述

发消息

//  测试定向交换机
@Test
public void test03() throws InterruptedException {
    String exchangeName = "test2024.direct";
    String[] keyArray = {"red", "yellow", "blue", "black", "white"};
    String message = "this is a message from direct! key: ";
    for (int i = 0; i < 50; i++) {
        int index = new Random().nextInt(keyArray.length);
        rabbitTemplate.convertAndSend(exchangeName, keyArray[index], message + keyArray[index]);
    }
    Thread.sleep(500);
}

在这里插入图片描述

看到数据都规规整整的进入指定的key对应的队列,并被消费.

应用

Direct 交换机适用于一对一的消息传递模式，它通过消息的路由键（Routing Key）将消息发送到与之完全匹配的队列中。因此，Direct交换机常用于以下情况：

点对点通信：当系统中存在一对一的通信需求时，可以使用Direct交换机来确保消息被准确地路由到目标队列。例如，订单系统中将订单消息发送到指定的订单处理队列。
任务分发：在分布式系统中，可以使用Direct交换机来将任务分发到不同的工作节点。每个工作节点都可以绑定一个特定的队列，根据任务的类型或者其他属性，将任务发送到相应的队列中。
系统内部通知：当系统需要向特定的用户或者部门发送通知消息时，可以使用Direct交换机来确保消息仅发送给目标接收者，而不会广播给所有用户。
错误处理：在系统中可能会发生错误，需要将错误消息发送到指定的队列中进行处理。Direct交换机可以将错误消息准确地路由到错误处理队列，方便进行后续的排查和处理。

Direct交换机适用于需要精确路由消息到指定队列的场景，是一种简单而高效的消息传递方式。

在这里插入图片描述