TTL队列/消息
TTL: Time To Live, 生存时间
RabbitMQ支持消息的过期时间, 在消息发送时可以指定
RabbitMQ支持队列的过期时间, 从消息进入队列开始计算, 只要超过了队列的超时时间配置..., 那么消息会被自动清除
TTL队列代码实现
消费者
package com.dance.redis.mq.rabbit.ttl;
import com.dance.redis.mq.rabbit.RabbitMQHelper...RabbitMQHelper.EXCHANGE_TYPE_TOPIC);
Map arguments = new HashMap();
// 指定队列的消息过期时间...启动消费者
启动生产者
查看消费者
消费成功
此时, 停止消费者, 查看控制台
从队列上的标记features, 也可以看到这是一个TTL队列
队列中是没有消息的,不要启动消费者, 直接启动生产者发送一条消息...启动消费者
启动生产者
查看消费者
消费成功, 此时停止消费者, 查看控制台
队列上并没有TTL标记, 所以这不是TTL队列, 这个时候不要启动消费者, 直接启动生产者, 发送一条消息
可以看到有了一条消息