美文网首页
rabbitMQ-TTL(生存时间)

rabbitMQ-TTL(生存时间)

作者: 这是一个假的程序员 | 来源:发表于2020-10-12 09:22 被阅读0次

官网地址:https://www.rabbitmq.com/ttl.html
TTL(Time To Live)代表的是一条消息或者该队列中的所有消息的最大存活时间,如果再这段时间内消息没有被消息,则该消息会成为死信。

1.如何设置TTL

RabbitMQ允许给消息或者队列设置TTL,如果一个设置了TTL的消息进入了一个设置了TTL的队列,则最小的TTL生效。

创建队列的时候设置TTL:
Map<String, Object> args = new HashMap<String, Object>();
args.put("x-message-ttl", 60000);
channel.queueDeclare("myqueue", false, false, false, args);

这样所有被投递到该队列的消息都最多不会存活超过6s

对每一条消息设置TTL:
byte[] messageBodyBytes = "Hello, world!".getBytes();
AMQP.BasicProperties properties = new AMQP.BasicProperties.Builder()
                                   .expiration("60000")
                                   .build();
channel.basicPublish("my-exchange", "routing-key", properties, messageBodyBytes);

这样这条消息的过期时间也被设置成了6s
在使用第二种方式设置TTL的时候需要注意,过期的消息可能排在未过期的消息后面,即消息过期不会被立马丢弃,只有当消息准备投递到消费者之前才会判定为过期,例如,消息A比消息B先进了消息队列,消息B的过期时间为5S,在消息B的存活时间内,消息A一直还未被消费,即使5S过去了消息B已经过期,但它仍然在队列中,直到消息A被消费。


2.实战!

队列设置ttl

配置类:

@Configuration
public class TTLMQConfig {

    public static final String TTL_QUEUE_NAME = "ttl.queue";
    public static final String TTL_EXCHANGE_NAME = "ttl.exchange";

    @Bean("ttlQueue")
    public Queue ttlQueue(){
        Map<String, Object> args = new HashMap<>(2);
        args.put("x-message-ttl", 30000);
        return QueueBuilder.durable(TTL_QUEUE_NAME).withArguments(args).build();
    }

    @Bean("ttlExchange")
    public FanoutExchange ttlExchange(){
        return new FanoutExchange(TTL_EXCHANGE_NAME);
    }

    @Bean
    public Binding ttlBind(@Qualifier("ttlQueue")Queue ttlQueue,
                           @Qualifier("ttlExchange")FanoutExchange ttlExchange){
        return BindingBuilder.bind(ttlQueue).to(ttlExchange);
    }
}
ttl.queue

同样也是写一个controller来生产消息

@PostMapping("ttlSend")
    public void ttlSend(@RequestParam("msg")String msg){
        rabbitTemplate.convertSendAndReceive(TTLMQConfig.TTL_EXCHANGE_NAME,"", msg);
    }

发送了一条消息,在30S之后被丢弃了


30S

再来一条


也是同样的结果
消息设置ttl

同样是往设置了30Sttl的队列中发送消息,设置消息的ttl为10S

@PostMapping("ttlMsgSend")
    public void ttlMsgSend(@RequestParam("msg")String msg){
        rabbitTemplate.convertAndSend(TTLMQConfig.TTL_EXCHANGE_NAME,"", msg, message -> {
            message.getMessageProperties().setExpiration("10000");
            return message;
        });
    }
结果

可以看到消息在10S后自动消失了,同时也验证了上面说到的最小的TTL生效。

相关文章

  • rabbitMQ-TTL(生存时间)

    官网地址:https://www.rabbitmq.com/ttl.html[https://www.rabbit...

  • 主动生存时间被动生存时间

    被动生存时间: 因为无能为力被迫成为的一种状态 能力不足时的任人安排 主动生存:能力增强后,不满足于现状,作出主动...

  • 生存时间

    大多数人在人生的大部分时间 因为自身能力不足或外部条件受限 无法做到主动选择而被动处于的时间分布 不主动逾越 便会...

  • 生存时间

    在未读潇洒姐的《五种时间》这本书之前,我对生存时间丝毫没有任何的概念。在我固有的认知当中,我认为活着就是生存,而我...

  • 生存时间

    生存时间是《五种时间》里王潇介绍的第一种时间。她给出的定义是: “生存时间就是这样的一种时间分布存在——占据了人生...

  • 生存时间

    我们每天除了吃饭和睡眠的时间,还必须有一段生存时间,就是一个人为了生存所用去的时间,当你是不是感到选择受限?是不...

  • 被动生存时间与主动生存时间

    1、一日三餐时间 早餐:30分钟 午餐:1小时 晚餐:1小时 如果仅仅是为了吃饭,那这段时间就是...

  • 主动生存时间和被动生存时间

    Day9|时间管理分享 昨天分享了王潇《五种时间》这本书里的生存时间,说的是为了生存而占据的时间,我们一生中很多时...

  • Redis学习篇(九)之生存时间

    EXPIRE 设置生存时间,以秒为单位 EXPIREAT 设置生存时间,秒时间戳格式 PEXPIRE 设置生存时间...

  • 生存时间解析

    “五种时间”体系对生存时间的定义是:大多数人在人生的大部分时间里,因为自身能力不足和外部条件的限制,无法做到主动选...

网友评论

      本文标题:rabbitMQ-TTL(生存时间)

      本文链接:https://www.haomeiwen.com/subject/vysjpktx.html