RabbitMQ springboot基本用法
时间: 2023-07-11 09:28:31 浏览: 53
在 Spring Boot 中使用 RabbitMQ 需要先配置 RabbitMQ 的连接信息,然后定义消息发送者和消息接收者,最后在应用程序中使用它们来发送和接收消息。
以下是 RabbitMQ Spring Boot 的基本用法:
1. 引入依赖
在 pom.xml 文件中添加以下依赖:
```xml
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-amqp</artifactId>
</dependency>
```
2. 配置 RabbitMQ 连接信息
在 application.properties 或 application.yml 文件中添加以下配置:
```yaml
spring.rabbitmq.host=localhost
spring.rabbitmq.port=5672
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest
```
3. 定义消息发送者
```java
@Component
public class MessageSender {
@Autowired
private RabbitTemplate rabbitTemplate;
public void sendMessage(String message) {
rabbitTemplate.convertAndSend("exchange-name", "routing-key", message);
}
}
```
4. 定义消息接收者
```java
@Component
public class MessageReceiver {
@RabbitListener(queues = "queue-name")
public void receiveMessage(String message) {
System.out.println("Received message: " + message);
}
}
```
5. 发送和接收消息
在应用程序中使用消息发送者来发送消息:
```java
@Autowired
private MessageSender messageSender;
messageSender.sendMessage("Hello, RabbitMQ!");
```
在应用程序中使用消息接收者来接收消息:
```java
@Autowired
private MessageReceiver messageReceiver;
```
以上就是 RabbitMQ Spring Boot 的基本用法,它可以帮助您在应用程序中轻松地集成 RabbitMQ。