RabbitMQ学习笔记（六）- 高级特性

逃离我推掉我的手 2023-01-15 12:23 119阅读 0赞

## 一、TTL（Time TO LIVE 过期时间） ##

*  TTL是Time To Live的缩写, 也就是生存时间
 *  RabbitMQ支持消息的过期时间, 在消息发送时可以进行指定
 *  RabbitMQ支持队列的过期时间, 从消息入队列开始计算, 只要超过了队列的超时时间配置, 那么消息会自动清除

注意：如果上述两种方法同时使用，则消息的过期时间以两者 TTL较小的那个数值为准。消息在队列的生存时间一旦超过设置的 TTL值，就称为 dead message被投递到死信队列，消费者将无法再收到该消息；

代码实现：  
设置队列过期配置类：

设置消息过期方式：

public class OrderService{
        
        @Autowired
        private RabbitTemplate rabbitTemplate;
        //模拟用户下单
        public void makeOrder(String userid,String productid,int num){
        
            //1.根据商品id查询库存是否足够
            //2.保存订单
            String orderId = UUID.randomUUID().toString();
            sout("订单生产成功："+orderId);
            //3.通过MQ来完成消息的分发
            //参数1：交换机 参数2：路由key/queue队列名称 参数3：消息内容
            String exchangeName = "ttl_order_exchange";
            String routingKey = "ttlmessage";
            //给消息设置过期时间
            MessagePostProcessor messagePostProcessor = new MessagePostProcessor(){
        
                public Message postProcessMessage(Message message){
        
                    //这里就是字符串
                    message.getMessageProperties().setExpiration("5000");
                    message.getMessageProperties().setContentEncoding("UTF-8");
                    return message;
                }
            }
            rabbitTemplate.convertAndSend(exchangeName,routingKey,orderId,messagePostProcessor);
        }
    }

## 二、死信队列 ##

（1）概念：DLX，全称 Dead-Letter-Exchange，可以称之为死信交换机，也有人称之为死信邮箱。当消息再一个队列中变成死信之后，它能被重新发送到另一个交换机中，这个交换机就是 DLX，绑定 DLX的队列就称之为死信队列。  
（2）进入死信队列的可能原因：

*  消息被拒绝；
 *  消息过期；
 *  队列达到最大长度；

**注意：** DLX也是一个正常的交换机，和一般的交换机没有区别，它能在任何的队列上被指定，实际上就是设置某一个队列的属性，当这个队列中存在死信时，Rabbitmq就会自动地将这个消息重新发布到设置的 DLX上去，进而被路由到另一个队列，即死信队列。

要想使用死信队列，只需要在定义队列的时候设置队列参数x-dead-letter-exchange指定交换机即可

@Configuration
    public class TTLRabbitMQConfiguration{
        
        //1.声明注册direct模式的交换机
        @Bean
        public DirectExchange ttldirectExchange(){
        
            return new DirectExchange("ttl_direct_exchange",true,false);}
        //2.队列的过期时间
        @Bean
        public Queue directttlQueue(){
        
            //设置过期时间
            Map<String,Object> args = new HashMap<>();
            //args.put("x-max-length",5);
            args.put("x-message-ttl",5000);//这里一定是int类型
            //配置死信交换机;
            args.put("x-dead-letter-exchange","dead_direct_exchange");
            //配置死信交换机的routing-key;
            args.put("x-dead-letter-routing-key","dead");//fanout不需要配置
            return new Queue("ttl.direct.queue",true,false,false,args);}
        @Bean
        public Queue directttlMessageQueue(){
        
            return new Queue("ttlMessage.direct.queue",true,false,false,args);}
        
        @Bean
        public Binding ttlBingding(){
        
            return BindingBuilder.bin(directttlMessageQueue()).to(ttldirectExchange()).with("ttlmessage");
        }
    }

@Configuration
    public class DeadRabbitMqConfiguration{
        
        //1.声明注册direct模式的交换机
        @Bean
        public DirectExchange deadDirect(){
        
            return new DirectExchange("dead_direct_exchange",true,false);}
        //2.队列的过期时间
        @Bean
        public Queue deadQueue(){
        
            return new Queue("dead.direct.queue",true);}
        @Bean
        public Binding deadbinds(){
        
            return BindingBuilder.bind(deadDirect()).to(deadQueue()).with("dead");
        }
    }

![在这里插入图片描述][20210422162606981.png]

[20210422162606981.png]: /images/20221022/90fc56ad4ecc4cdaaffdcfa976bbba59.png