springboot rabbitmq延时队列

在Spring Boot中使用RabbitMQ实现延迟队列，可以通过以下两种主要方法来完成： ### 1. 利用TTL（Time To Live）和死信队列（Dead Letter Exchange, DLX） 这种方法是通过设置消息的TTL属性和队列的TTL属性，结合死信队列的机制来实现延迟队列的效果。具体步骤如下： - **定义交换机和队列**：首先需要定义一个普通交换机和一个死信交换机，以及一个普通队列和一个死信队列。普通队列需要配置其TTL值，并且设置死信交换机和死信路由键。 - **发送消息**：向普通交换机发送消息，并设置消息的TTL值。 - **处理消息**：当消息在普通队列中的生存时间超过设定的TTL值后，会被自动转发到死信交换机，进而被投递到死信队列中，由监听死信队列的消费者进行处理。 示例代码片段展示了如何监听延迟队列和死信队列： ```java private static final String DEAD_QUEUE_NAME = "test_dead_ttl_springboot_queue"; @RabbitListener(queues = "test_delay_ttl_springboot_queue") public void delay(Message message, Channel channel) throws IOException { String msg = new String(message.getBody(), "UTF-8"); System.out.println("msg : " + msg); channel.basicAck(message.getMessageProperties().getDeliveryTag(), false); } @RabbitListener(queues = DEAD_QUEUE_NAME) public void delay2(Message message, Channel channel) throws IOException { String msg = new String(message.getBody(), "UTF-8"); System.out.println("msg : " + msg); channel.basicAck(message.getMessageProperties().getDeliveryTag(), false); } ``` ### 2. 使用RabbitMQ的延迟插件 从RabbitMQ 3.5.7版本开始，可以使用`rabbitmq-delayed-message-exchange`插件来实现延迟队列。这种方法提供了更灵活的配置选项，并且可能提供更高的时间精度和可靠性。具体步骤如下： - **安装插件**：首先需要下载并安装`rabbitmq-delayed-message-exchange`插件。 - **声明自定义交换机**：在应用程序中声明一个带有`x-delayed-type`参数的自定义交换机。 - **发送消息**：发送消息时设置`x-delay`属性来指定延迟时间。 示例代码片段展示了如何声明一个带有延迟特性的交换机： ```java @Bean public CustomExchange delayedExchange() { return new CustomExchange("delayed_exchange", "x-delayed-message", true, false); } @Bean public Queue delayedQueue() { return QueueBuilder.durable("delayed_queue").build(); } @Bean public Binding bindingDelayedExchange(@Qualifier("delayedQueue") Queue queue, @Qualifier("delayedExchange") CustomExchange exchange) { return BindingBuilder.bind(queue).to(exchange).with("delayed_key").noargs(); } ``` 在发送消息时，可以通过设置`x-delay`属性来指定延迟时间： ```java MessageProperties props = new MessageProperties(); props.setDelay(5000); // 设置延迟时间为5秒 channel.basicPublish("delayed_exchange", "delayed_key", props, "Hello World".getBytes()); ``` 这两种方法各有优缺点，选择哪种方法取决于具体的业务需求和技术环境。如果需要更高精度的延迟控制和更复杂的延迟逻辑，推荐使用RabbitMQ的延迟插件；而对于简单的延迟需求，使用TTL和死信队列的方法更为简便。[^4]