[大数据]RabbitMQ---消息过期时间（TTL）

目前有两种方法可以设置消息的 TTL 。

1. 通过队列属性设置，队列中所有消息都有相同的过期时间。

2. 对消息本身进行单独设置，每条消息的 TTL 可以不同。

   如果两种方法一起使用，则消息的 TTL 以两者之间较小的那个数值为准。消息在队列中的生存时一旦超过设置 TTL 值时，就会变成"死信" (Dead Message) ，消费者将无法再收到该消息(当然也不是绝对)。

下面我介绍两种方式常用的写法。

第一种方式声明队列过期时间的方式：

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

第二种方式声明队列过期时间的方式：

AMQP .BasicProperties properties = new AMQP . BasicProperties() ; 
Properties.setDeliveryMode(2); 
properties.setExpiration("6000"); 
channel.basicPublish(exchangeName, routingKey, mandatory, properties,
"ttlTestMessage".getBytes());

上述设置过期时间的单位都是毫秒

额外补充以下一点

对于第一种设置队列属性的方法，一旦消息过期，就会从队列中抹去，而在第二种方法中，即使消息过期，也不会马上从队列中抹去，因为每条消息是否过期是在即将投递到消费者之前判定的。

为什么这两种方法处理的方式不一样?

因为第一种方法里，队列中己过期的消息肯定在队列头部， RabbitMQ 只要定期从队头开始扫描是否有过期的消息即可。而第二种方法里，每条消息的过期时间不同，如果要删除所有过期消息势必要扫描整个队列，所以不如等到此消息即将被消费时再判定是否过期，如果过期再进行删除即可。

知是行之始，行是知之成