springboot整合rabbitMQ具体代码
时间: 2023-02-08 11:28:23 浏览: 150
springboot+整合rabbitmq的全套代码
Spring Boot 整合 RabbitMQ 的具体代码如下:
1. 在 pom.xml 中添加 RabbitMQ 的依赖:
```xml
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-amqp</artifactId>
</dependency>
```
2. 在 application.properties 或 application.yml 中配置 RabbitMQ 的连接信息:
```yml
spring:
rabbitmq:
host: localhost
port: 5672
username: guest
password: guest
```
3. 在需要发送消息的类中注入 RabbitTemplate,并使用它来发送消息:
```java
@Autowired
private RabbitTemplate rabbitTemplate;
public void send(String message) {
rabbitTemplate.convertAndSend("exchangeName", "routingKey", message);
}
```
4. 在需要接收消息的类中使用 @RabbitListener 注解,并在方法中接收消息:
```java
@RabbitListener(queues = "queueName")
public void receive(String message) {
// do something with the message
}
```
这只是整合 RabbitMQ 的基本流程,具体实现还可能根据项目需求进行更多的设置和配置。
阅读全文