RabbitMQ如何设置消息过期 ?

在 RabbitMQ 中，可以通过设置消息的 TTL（Time-To-Live，存活时间）来实现消息的过期控制。当消息的 TTL 时间到达后，RabbitMQ 将会自动将该消息标记为过期，并进行相应的处理。

消息的 TTL 可以通过两种方式进行设置：

1. 针对队列设置 TTL： 在声明队列时，可以通过设置 x-message-ttl 参数来指定队列中所有消息的默认 TTL。例如，声明一个具有 10 秒 TTL 的队列：
2. Copy Code

channel.queueDeclare("myQueue", false, false, false, 
    new HashMap<String, Object>(){{ put("x-message-ttl", 10000); }});

1. 针对单个消息设置 TTL： 在发送消息时，可以通过设置消息的属性 expiration 来指定该消息的 TTL。属性 expiration 的值可以是一个时间段（如 "5000" 表示 5 秒）或者一个绝对的时间戳（如 "1626897600000" 表示 2021 年 7 月 22 日的时间戳）。
2. Copy Code

AMQP.BasicProperties properties = new AMQP.BasicProperties.Builder()
    .expiration("5000")
    .build();
channel.basicPublish("", "myQueue", properties, messageBytes);

需要注意以下几点：

• 当消息的 TTL 时间到达时，RabbitMQ 并不会立即删除过期消息，而是等待下次清理操作执行时才会删除。清理操作的执行频率由 RabbitMQ 的策略配置决定。
• 在消息的 TTL 和队列的 TTL 都设置时，较小的那个值会生效。
• 消息的 TTL 只会在消息在队列中等待投递时生效，不包括已经被消费者接收的消息。
• RabbitMQ 的消息过期功能是基于时钟的，因此它的精确度可能受到系统时钟的影响。

通过设置消息的 TTL，可以控制消息在队列中的存活时间，从而实现消息的过期处理。这对于一些需要在一定时间后自动清理和丢弃消息的场景非常有用，比如缓存失效、任务超时等。