RabbitMQ进阶 - 过期时间TTL

MrJason...大约 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);