TTL队列/消息
TTL: Time To Live, 生存时间
RabbitMQ支持消息的过期时间, 在消息发送时可以指定
RabbitMQ支持队列的过期时间, 从消息进入队列开始计算, 只要超过了队列的超时时间配置..., 那么消息会被自动清除
TTL队列代码实现
消费者
package com.dance.redis.mq.rabbit.ttl;
import com.dance.redis.mq.rabbit.RabbitMQHelper...直接启动生产者发送一条消息
查看控制台
可以看到有一条消息, 等待6秒再次查看
消息已经被删除
TTL消息代码实现
消费者
package com.dance.redis.mq.rabbit.ttl.message...";
String exchangeName = "test_ttl_exchange_message";
String routingKey = "ttl.message...消息测试
启动消费者
启动生产者
查看消费者
消费成功, 此时停止消费者, 查看控制台
队列上并没有TTL标记, 所以这不是TTL队列, 这个时候不要启动消费者, 直接启动生产者, 发送一条消息