springboot 操作rabbitmq
时间: 2023-09-22 21:12:18 浏览: 42
Spring Boot提供了很好的支持来使用RabbitMQ。以下是在Spring Boot应用程序中使用RabbitMQ的步骤:
1. 添加RabbitMQ依赖
在pom.xml文件中添加以下依赖:
```
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-amqp</artifactId>
</dependency>
```
2. 配置RabbitMQ连接信息
在application.properties文件中添加以下配置:
```
spring.rabbitmq.host=localhost
spring.rabbitmq.port=5672
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest
```
3. 创建RabbitMQ消息接收者
使用@RabbitListener注解创建一个消息接收者方法,该方法将在接收到消息时被调用。
```
@Component
public class RabbitMQReceiver {
@RabbitListener(queues = "${myqueue}")
public void receiveMessage(String message) {
System.out.println("Received message: " + message);
}
}
```
4. 发送消息到RabbitMQ
使用RabbitTemplate发送消息到RabbitMQ。
```
@Autowired
private RabbitTemplate rabbitTemplate;
public void sendMessage(String message) {
rabbitTemplate.convertAndSend("${myexchange}", "${myroutingkey}", message);
}
```
在上面的代码中,${myexchange}和${myroutingkey}是交换机和路由键的名称,$ {myqueue}是队列的名称。
5. 运行应用程序
运行Spring Boot应用程序并发送消息到RabbitMQ,然后在控制台中查看消息接收。
以上是在Spring Boot应用程序中使用RabbitMQ的步骤。