当前位置：首页 > article >正文

RabbitMQ的高级特性-TTL

article 2024/9/28 16:56:48

TTL(Time to Live, 过期时间), 即过期时间. RabbitMQ可以对消息和队列设置TTL.当消息到达存活时间之后, 还没有被消费, 就会被⾃动清除

设置消息的TTL：

①设置队列的TTL，队列中所有的消息都有相同的过期时间 ②TTL(Time to Live, 过期时间), 即过期时间. RabbitMQ可以对消息和队列设置TTL.当消息到达存活时间之后, 还没有被消费, 就会被⾃动清除

注：如果不设置TTL，则表⽰此消息不会过期;如果将TTL设置为0，则表⽰除⾮此时可以直接将消息投递到消费者，否则该消息会被⽴即丢弃.

设置队列的过期时间：

@Bean("ttlQueue2")
public Queue ttlQueue2() {
    Map<String, Object> arguments = new HashMap<>();
    arguments.put("x-message-ttl",20000);//20秒过期
return
QueueBuilder.durable(Constant.TTL_QUEUE2).withArguments(arguments).build();
}

@Bean("ttlQueue2")
public Queue ttlQueue2() {
//设置20秒过期
return QueueBuilder.durable(Constant.TTL_QUEUE2).ttl(20*1000).build();
}

设置消息的过期时间：

@RequestMapping("ttl")
    public String ttl(){
        MessagePostProcessor messagePostProcessor=new MessagePostProcessor() {
            @Override
            public Message postProcessMessage(Message message) throws AmqpException {
                    message.getMessageProperties().setExpiration("10000");
                    return message;
            }
        };
        MessagePostProcessor messagePostProcessor1=new MessagePostProcessor() {
            @Override
            public Message postProcessMessage(Message message) throws AmqpException {
                message.getMessageProperties().setExpiration("20000");
                return message;
            }
        };
        rabbitTemplate.convertAndSend(Constant.TTL_EXCHANGE,"ttl","hello ttl test1...",messagePostProcessor1);
        rabbitTemplate.convertAndSend(Constant.TTL_EXCHANGE,"ttl","hello ttl test2...",messagePostProcessor);
        return "消息发送成功";
    }

两者区别
①设置队列TTL属性的⽅法, ⼀旦消息过期, 就会从队列中删除
②设置消息TTL的⽅法, 即使消息过期, 也不会⻢上从队列中删除, ⽽是在即将投递到消费者之前进⾏判定的.
为什么这两种⽅法处理的⽅式不⼀样?
①因为设置队列过期时间, 队列中已过期的消息肯定在队列头部, RabbitMQ只要定期从队头开始扫描是否有过期的消息即可.
②⽽设置消息TTL的⽅式, 每条消息的过期时间不同, 如果要删除所有过期消息需要扫描整个队列, 所以不如等到此消息即将被消费时再判定是否过期, 如果过期再进⾏删除即可.

查看全文

http://www.kler.cn/news/323427.html