springboot 接入RabbitMQ

Spring Boot可以很方便地接入RabbitMQ作为消息队列。下面是一个简单的示例，演示如何在Spring Boot中使用RabbitMQ进行消息队列的操作。

首先，需要在`pom.xml`文件中添加RabbitMQ依赖：

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

接下来，在`application.properties`文件中配置RabbitMQ相关的属性：

spring.rabbitmq.host=localhost
spring.rabbitmq.port=5672
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest

然后，在Spring Boot的主类上使用`@EnableRabbit`注解启用RabbitMQ支持：

@EnableRabbit
@SpringBootApplication
public class MyApplication {
    public static void main(String[] args) {
        SpringApplication.run(MyApplication.class, args);
    }
}

接着，创建一个消息消费者：

@Component
public class RabbitMQConsumer {
    @RabbitListener(queues = "my-queue")
    public void consume(String message) {
        // 处理接收到的消息
        System.out.println("Received message: " + message);
    }
}

最后，创建一个消息生产者：

@Component
public class RabbitMQProducer {
    private final RabbitTemplate rabbitTemplate;

    public RabbitMQProducer(RabbitTemplate rabbitTemplate) {
        this.rabbitTemplate = rabbitTemplate;
    }

    public void produce(String message) {
        // 发送消息到指定的queue
        rabbitTemplate.convertAndSend("my-queue", message);
    }
}

这样，你就可以在Spring Boot中使用RabbitMQ进行消息队列的操作了。