RabbitMQ消息TTL与队列TTL

RabbitMQ 消息 TTL 与队列 TTL

在 RabbitMQ 中，TTL（Time To Live） 用于控制消息和队列的过期时间。理解消息 TTL 和队列 TTL 的区别，以及队头消息的删除机制，是构建可靠消息系统的重要环节。

一、核心概念

1.1 两种 TTL 类型

重要区别：

• 消息 TTL 过期：消息被删除，队列还在
• 队列 TTL 过期：队列和所有消息一起被删除

1.2 队头消息删除机制

队头（Head） 指队列中等待时间最长的消息（最先进入队列的消息）。

RabbitMQ 不会主动扫描所有消息来删除过期消息，而是采用惰性删除策略：

关键点：消息过期后不会立即删除，只有在被消费或队列重启时才会清理。

二、消息 TTL

2.1 作用范围

消息 TTL 可以在两个地方设置：

当两者都设置时，以较小值为准（即先过期的生效）。

2.2 非 Spring 环境（原生 Java Client）

// 方式一：队列声明时设置
Map<String, Object> args = new HashMap<>();
args.put("x-message-ttl", 30000); // 30秒
channel.queueDeclare("my.queue", true, false, false, args);

// 方式二：发送消息时设置
AMQP.BasicProperties props = new AMQP.BasicProperties.Builder()
.expiration("30000") // 30秒（字符串，单位毫秒）
.build();
channel.basicPublish("", "my.queue", props, "message".getBytes());

2.3 Spring 环境（Spring AMQP）

// 方式一：队列声明时设置
@Bean
public Queue ttlQueue() {
return QueueBuilder.durable("ttl-queue")
.ttl(30000) // 30秒
.build();
}

// 方式二：发送消息时设置
rabbitTemplate.convertAndSend("my-exchange", "routing.key", "message", msg -> {
msg.getMessageProperties().setExpiration("30000"); // 30秒
return msg;
});

三、队列 TTL

3.1 作用范围

队列 TTL 是队列级别的过期时间，队列在指定时间内没有被消费，整个队列会被删除。

3.2 非 Spring 环境（原生 Java Client）

Map<String, Object> args = new HashMap<>();
args.put("x-expires", 60000); // 60秒后队列过期
channel.queueDeclare("temp-queue", true, false, false, args);

3.3 Spring 环境（Spring AMQP）

@Bean
public Queue expiresQueue() {
return QueueBuilder.durable("expires-queue")
.expires(60000) // 60秒
.build();
}

四、消息 TTL vs 队列 TTL

五、注意事项