springboot配置mq
时间: 2023-11-08 09:02:46 浏览: 85
首先,需要在pom.xml中引入spring-boot-starter-amqp依赖。然后在application.properties中配置MQ的连接信息,例如:
```
spring.rabbitmq.host=localhost
spring.rabbitmq.port=5672
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest
```
接下来,我们可以创建一个消息发送者或者消息消费者,使用注解 @EnableRabbit 开启对RabbitMQ的支持。例如:
```java
@Component
@EnableRabbit
public class RabbitMQSender {
@Autowired
private RabbitTemplate rabbitTemplate;
public void send(String message) {
rabbitTemplate.convertAndSend("exchangeName", "routingKey", message);
}
@RabbitListener(queues = "queueName")
public void receive(String message) {
System.out.println("Received message: " + message);
}
}
```
在上面的代码中,我们通过使用RabbitTemplate发送消息到交换机,然后使用@RabbitListener注解监听队列中的消息。
阅读全文