嗨客网搜索
RabbitMQ消息TTL

说明

举个例子:在电商平台上购买一个商品,但是下单了还没付款。系统提示会为你保留一段时间,比如 15 分钟,超过时间后未支付,订单就会被取消掉。

实现这个功能,一个笨拙的方法就是用定时任务,每分钟扫描下所有未付款的订单,判断是否到期。如果到期了,就删除订单。这种方式效率就很低下,做了很多无用功,另一种方法,你就可以使用 RabbitMQ 的 TTL 机制+死信队列来处理。

TTL机制

TTL,全称是 Time to Live,也就是过期时间。RabbitMQ 可以对消息或者队列设置过期时间。通过设置过期时间,如果消息没有消费,到期了就会被处理掉。这样在一个程度上就可以防止 MQ 的消息堆积问题。

  • 给队列设置过期时间,那就是队列中所有消息都有相同的过期时间,不管是早入队的消息,还是晚入队的消息,只要队列的过期时间一到,消息都会被处理掉。
  • 给消息设置过期时间,那就是每条消息的过期时间就都不一样了。
  • 给队列或者消息都设置过期时间,那过期的时间就以这两个时间中较小的为准。队列没到期,某条消息到期了,那这条消息被处理掉。队列到期,那就是覆巢之下焉有完卵了。

那到期了,消息是怎么被处理掉的?它们会变成 “死信”(死亡的消息,Dead Message),放到死信队列中,消费者默认就无法再收到这消息。但死信也是可以被取出来消费的。

默认情况下,如果不设置 TTL,消息就永不过期。如果 TTL 设置为 0,那表示消息要直接投递给消费者,否着消息就会被丢弃掉。

设置方法

设置队列属性

在 queue.declare 方法中加入 x-message-ttl 参数,单位为 ms:

Map<String, Object> argss = new HashMap<String, Object>(); argss.put("x-message-ttl",6000); channel.queueDeclare(queueName, durable, exclusive, autoDelete, argss);

设置消息属性

针对每条消息设置 TTL 的方法是在 basic.publish 方法中加入 expiration 的属性参数,单位为 ms。

AMQP.BasicProperties.Builder builder = new AMQP.BasicProperties.Builder(); builder.expiration("6000"); AMQP.BasicProperties properties = builder.build(); channel.basicPublish(exchangeName, routingKey, mandatory, properties, "ttlTestMessage".getBytes());
嗨客网顶部