RabbitMQ 消息过期时间（TTL）

柔情只为你懂 2022-11-16 05:43 319阅读 0赞

# 消息过期时间 #

### 文章目录 ###

*  消息过期时间
 *   *   *  1. 设置队列的过期时间
         *  2. 设置消息的过期时间

*  TTL 全称 Time To Live（存活时间/过期时间）
 *  当消息达到存活时间后，还没有被消费，会被自动清除
 *  RabbitMQ可以对消息设置过期时间，也可以对整个队列设置过期时间
    
     *  如果两者都进行了设置，以时间短的为准

### 1. 设置队列的过期时间 ###

*  在xml配置文件中声明队列时使用参数 `x-message-ttl`设置过期时间，单位是毫秒，时间到期后，会将整个队列消息全部移除
    
        
        
        
        <rabbit:queue name="test_queue_ttl" id="test_queue_ttl">
            
            <rabbit:queue-arguments>
                
                <entry key="x-message-ttl" value="10000" value-type="java.lang.Integer"/>
            </rabbit:queue-arguments>
        </rabbit:queue>
        
        
        <rabbit:topic-exchange name="test_exchange_ttl" >
            <rabbit:bindings>
                <rabbit:binding pattern="ttl.#" queue="test_queue_ttl"/>
            </rabbit:bindings>
        </rabbit:topic-exchange>
 *  进行测试
    
        for (int i = 0; i < 10; i++) { 
            // 发送消息
            rabbitTemplate.convertAndSend("test_exchange_ttl", "ttl.hehe", "消息内容");
        }
    
    运行结果：10秒之后，队列中的所有消息全被清空

### 2. 设置消息的过期时间 ###

*  设置消息过期时间使用参数 `expiration`，单位是毫秒（在消息的后处理对象中设置）
    
     *  消息过期后，只有消息在队列顶端（马上要被消费了），才会将其删除
     *  如果消息不在顶端，即使过期也不会移除

// 消息的后处理对象，设置消息的一些参数信息
    MessagePostProcessor messagePostProcessor = new MessagePostProcessor() { 
        @Override
        public Message postProcessMessage(Message message) throws AmqpException { 
            // 设置消息的过期时间
            message.getMessageProperties().setExpiration("5000");
            // 返回该消息
            return message;
        }
    };
    
    // 循环发送10条消息
    for (int i = 0; i < 10; i++) { 
        if(i == 5){ 
            // 带过期时间的消息，第四个参数声明消息的后处理对象设置过期时间
            rabbitTemplate.convertAndSend("test_exchange_ttl", "ttl.hehe", "message ttl....", messagePostProcessor);
        }else{ 
            // 不过期的消息
            rabbitTemplate.convertAndSend("test_exchange_ttl", "ttl.hehe", "message ttl....");
        }
    }

运行结果：

*  5秒后，所有的消息都保留，因为过期时间的消息不在队列顶端，即使过期也保留
 *  10秒后，队列中的所有消息被全部清空，因为设置了队列过期时间