RabbitMQ_02 进阶 - 过期时间TTL
...大约 3 分钟
RabbitMQ进阶 - 过期时间TTL
Time to Live 简称 TTL,即过期时间。RabbitMQ 可以对 消息 和 队列 设置 TTL。
1. 设置消息的 TTL
- 通过队列设置:队列中的消息都有相同的过期时间
- 对消息本身设置:每条消息的 TTL 可以不同
如果两种一起设置,则以最小的 TTL 生效。
消息在队列中生存时间一旦超过 TTL,就会变成「死信(Dead Message)」,消费者将无法收到该消息。(具体细节后续章节讲解)
1.1 在队列上设置
定义队列时,通过参数 x-message-ttl
设置,单位是 毫秒
final HashMap<String, Object> arguments = new HashMap<>();
arguments.put("x-message-ttl", 6000);
channel.queueDeclare(QUEUE_NAME, true, false, false, arguments);
TTL 值得几种情况:
- 值为 0 :表示,除非此时可以直接将消息投递到消费者,否则该消息被立即丢弃
- 大于 0:将在该时间内过期,
1.2 在消息设置
通过 BasicProperties 来设置 expiration 属性:
final AMQP.BasicProperties.Builder builder = new AMQP.BasicProperties().builder();
builder.deliveryMode(2); // 持久化消息
builder.expiration("60000"); //设置消息的 ttl
channel.basicPublish(EXCHANGE_NAME,
"",
true,
builder.build(),
"mandatory test".getBytes()
);
此种方式当超过 TTL 时,并不会立即从队列中抹去,而是在投递消费者时判定的。而在队列上一旦过期,则立即从队列中抹去。
这是因为内部实现的原因导致的:
- 队列中已过期的消息肯定在队列头部,只要定期从队头开始扫描是否有过期的消息即可
- 在消息中设置的过期,需要扫描整个队列。
因为第一种方法里,队列中已过期的消息肯定在队列头部,RabbitMQ只要定期从队头开始扫描是否有过期消息即可,而第二种方法里,每条消息的过期时间不同,如果要删除所有过期消息,势必要扫描整个队列,所以不如等到此消息即将被消费时再判定是否过期,如果过期,再进行删除。
2. 设置队列的 TTL
注意这是队列TTL,上面两个都是消息TTL,只是1.1 的是在队列中设置消息ttl
定义队列时间,通过参数 x-expires
参数,单位为毫秒
final HashMap<String, Object> arguments = new HashMap<>();
// 该参数必须大于 0,要么就不设置
arguments.put("x-expires", 6000);
channel.queueDeclare(QUEUE_NAME, true, false, false, arguments);
channel.queueBind(QUEUE_NAME, EXCHANGE_NAME, ROUTING_KEY);
队列的 TTL 其实就是在声明:当队列空闲多久时,被自动删除。
空闲多久指的是:队列上没有任何消费者、也没有被重新声明、并且在过期时间内也未调用过 Basic.Get 命令
适合使用的场景:可以应用在类似 RPC 方式的回复队列,在 RPC 中,许多队列会被创建出来,但是未被使用。
参考文章
Powered by Waline v2.15.8