📣读完这篇文章里你能收获到
- 延时队列的应用场景介绍
- RabbitMQ通过TTL+DLX 实现定时任务
一、场景
- 订单下单60分钟后，如果用户没有付款，则自动取消订单
- 订单下单48小时后，如果商家没有发货，则发送信息提醒商家发货
二、问题
- 消耗系统内存，如果定时任务很多，长时间得不到释放，将会一直占用系统进程耗费内存。
- 单线程如何保障出现系统崩溃后之前的定时任务不受影响？多进程集群模式下一致性的保证？
- setTimeout、setInterval会存在时间误差，对于时间精度要求较高的是不行的。
三、TTL+DLX 实现定时任务
- RabbitMQ本身是不支持的，可以通过它提供的两个特性Time-To-Live and Expiration、Dead Letter Exchanges来实现，通过以下泳道图可以看到一个消息从发布到消费的整个过程。
1 死信队列
死信队列全称 Dead-Letter-Exchange 简称 DLX 是 RabbitMQ 中交换器的一种类型，消息在一段时间之后没有被消费就会变成死信被重新 publish 到另一个 DLX 交换器队列中，因此称为死信队列。
死信队列产生几种情况
- 消息被拒绝
- 消息TTL过期
- 队列达到最大长度
设置DLX的两个参数
- deadLetterExchange: 设置DLX，当正常队列的消息成为死信后会被路由到DLX中
- deadLetterRoutingKey: 设置DLX指定的路由键
注意：Dead-Letter-Exchange也是一种普通的Exchange
2 消息TTL
消息的TTL指的是消息的存活时间，RabbitMQ支持消息、队列两种方式设置TTL，分别如下：
- 消息设置TTL：对消息的设置是在发送时进行TTL设置，通过x-message-ttl 或expiration 字段设置，单位为毫秒，代表消息的过期时间，每条消息的TTL可不同。
- 队列设置TTL：对队列的设置是在消息入队列时计算，通过 x-expires 设置，队列中的所有消息都有相同的过期时间，当超过了队列的超时设置，消息会自动的清除。
注意：如果以上两种方式都做了设置，消息的TTL则以两者之中最小的那个为准。
