RabbitMQ之 Direct 交换机

news2025/1/21 12:00:02

👽System.out.println(“👋🏼嗨，大家好，我是代码不会敲的小符，双非大四，Java实习中…”);
📚System.out.println(“🎈如果文章中有错误的地方，恳请大家指正！共同进步，共同成长✊”);
🌟System.out.println(“💡如果文章对您有所帮助，希望您可以三连支持一下博主噢🔥”);
🌈System.out.println("🚀正在完成计划中：接下来的三个月里，对梦想的追逐 ");

文章目录

- Direct交换机
- - 模拟使用 DirectExchange
  - 发送者（生产者）
  - 消费者
- 交换机的作用
- 最后

Direct交换机

Direct Exchange 会将接收到的消息根据规则路由到指定的Queue因此称为定向路由

每一个Queue都与Exchange设置一个BindingKey
发布者发送消息时，指定消息的RoutingKey
Exchange将消息路由到BindingKey与消息RoutingKey一致的队列

模拟使用 DirectExchange

利用SpringAMQP演示的使用，实现思路如下

在RabbitMQ控制台中，声明队列direct.queue1和direct.queue2
direct.queue1 绑定路由 red、blue；direct.queue2 绑定路由 red、yellow
在RabbitMQ控制台中，声明交换机directTest.direct，将两个队列与其绑定
在consumer服务中，编写两个消费者方法，分别监听direct.queue1和direct.queue2
在publisher中编写测试方法，向directTest.direct发送消息

发送者（生产者）

@SpringBootTest
public class SpringAmqpTest {
    @Autowired
    private RabbitTemplate rabbitTemplate;

    @Test
    public void testSendMessage2DirectQueue1() {
        String exchangeName = "directTest.direct";
        String msg = "hello, exchangeName_directTest, message: red! red! red! " ;
        rabbitTemplate.convertAndSend(exchangeName, "red", msg);
    }
    @Test
    public void testSendMessage2DirectQueue2() {
        String exchangeName = "directTest.direct";
        String msg = "hello, exchangeName_directTest, message: blue! blue! blue! " ;
        rabbitTemplate.convertAndSend(exchangeName, "blue", msg);
    }
    @Test
    public void testSendMessage2DirectQueue3() {
        String exchangeName = "directTest.direct";
        String msg = "hello, exchangeName_directTest, message: yellow! yellow! yellow! " ;
        rabbitTemplate.convertAndSend(exchangeName, "yellow", msg);
    }
}

消费者

@Component
@Slf4j
public class RabbitMqListener {

    @RabbitListener(queues = "direct.queue1")
    public void listenDirectQueueMessage1(String msg) {
        log.info("directConsumer1 accept message: {}", msg);
        log.info("directConsumer1 message success!");
    }

    @RabbitListener(queues = "direct.queue2")
    public void listenDirectQueueMessage2(String msg) {
        log.info("directConsumer2 accept message: {}", msg);
        log.info("directConsumer2 message success!");
    }
}

交换机的作用

接收publisher发送的消息
将消息按照规则路由到与之绑定的队列
Direct Exchange 将消息路由转发到 BindingKey 与消息 RoutingKey 一致的队列。Direct交换机是根据消息的Routing Key来进行路由的
DirectExchange 通常用于一对一的消息传递场景，例如，订单系统中的订单创建、修改和取消等消息需要被路由到不同的队列中进行处理。在这种场景下，每个队列都需要绑定一个唯一的Routing Key，以确保消息能够被正确地路由到目标队列中去