Rabbit MQ在spring boot中的使用

RabbitMQ 是一个开源的消息队列系统，它在 Spring Boot 应用中广泛用于解耦组件间的通信，提高系统的可扩展性和响应速度。在 Spring Boot 中使用 RabbitMQ，可以通过 Spring AMQP 提供的集成来简化配置和操作。以下是基本步骤：

1. 添加依赖：在你的 `pom.xml` 或者 `build.gradle` 文件中添加 Spring AMQP 和 RabbitMQ 客户端的依赖。

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

<!-- Gradle (Kotlin) -->
implementation("org.springframework.boot:spring-boot-starter-amqp")

2. 配置 RabbitMQ：在 `application.properties` 或 `application.yml` 中添加 RabbitMQ 的连接信息，如主机名、端口、用户名、密码和虚拟主机（vhost）。

spring.rabbitmq.host=localhost
spring.rabbitmq.port=5672
spring.rabbitmq.username=myuser
spring.rabbitmq.password=mypassword
spring.rabbitmq.virtual-host=/my-virtual-host

3. 创建 RabbitMQ 实体：定义消息的交换器（exchange）、队列（queue）、绑定（binding）以及消费者。你可以创建 `RabbitConfig` 类来配置这些元素。

4. 发送消息：使用 `RabbitTemplate` 来发送消息到指定的队列或主题。

@Autowired
private RabbitTemplate rabbitTemplate;

rabbitTemplate.convertAndSend("myQueue", "message to send");

5. 接收消息：创建一个实现了 `RabbitListener` 接口的类，Spring Boot 会自动处理消息的接收和处理。

@Component
public class MyConsumer implements RabbitListener {
    @RabbitHandler
    public void handle(String message) {
        System.out.println("Received message: " + message);
    }
}