springboot接入MQ

在Spring Boot中接入MQ，可以使用Spring Boot提供的JMS（Java Message Service）或者AMQP（Advanced Message Queuing Protocol）规范的消息中间件。下面以RabbitMQ为例，介绍如何在Spring Boot中接入MQ：

1. 添加依赖

在pom.xml文件中添加以下依赖：

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-amqp</artifactId>
</dependency>

2. 配置连接信息

在application.properties文件中配置RabbitMQ的连接信息：

spring.rabbitmq.host=your_host
spring.rabbitmq.port=your_port
spring.rabbitmq.username=your_username
spring.rabbitmq.password=your_password

3. 发送消息

使用RabbitTemplate发送消息：

@Autowired
private RabbitTemplate rabbitTemplate;

public void send(String message) {
    rabbitTemplate.convertAndSend("exchange_name", "routing_key", message);
}

4. 接收消息

使用@RabbitListener注解监听消息：

@RabbitListener(queues = "queue_name")
public void receive(String message) {
    System.out.println("Received message: " + message);
}