《RabbitMQ系列教程-第十章-RabbitMQ之延时队列》

拼搏现实的明天。 2023-01-02 04:20 67阅读 0赞

# 教程说明 #

*  本系列教程目录大纲：[《RabbitMQ系列教程-目录大纲》][RabbitMQ_-]

--------------------

*  本系列教程配套代码：[https://gitee.com/Horizon1024/rabbitmt.git][https_gitee.com_Horizon1024_rabbitmt.git]（码云地址）

--------------------

# RabbitMQ之延时队列 #

有时候我们希望消息到达之后不会被立即消费，而是等到指定的时间进行消费，这个时候我们就可以利用延时队列来完成我们的功能

延时队列的应用场景：

1）下一个订单，如果10分钟后还未支付，那么修改其订单状态

2）当用户3天未登录，进行登录提醒、礼包赠送等

3）开启一个会议后，会议达到开始时间时自动更改状态

在`RabbitMQ`中，我们可以借助**TTL+死信队列**来完成延时队列的效果

> **延时队列很大程度上解决了我们以前定时器的功能，定时器通常采用每秒、每分钟轮询方式进行，这样不仅效率低，对数据库压力也非常大，代码不够严谨美观；**

#### 延时队列工作流程图： ####

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0JiMTUwNzAwNDc3NDg_size_16_color_FFFFFF_t_70_pic_center]

当一个`Producer`发送出一个消息之后，设置过期时间并推送到指定的业务队列中（或业务交换机），超过指定的时间不消费，该消息自动成为死信，并交由死信交换机分发给死信队列，消费者只要监听死信队列中的消息即可；

> **上述案例中Producer直接将消息发送给Queue，也可以发送给业务交换机，然后由业务交换机转发给Queue**

### 7.4.2 案例测试 ###

#### 配置spring.xml： ####

<rabbit:queue name="test_queue_dlx2" id="test_queue_dlx2">
        <rabbit:queue-arguments>
            
            <entry key="x-dead-letter-exchange" value="exchange_dlx"/>
    
            
            <entry key="x-dead-letter-routing-key" value="dlx.abc"/>
        </rabbit:queue-arguments>
    </rabbit:queue>

#### 测试类： ####

/** * 延迟队列 * TTL+死信队列 */
    @Test
    public void testDelay() { 
        //1. 测试过期时间，死信消息
        MessageProperties prop = new MessageProperties();
        // 5s不消费消息将成为死信
        prop.setExpiration("5000");
    
        Message message = new Message("delay=ttl+dl".getBytes(), prop);
    
        rabbitTemplate.convertAndSend("test_queue_dlx2", message);
    }

> 测试观察，发送消息到test\_queue\_dlx2（正常的队列）中，5s没有消费该消息自动到死信队列中；

[RabbitMQ_-]: https://blog.csdn.net/Bb15070047748/article/details/112194912
[https_gitee.com_Horizon1024_rabbitmt.git]: https://gitee.com/Horizon1024/rabbitmt.git
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0JiMTUwNzAwNDc3NDg_size_16_color_FFFFFF_t_70_pic_center]: /images/20221120/2436a678fcf14dfbaf509382ef8c48a4.png