上一篇文章中的 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交换机适用于需要精确路由消息到指定队列的场景，是一种简单而高效的消息传递方式。
