RabbitMQ 入门系列：10、扩展内容：延时队列：延时队列插件及其有限的适用场景（系列大结局）。

系列目录

​​RabbitMQ 入门系列：1、MQ的应用场景的选择与RabbitMQ安装。​​

​​RabbitMQ 入门系列：2、基础含义：链接、通道、队列、交换机。​​

​​RabbitMQ 入门系列：3、基础含义：持久化、排它性、自动删除、强制性、路由键。​​

​​RabbitMQ 入门系列：4、基础编码：官方SDK使用：链接创建、单例改造、发送消息、接收消息。​​

​​RabbitMQ 入门系列：5、基础编码：交换机的进阶介绍及编码方式。​​

​​RabbitMQ 入门系列：6、保障消息：不丢失：发送方、Rabbit存储端、接收方。​​

​​RabbitMQ 入门系列：7、保障消息：不重复消费：产生消息的唯一ID。​​

​​RabbitMQ 入门系列：8、扩展内容：接收信息时：可否根据RoutingKey过滤监听信息，答案是不能。​​

​​RabbitMQ 入门系列：9、扩展内容：死信队列：真不适合当延时队列。​​

​​RabbitMQ 入门系列：10、扩展内容：延时队列：延时队列插件及其有限的适用场景。​​

前言：

延迟队列用于事件发生后间隔一段时间后需要做特定处理的场景，如：

1、电商支付系统中，用户下单后N分钟不支付，自动取消订单。
2、用户浏览商品长时间后还没下单，后续推送相关产品和优惠券。
3、用户注册或修改生日后：生日短信推送等。
4、7天后的自动确认收货等。。。
......

对于这类应用，其实用消息队列，对个要求要求，是合适的，但对整个系统应用而言，它是不靠谱的。

消息队列的核心应用，是保持内存的队列，不断的产生并不断的消耗，最佳状态的保持系统的稳定和流畅。

而延迟队列的核心，是积压消息，还是大量积压，这明显与消息队列的设计就不符合。

下面来看看网上官方的延时队列插入：

1、延时队列插件：下载解压与启用

 1、下载地址：​​https://github.com/rabbitmq/rabbitmq-delayed-message-exchange/releases​​

2、解压到RabbitMQ安装目录下的plugins目录下 

3、启动：命令行运行以下命令：

rabbitmq-plugins enable rabbitmq_delayed_message_exchange

4、重启RabbitMQ：

多了个x-delayed-message则为安装成功。

2、延时队列插件：实现原理

3、延时队列插件：编码实现

其实，队列一直还是那个普通的队列，只是多了一个交换机的类型是延时类型。

因此，原理就是把消息，设置过期时间，发给延时交换机，它自己存着，到时间了，会转发到队列去。

代码如下：

using (var channel = Rabbit.Instance.DefaultConnection.CreateModel())
{

    //定义队列
    channel.QueueDeclare("dead");
　　 
　　 //定义延时路由<string, object> dic = new Dictionary<string, object>();
    dic.Add("x-delayed-type", "direct");
    channel.ExchangeDeclare("ex-dead", "x-delayed-message", arguments: dic);

    channel.QueueBind("dead", "ex-dead", "dead");

    var p1 = channel.CreateBasicProperties();
    IDictionary<string, object> header = new Dictionary<string, object>();
    header.Add("x-delay", 6000);
    p1.Headers = header;
    var p2 = channel.CreateBasicProperties();
    IDictionary<string, object> header2 = new Dictionary<string, object>();
    header2.Add("x-delay", 16000);
    p2.Headers = header2;
    channel.BasicPublish("ex-dead", "dead", false, p1, Encoding.UTF8.GetBytes("6秒就过期了1。"));
    channel.BasicPublish("ex-dead", "dead", false, p2, Encoding.UTF8.GetBytes("16秒就过期了2。"));

}

运行，等了16秒，终于等来了数据：

4、延时队列插件：适合应用场景

如果说，死信队列的适合场景，是短时间的固定间隔时间。

那么说，延时队列插件的适合场景，就是更进一步的短时间内的随机时间。

划重点的话，还是取决于积压的数据量。

官方的吐槽说明，目前的设计，由于存储数据库设计不佳，该插件推荐积压数据在100万条数据以下适合应用。

总结：

使用延时队列，应该考量业务积压的数据量，如果数据量小，那么都不是问题。

如果数据量大，那么建立队列数据库，按时间存档要发送的数据，定时扫描处理更合适。 

​​RabbitMQ 入门系列：1、MQ的应用场景的选择与RabbitMQ安装。​​

​​RabbitMQ 入门系列：2、基础含义：链接、通道、队列、交换机。​​

​​RabbitMQ 入门系列：3、基础含义：持久化、排它性、自动删除、强制性、路由键。​​

​​RabbitMQ 入门系列：4、基础编码：官方SDK使用：链接创建、单例改造、发送消息、接收消息。​​

​​RabbitMQ 入门系列：5、基础编码：交换机的进阶介绍及编码方式。​​

​​RabbitMQ 入门系列：6、保障消息：不丢失：发送方、Rabbit存储端、接收方。​​

​​RabbitMQ 入门系列：7、保障消息：不重复消费：产生消息的唯一ID。​​

​​RabbitMQ 入门系列：8、扩展内容：接收信息时：可否根据RoutingKey过滤监听信息，答案是不能。​​

​​RabbitMQ 入门系列：9、扩展内容：死信队列：真不适合当延时队列。​​

​​RabbitMQ 入门系列：10、扩展内容：延时队列：延时队列插件及其有限的适用场景。​​

​​RabbitMQ 入门系列：1、MQ的应用场景的选择与RabbitMQ安装。​​

​​RabbitMQ 入门系列：2、基础含义：链接、通道、队列、交换机。​​

​​RabbitMQ 入门系列：3、基础含义：持久化、排它性、自动删除、强制性、路由键。​​

​​RabbitMQ 入门系列：4、基础编码：官方SDK使用：链接创建、单例改造、发送消息、接收消息。​​

​​RabbitMQ 入门系列：5、基础编码：交换机的进阶介绍及编码方式。​​

​​RabbitMQ 入门系列：6、保障消息：不丢失：发送方、Rabbit存储端、接收方。​​

​​RabbitMQ 入门系列：7、保障消息：不重复消费：产生消息的唯一ID。​​

​​RabbitMQ 入门系列：8、扩展内容：接收信息时：可否根据RoutingKey过滤监听信息，答案是不能。​​

​​RabbitMQ 入门系列：9、扩展内容：死信队列：真不适合当延时队列。​​

​​RabbitMQ 入门系列：10、扩展内容：延时队列：延时队列插件及其有限的适用场景。​​