springboot rabbitmq发送消息队列
时间: 2023-10-22 21:20:01 浏览: 120
rabbitMQ消息队列
使用Spring Boot和RabbitMQ发送消息队列非常简单,只需要遵循以下步骤:
1. 添加依赖
首先,在Maven或Gradle中添加RabbitMQ客户端库的依赖项。例如,在Maven中添加以下依赖:
```xml
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-amqp</artifactId>
</dependency>
```
2. 配置RabbitMQ连接
在application.properties或application.yml中添加RabbitMQ连接相关的配置,例如:
```properties
spring.rabbitmq.host=localhost
spring.rabbitmq.port=5672
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest
```
3. 创建消息发送者
使用`RabbitTemplate`类创建一个消息发送者,例如:
```java
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
@Component
public class MessageSender {
@Autowired
private RabbitTemplate rabbitTemplate;
public void sendMessage(String message) {
rabbitTemplate.convertAndSend("exchange-name", "routing-key", message);
}
}
```
此处的exchange-name和routing-key需要根据你的具体需求进行配置。
4. 发送消息
在你的业务代码中调用`MessageSender`类的`sendMessage()`方法发送消息,例如:
```java
@Autowired
private MessageSender messageSender;
public void someMethod() {
messageSender.sendMessage("hello, RabbitMQ!");
}
```
这样就可以在RabbitMQ中发送一个消息了。
阅读全文