标签：插件 系列 入门 队列 dead RabbitMQ 延时
系列目录
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");
//定义延时路由
IDictionary<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万条数据以下适合应用。
总结：
使用延时队列，应该考量业务积压的数据量，如果数据量小，那么都不是问题。
如果数据量大，那么建立队列数据库，按时间存档要发送的数据，定时扫描处理更合适。
标签：插件,系列,入门,队列,dead,RabbitMQ,延时 来源： https://www.cnblogs.com/cyq1162/p/16607941.html
本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享； 2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关； 3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关； 4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除； 5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。