RabbitMQ延时队列应用

素颜马尾好姑娘i 2023-01-16 09:47 215阅读 0赞

### 文章目录 ###

*  一、延时队列使用场景
 *  二、RabbitMQ 延时队列相关概念
 *   *  2.1 TTL
     *  2.2 Dead Letter Exchanges(DLX)
 *  三、RabbitMQ 延时队列实现方式
 *  四、RabbitMQ 延时队列实战

# 一、延时队列使用场景 #

场景：比如未付款订单，超过一定时间后，系统自动取消订单并释放占有物品。  
常用解决方案：`spring`的`schedule`定时任务轮询数据库  
缺点：消耗系统内存、增加了数据库的压力、存在较大的时间误差  
解决：`RabbitMQ`的消息`TTL`和死信`Exchange`结合

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

# 二、RabbitMQ 延时队列相关概念 #

## 2.1 TTL ##

消息的`TTL`（`Time To Live`）：消息的存活时间，`RabbitMQ`可以对队列和消息分别设置`TTL`。

*  对队列设置就是队列没有消费者连着的保留时间。也可以对每一个单独的消息做单独的设置，超过了这个时间，我们认为这个消息就死了，称之为死信。
 *  如果队列设置了，消息也设置了，那么会取小的。所以一个消息如果被路由到不同的队列中，这个消息死亡的时间有可能不一样(不同的队列设置)。这里单讲单个消息的`TTL`，因为它才是实现延迟任务的关键。可以通过设置消息的`expiration`字段或者`x-message-ttl`属性来设置时间，两者是—样的效果。

## 2.2 Dead Letter Exchanges(DLX) ##

一个消息在满足如下条件下，会进**死信路由**，记住这里是路由而不是队列，一个路由可以对应很多队列。

死信的多种场景：

*  一个消息被`Consumer`拒收了，并且`reject`方法的参数里`requeuet`是`false`。也就是说不会被再次放在队列里，被其他消费者使用。(`basic.reject`/ `basic.nack`) `requeue=false`
 *  上面的消息的`TTL`到了，消息过期了。
 *  队列的长度限制满了，排在前面的消息会被丢弃或者扔到死信路由上

`Dead Letter Exchange`其实就是一种普通的`exchange`，和创建其他  
`exchange`没有两样。只是在某一个设置`Dead Letter Exchange`的队列中有消息过期了，会自动触发消息的转发，发送到`Dead Letter Exchange`中去。

我们既可以控制消息在一段时间后变成死信，又可以控制变成死信的消息被路由到某一个指定的交换机，结合二者，其实就可以实现一个延时队列。

# 三、RabbitMQ 延时队列实现方式 #

**① 设置队列过期时间实现延时队列**  
![在这里插入图片描述][2021042910315214.png]

**② 设置消息过期时间实现延时队列**

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

> RabbitMQ采用的是惰性检查机制，如果是发送的带过期时间的消息，RabbitMQ会从队列顶端读取消息的过期时间，然后到了过期时间后才会进行检查，这样会存在时间误差，通常我们会采用带过期时间的队列。

# 四、RabbitMQ 延时队列实战 #

**① 延时队列设计：**  
![在这里插入图片描述][20210429105741476.png]  
**② 根据设计创建对应的`exchange`、`queue`、`binding`**

@Configuration
    public class RabbitMQConfig { 
    	
        /** * 创建topic类型的交换机 */
        @Bean
        public TopicExchange createOrderEventExchange() { 
            TopicExchange topicExchange = new TopicExchange("order_event_exchange", true, false);
            return topicExchange;
        }
    
        /** * 死信队列 */
        @Bean
        public Queue createOrderDelayQueue() { 
            Map<String, Object> arguments = new HashMap<>();
            arguments.put("x-dead-letter-exchange","order_event_exchange");//指定死信交换机
            arguments.put("x-dead-letter-routing-key", "order-release-order");//指定死信路由键
            arguments.put("x-message-ttl",30000);//指定队列超时时间
            Queue queue = new Queue("order_delay_queue", true, false, false, arguments);
            return queue;
        }
    
        @Bean
        public Queue createOrderReleaseQueue() { 
            Queue queue = new Queue("order_release_queue", true, false, false);
            return queue;
        }
    
        @Bean
        public Binding createOrderBinding() { 
            Binding binding = new Binding("order_delay_queue", Binding.DestinationType.QUEUE,
                    "order_event_exchange", "order-create-order", null);
            return binding;
        }
    
        @Bean
        public Binding releaseOrderBinding() { 
            Binding binding = new Binding("order_release_queue", Binding.DestinationType.QUEUE,
                    "order_event_exchange", "order-release-order", null);
            return binding;
        }
    }

**③ 发送一条订单消息**

/** * 发送订单消息 */
    @Test
    public void sendOrderMessage() { 
        Order order = new Order(UUID.randomUUID().toString(), "iphone12");
        rabbitTemplate.convertAndSend("order_event_exchange", 
                "order-create-order", order);
    }

![在这里插入图片描述][20210507102254508.png]  
**④ 监听订单释放队列，经过30s后我们发现过期订单已被处理。**

@RabbitListener(queues = { "order_release_queue"})
    public void receiveDelayMessage(Message msg , Order order, Channel channel) { 
        System.out.println("过期订单已被处理---");
        System.out.println("Message："+msg);
        System.out.println("content：" + order);
        System.out.println("Channel：" + channel);
    }

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

[20210425205057933.png]: /images/20221022/5a15f51679194a5f9be64ffc59205a50.png
[2021042910315214.png]: /images/20221022/322f37a136524cc4811ac14d3be214a0.png
[20210429103216522.png]: /images/20221022/10541f4ccc8846c98788b25d6c13d285.png
[20210429105741476.png]: /images/20221022/c971c75ba2674508b3db7920deb96367.png
[20210507102254508.png]: /images/20221022/45f480392a2e4d258ea88d79bb94424b.png
[20210507102325973.png]: /images/20221022/119f1e556b534b748312ccc06ba5afbc.png
[20210507103054890.png]: /images/20221022/14487fe7eb3a41e5b9c8d76b46507a39.png