通常在应用开发中我们会碰到定时任务的需求，比如未付款订单，超过一定时间后，系统自动取消订单并释放占有物品。
许多同学的第一反应就是通过spring的schedule定时任务轮询数据库来实现，这种方案有一下几点劣势：
（1）消耗系统内存，由于定时任务一直在系统中占着进程，比较消耗内存
（2）增加了数据库的压力，这个提现在两方面，一是长时间占着数据库的连接，而是查询基数大
（3）存在较大的时间误差
如果我们利用第三方插件如rabbitmq来实现，就可以解决以上几种问题。
那么如何实现呢？
rabbitmq的消息TTL和死信Exchange结合
1.消息的TTL（Time To Live）
消息的TTL就是消息的存活时间。RabbitMQ可以对队列和消息分别设置TTL。对队列设置就是队列没有消费者连着的保留时间，也可以对每一个单独的消息做单独的设置。超过了这个时间，我们认为这个消息就死了，称之为死信。如果队列设置了，消息也设置了，那么会取小的。所以一个消息如果被路由到不同的队列中，这个消息死亡的时间有可能不一样（不同的队列设置）。这里单讲单个消息的TTL，因为它才是实现延迟任务的关键。可以通过设置消息的expiration字段或者x-message-ttl属性来设置时间，两者是一样的效果。
2.Dead Letter Exchanges
Exchage的概念在这里就不在赘述。一个消息在满足如下条件下，会进死信路由，记住这里是路由而不是队列，一个路由可以对应很多队列。
①.一个消息被Consumer拒收了，并且reject方法的参数里requeue是false。也就是说不会被再次放在队列里，被其他消费者使用。
②. 上面的消息的TTL到了，消息过期了。
③. 队列的长度限制满了。排在前面的消息会被丢弃或者扔到死信路由上。
Dead Letter Exchange其实就是一种普通的exchange，和创建其他exchange没有两样。只是在某一个设置Dead Letter Exchange的队列中有消息过期了，会自动触发消息的转发，发送到Dead Letter Exchange中去。
3.实现延迟队列
盗图一张
延迟队列的工作流程
4.在springboot中的应用
a.配置消息队列
在消息队列的参数配置中，先建立消息队列和死信交换机，并将其绑定起来，代码片段如下
TTL队列和死信交换机的配置
b.配置转发队列（TTL队列中的消息过期后，转发目标队列，即Queue2）
转发队列（死信接收队列）
c.监听转发队列，并进行业务处理
转发队列的监听处理
测试，利用junit测试，发送具有过期时间的消息
过期消息发送测试
配置完毕。
注意：由于队列的先进先出特性，只有当过期的消息到了队列的顶端（队首），才会被真正的丢弃或者进入死信队列。所以在考虑使用RabbitMQ来实现延迟任务队列的时候，需要确保业务上每个任务的延迟时间是一致的。如果遇到不同的任务类型需要不同的延时的话，需要为每一种不同延迟时间的消息建立单独的消息队列。
网友评论