6
RabbitMQ 入门系列：9、扩展内容：死信队列：真不适合当延时队列。 - 路过秋天
source link: https://www.cnblogs.com/cyq1162/p/16643569.html
Go to the source link to view the article. You can view the picture content, updated content and better typesetting reading experience. If the link is broken, please click the button below to view the snapshot at that time.
延迟队列用于事件发生后间隔一段时间后需要做特定处理的场景，如：
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。"));
}
运行后，消息从sendtoddead队列6秒过期后，转移到dead队列。
3、死信队列它的适用场景：
1、队列有统一的过期时间，不能使用单个信息的过期时间：
因为MQ不扫整个队列，只扫描队列第1个，判断是否过期，因此要求先进队列的必须先过期。
2、过期时间应该较短（根据可能积压的数据考量时间，一个核心的考量数据量是：10万条-100万条），避免长时间积压数据
对于长时间不消费的，不应该存入MQ，毕竟MQ的核心是内存队列，而不是磁盘队列。
4、死信队列它为什么不适合当延时队列：
了解完死信队列，会发现，其实在一个系统中，仅有比如N分钟后要处理逻辑的场景，比较适合，
其它N天后要处理的，都不靠谱。
而你用了N分钟的场景，那其它场景你用不用？
用了，不靠谱！ 不用，得用其它方案，方案会不会多样化，不方便管理？
总结：
1、如果非要用死信队列当延时队列，那么要建立很多个第N分钟过期的队列。
2、如果非要用死信队列当延时队列，那么下一篇介绍的官方的延时队列插件，会比死信队列更合适。
Recommend
About Joyk
Aggregate valuable and interesting links.
Joyk means Joy of geeK