【java常见的面试题】RabbitMQ如何设置消息过期 ?

RabbitMQ置消息过期的方式有二种 :

1. 为队列设置过期时间, 所有进到这个队列的消息就会具有统一的过期时间

   @Bean
   public Queue ttlQueue(){
        
       return QueueBuilder.durable("ttl.queue") // 指定队列名称，并持久化
           .ttl(10000) // 设置队列的超时时间，10秒
           .deadLetterExchange("dl.ttl.direct") // 指定死信交换机
           .build();
   }
   

2. 为消息单独设置过期时间

   @Test
   public void testTTLQueue() {
        
       // 创建消息
       String message = "hello, ttl queue";
       // 消息ID，需要封装到CorrelationData中
       CorrelationData correlationData = new CorrelationData(UUID.randomUUID().toString());
       // 发送消息
       rabbitTemplate.convertAndSend("ttl.direct", "ttl", message, correlationData);
       // 记录日志
       log.debug("发送消息成功");
   }
   

注意 :

1. 队列过期和消息过期同时存在 , 会以时间短的时间为准
2. RabbitMQ队列消息过期的机制是判断队列头部元素是否过期 , 如果队里头部消息没有到过期时间 , 中间消息到了过期时间, 这个消息也不会被自动剔除