当前位置：首页 > news >正文

RabbitMQ之基于注解声明队列交换机：使用@RabbitListener实现消息监听

news 来源：原创 2024/9/20 12:07:23

文章目录

- 什么是`@RabbitListener`？
- 队列和交换机的基本概念
- 使用`@RabbitListener`注解声明队列和交换机
- - 代码解析
  - - 1. `@QueueBinding`
    - 2. 消费者方法
- 运行原理
- 应用场景
- 总结

在现代的微服务架构中，消息队列是一种重要的异步通信机制。RabbitMQ作为一种流行的消息代理软件，提供了丰富的功能来处理消息的发布和订阅。在Spring Boot应用中，我们可以使用Spring AMQP提供的注解来简化RabbitMQ的配置和使用。本文将介绍如何使用 @RabbitListener注解来声明队列和交换机，并实现消息监听。

什么是`@RabbitListener`？

@RabbitListener是Spring AMQP框架提供的一个注解，用于定义一个方法，该方法可以监听指定的队列，并在接收到消息时自动调用。通过这种方式，我们可以非常方便地实现消息的异步处理。

队列和交换机的基本概念

在RabbitMQ中，消息的传递依赖于两个核心组件：队列和交换机。

队列（Queue）：用来存储消息，消费者可以从队列中读取消息。
交换机（Exchange）：负责接收生产者发送的消息，并根据绑定的规则将消息路由到一个或多个队列。

常见的交换机类型有：

Direct：根据消息的路由键（routing key）精确匹配队列。
Topic：根据路由键的模式匹配队列。
Fanout：将消息广播到所有绑定的队列。

使用`@RabbitListener`注解声明队列和交换机

下面我们通过一个具体的例子来展示如何使用@RabbitListener注解来声明队列和交换机。

@RabbitListener(bindings = @QueueBinding(value = @Queue(name = "direct.queue1", durable = "true"),exchange = @Exchange(name = "hmall.direct", type = ExchangeTypes.DIRECT),key = {"red", "blue"}
))
public void listenDirectQueue1(String message) {log.info("消费者1监听到direct.queue1消息：{}", message);
}@RabbitListener(bindings = @QueueBinding(value = @Queue(name = "direct.queue2", durable = "true"),exchange = @Exchange(name = "hmall.direct", type = ExchangeTypes.DIRECT),key = {"red", "yellow"}
))
public void listenDirectQueue2(String message) {log.info("消费者2监听到direct.queue2消息：{}", message);
}

代码解析

1. `@QueueBinding`

@QueueBinding用于绑定队列和交换机，并指定路由键。它包含以下几个属性：

value：声明一个队列，使用@Queue注解。
- name：队列名称，如direct.queue1和direct.queue2。
- durable：是否持久化队列。设置为true表示消息队列重启后依然存在。
exchange：声明一个交换机，使用@Exchange注解。
- name：交换机名称，如hmall.direct。
- type：交换机类型，这里使用ExchangeTypes.DIRECT表示Direct交换机。
key：路由键数组，指定消息匹配的路由键。如direct.queue1监听red和blue两个路由键的消息。

2. 消费者方法

listenDirectQueue1：监听direct.queue1，当队列接收到符合路由键red或blue的消息时，方法被调用，输出日志信息。
listenDirectQueue2：监听direct.queue2，当队列接收到符合路由键red或yellow的消息时，方法被调用，输出日志信息。