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

2年前 (2022) 程序员胖胖胖虎阿
224 0 0

系列目录

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、默认队列的消息过期了,或是被拒约处理,系统就是直接丢弃掉的。

2、如果你不希望过期的消息,被系统直接丢弃,还想拿来二次处理,那么:

可以通过绑定另一个队列,并标识为“x-dead-letter-exchange”,

那么,原本要丢弃的消息,就都转发到这指定的队列中,这个接收丢弃信息的队列,就叫死信队列。

2、死信队列的编码:

using (var channel = Rabbit.Instance.DefaultConnection.CreateModel())
{
    //定义普通队列来接收丢弃的信息
    channel.QueueDeclare("dead");

    IDictionary<string, object> dic2 = new Dictionary<string, object>();
    dic2.Add("x-dead-letter-exchange", "");//使用默认交换机
    dic2.Add("x-dead-letter-routing-key", "dead");//设置转移到的队列
    dic2.Add("x-message-ttl", 6000);//设置过期时间
    channel.QueueDeclare("sendtodead", arguments: dic2);

    channel.BasicPublish("", "sendtodead", false, null, Encoding.UTF8.GetBytes("6秒就过期了1。"));
    channel.BasicPublish("", "sendtodead", false, null, Encoding.UTF8.GetBytes("6秒就过期了2。"));

}

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

 运行后,消息从sendtoddead队列6秒过期后,转移到dead队列。

3、死信队列它的适用场景:

1、队列有统一的过期时间,不能使用单个信息的过期时间:

因为MQ不扫整个队列,只扫描队列第1个,判断是否过期,因此要求先进队列的必须先过期。

2、过期时间应该较短(根据可能积压的数据考量时间,一个核心的考量数据量是:10万条-100万条),避免长时间积压数据

对于长时间不消费的,不应该存入MQ,毕竟MQ的核心是内存队列,而不是磁盘队列。

4、死信队列它为什么不适合当延时队列:

了解完死信队列,会发现,其实在一个系统中,仅有比如N分钟后要处理逻辑的场景,比较适合,

其它N天后要处理的,都不靠谱。

而你用了N分钟的场景,那其它场景你用不用?

用了,不靠谱!

不用,得用其它方案,方案会不会多样化,不方便管理?

总结:

1、如果非要用死信队列当延时队列,那么要建立很多个第N分钟过期的队列。

2、如果非要用死信队列当延时队列,那么下一篇介绍的官方的延时队列插件,会比死信队列更合适。

相关文章

暂无评论

暂无评论...