springboot集成rabbmitmq
时间: 2023-07-05 20:31:53 浏览: 51
好的,以下是Spring Boot集成RabbitMQ的步骤:
1. 添加依赖
在pom.xml文件中添加以下依赖:
```
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-amqp</artifactId>
</dependency>
```
2. 配置RabbitMQ连接信息
在application.properties文件中添加以下配置:
```
spring.rabbitmq.host=your-rabbitmq-host
spring.rabbitmq.port=5672
spring.rabbitmq.username=your-rabbitmq-username
spring.rabbitmq.password=your-rabbitmq-password
```
3. 创建消息发送者
使用注入的AmqpTemplate对象发送消息,示例代码如下:
```
@RestController
public class MessageController {
@Autowired
private AmqpTemplate rabbitTemplate;
@GetMapping("/send")
public String sendMessage() {
String message = "Hello, RabbitMQ!";
rabbitTemplate.convertAndSend("queue-name", message);
return "Message sent: " + message;
}
}
```
4. 创建消息接收者
使用@RabbitListener注解监听指定的队列,示例代码如下:
```
@Component
public class MessageReceiver {
@RabbitListener(queues = "queue-name")
public void receiveMessage(String message) {
System.out.println("Received message: " + message);
}
}
```
以上就是Spring Boot集成RabbitMQ的基本步骤,你可以根据业务需求进行自定义配置和开发。