RabbitMQ中TTL

太过爱你忘了你带给我的痛 2024-03-24 11:34 72阅读 0赞

#### 目录 ####

*  一、TTL
 *   *  1.控制后台演示消息过期
     *  2.代码实现
     *   *  2.1 队列统一过期
         *  2.2 消息过期

## 一、TTL ##

TTL 全称 Time To Live（存活时间/过期时间）。  
当消息到达存活时间后，还没有被消费，会被自动清除。  
RabbitMQ可以对消息设置过期时间，也可以对整个队列（Queue）设置过期时间。  
![在这里插入图片描述][bf13bc6ea2014670bfad557e2d7642fb.png]

### 1.控制后台演示消息过期 ###

① 修改管理后台界面，增加队列  
参数：表示过期时间，单位毫秒 ，10000表示10秒  
![在这里插入图片描述][6949836e590545239fe99900cae60d4c.png]  
② 增加交换机  
![在这里插入图片描述][f32e6da0d75b468d97792deffc6e5faf.png]  
③ 绑定队列  
![在这里插入图片描述][126d0373ab6e411aa043b1570a038daa.png]  
④ 发送消息  
Delivery mode：2-Persistent表示需要进行持久化  
![在这里插入图片描述][919e29373f404c2abdadf7664ed5735a.png]  
⑤ 查看消息，可以看到消息，但十秒之后，消息自动消失，因为我们设置了十秒消息过期  
![在这里插入图片描述][b97108342a294b94a64f6de994d17e5c.png]

### 2.代码实现 ###

#### 2.1 队列统一过期 ####

在队列后面添加.ttl(10000)为10s

import org.springframework.amqp.core.*;
    import org.springframework.beans.factory.annotation.Qualifier;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    
    @Configuration
    public class RabbitMQConfig {
        
        public static final String EXCHANGE_NAME = "boot_topic_exchange2";
        public static final String QUEUE_NAME = "boot_queue666";
    
        // 1 交换机
        @Bean("bootExchange")
        public Exchange bootExchange(){
        
            return ExchangeBuilder.topicExchange(EXCHANGE_NAME).durable(true).build();
        }
        //2.Queue 队列
        @Bean("bootQueue")
        public Queue bootQueue(){
        
    
            return QueueBuilder.durable(QUEUE_NAME).ttl(10000).build();
        }
        //3. 队列和交互机绑定关系 Binding
        /*
            1. 知道哪个队列
            2. 知道哪个交换机
            3. routing key
            noargs()：表示不指定参数
         */
        @Bean
        public Binding bindQueueExchange(@Qualifier("bootQueue") Queue queue,
                                         @Qualifier("bootExchange") Exchange exchange){
        
            return BindingBuilder.bind(queue).to(exchange).with("confirm").noargs();
        }
    }

启动发送

@Test
        public void testConfirm() {
        
            //3. 发送消息
            for (int i = 0; i < 10; i++) {
        
                rabbitTemplate.convertAndSend(RabbitMQConfig.EXCHANGE_NAME, "confirm", "消息");//成功
            }
        }

查看控制台,发现有10条消息,十秒之后自动过期  
![在这里插入图片描述][d6704881d88b47db81dc8696cdb1448c.png]

#### 2.2 消息过期 ####

/**
         * TTL：过期时间
         *  1. 队列统一过期
         *  2. 消息单独过期
         * 如果设置了消息的过期时间,也设置了队列的过期时间,它以时间短的为准。
         */
        @Test
        public void testMessageTtl() {
        
            // 消息后处理对象,设置一些消息的参数信息
            MessagePostProcessor messagePostProcessor = new MessagePostProcessor() {
        
    
                @Override
                public Message postProcessMessage(Message message) throws AmqpException {
        
                    //1.设置message的信息
                    // 第二个方法：消息的过期时间 ,5秒之后过期
                    message.getMessageProperties().setExpiration("5000");
                    //2.返回该消息
                    return message;
                }
            };
    
            //消息单独过期
            rabbitTemplate.convertAndSend("test_exchange_ttl","ttl.hehe","message ttl....",messagePostProcessor);
        }

运行程序,查看后台管理系统  
![在这里插入图片描述][fa57a418cfc54a14b9c0584b7418fb31.png]

[bf13bc6ea2014670bfad557e2d7642fb.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/24/cde869749f054a7c85517f494496a7bd.png
[6949836e590545239fe99900cae60d4c.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/24/4bdd406b71e64db48745fcdc32afa174.png
[f32e6da0d75b468d97792deffc6e5faf.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/24/ffbf01c5db3646f7b47c273ac423c8e7.png
[126d0373ab6e411aa043b1570a038daa.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/24/0f9d36584ecc434388c72dffb28cccdc.png
[919e29373f404c2abdadf7664ed5735a.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/24/ca648e1d28f24731873ac5fa70621734.png
[b97108342a294b94a64f6de994d17e5c.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/24/de9a15f2e35d4f4db94b273a9e46c37b.png
[d6704881d88b47db81dc8696cdb1448c.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/24/ffda141e2729443199c1225401bf1580.png
[fa57a418cfc54a14b9c0584b7418fb31.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/24/44c679de6f00450cbd0136b482793f3f.png