SpringBoot如何监听RabbitMQ消息?
时间: 2024-02-17 17:30:48 浏览: 73
Spring Boot 提供了 RabbitMQ 的支持,可以通过 RabbitMQTemplate 和 RabbitListenerContainerFactory 来监听消息。
首先,需要在 pom.xml 文件中添加 RabbitMQ 的依赖:
```xml
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-amqp</artifactId>
</dependency>
```
然后,使用 @RabbitListener 注解定义一个方法来监听消息。例如:
```java
@Component
public class RabbitMQListener {
@RabbitListener(queues = "myQueue")
public void receiveMessage(String message) {
System.out.println("Received message: " + message);
}
}
```
在这个例子中,@RabbitListener 注解定义了监听名为 "myQueue" 的队列,当队列中有消息到达时,receiveMessage() 方法将被调用,并且将消息内容作为参数传递给方法。
最后,在 application.properties 文件中配置 RabbitMQ 的连接信息:
```
spring.rabbitmq.host=localhost
spring.rabbitmq.port=5672
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest
```
这样就完成了 RabbitMQ 消息监听的配置。
阅读全文