springboot rabbitmq写一个消息队列
时间: 2023-07-04 19:13:40 浏览: 118
好的,首先需要在Spring Boot项目中添加RabbitMQ的依赖:
```xml
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-amqp</artifactId>
</dependency>
```
接下来,需要配置RabbitMQ的连接信息,可以在`application.properties`或`application.yml`中添加以下配置:
```properties
spring.rabbitmq.host=localhost
spring.rabbitmq.port=5672
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest
```
然后,定义一个消息发送者和一个消息接收者。示例代码如下:
```java
// 消息发送者
@Component
public class MessageSender {
@Autowired
private AmqpTemplate amqpTemplate;
public void sendMessage(String message) {
amqpTemplate.convertAndSend("myExchange", "myRoutingKey", message);
}
}
// 消息接收者
@Component
@RabbitListener(queues = "myQueue")
public class MessageReceiver {
@RabbitHandler
public void handleMessage(String message) {
System.out.println("Received message: " + message);
}
}
```
这里定义了一个名为`myExchange`的Exchange和一个名为`myQueue`的Queue,然后在`MessageSender`中发送消息到`myExchange`,在`MessageReceiver`中监听并处理`myQueue`中的消息。
最后,在启动类上加上`@EnableRabbit`注解启用RabbitMQ支持即可。
```java
@SpringBootApplication
@EnableRabbit
public class Application {
public static void main(String[] args) {
SpringApplication.run(Application.class, args);
}
}
```
以上就是一个简单的Spring Boot RabbitMQ消息队列的实现。
阅读全文