springboot实现rabbitmq延时队列

要使用 Spring Boot 实现 RabbitMQ 延时队列，可以使用 RabbitMQ 的插件 RabbitMQ Delayed Message Exchange（rabbitmq_delayed_message_exchange）。

以下是实现步骤：

1. 首先，需要在 Maven 或 Gradle 中添加 RabbitMQ 的 Java 客户端库和 RabbitMQ Delayed Message Exchange 插件的依赖。例如，在 Maven 中添加以下依赖：

<dependency>
    <groupId>com.rabbitmq</groupId>
    <artifactId>amqp-client</artifactId>
    <version>5.11.0</version>
</dependency>
<dependency>
    <groupId>net._95point2.fmq</groupId>
    <artifactId>rabbitmq-delayed-message-exchange</artifactId>
    <version>2.2.0</version>
</dependency>

2. 在 Spring Boot 应用程序中配置 RabbitMQ 连接属性。可以使用 application.yml 或 application.properties 文件来配置。

spring:
  rabbitmq:
    host: localhost
    port: 5672
    username: guest
    password: guest

3. 创建一个配置类来配置 RabbitMQ Exchange。在这个类中，将使用 `CustomExchange` 类来创建一个延时 Exchange。需要为这个 Exchange 指定一个名称和类型，并且设置其参数 `x-delayed-type` 为要延迟的消息的 Exchange 类型，例如 `direct` 或 `topic`。

@Configuration
public class RabbitMQConfig {
    @Bean
    public CustomExchange delayedExchange() {
        Map<String, Object> args = new HashMap<>();
        args.put("x-delayed-type", "direct");
        return new CustomExchange("delayed_exchange", "x-delayed-message", true, false, args);
    }
}

4. 创建一个生产者来发送延迟消息。在这个生产者类中，注入 RabbitTemplate 并使用其 convertAndSend 方法发送消息。需要为消息设置一个 Routing Key，它将用于将消息路由到正确的队列。还需要为消息设置一个延迟时间，将消息发送到刚刚创建的 Exchange 中。

@Component
public class Producer {
    @Autowired
    private RabbitTemplate rabbitTemplate;

    public void sendDelayedMessage(String message, int delay) {
        rabbitTemplate.convertAndSend("delayed_exchange", "delayed_queue", message, message1 -> {
            message1.getMessageProperties().setDelay(delay);
            return message1;
        });
    }
}

5. 创建一个消费者来处理延迟消息。在这个消费者类中，注入 RabbitTemplate 并使用其 receiveAndConvert 方法来接收消息。需要为消费者设置一个队列，并将这个队列绑定到刚刚创建的 Exchange 上。

@Component
public class Consumer {
    @RabbitListener(queues = "delayed_queue")
    public void receiveMessage(String message) {
        System.out.println("Received message: " + message);
    }

    @Bean
    public Queue delayedQueue() {
        return QueueBuilder.durable("delayed_queue")
                .withArgument("x-dead-letter-exchange", "")
                .withArgument("x-dead-letter-routing-key", "real_queue")
                .build();
    }

    @Bean
    public Binding binding() {
        return BindingBuilder.bind(delayedQueue()).to(delayedExchange()).with("delayed_queue").