RabbitMQ消息中间件技术精讲17 高级篇十 死信队列
- RabbitMQ学习系列教程
- 时间：2019-08-04 08:59
- 6690人已阅读
🔔🔔🔔好消息!好消息!🔔🔔🔔
有需要的朋友👉:联系凯哥
死信队列介绍
本文是《RabbitMQ精讲系列》中第十七：RabbitMQ消息中间件技术精讲17 高级篇十 死信队列
死信队列：DLX(dead-letter-exchange)
当一个消息没有了消费者之后，这个队列就成了死信队列。
在RabbitMQ中，死信队列是相对于exchange的。RabbitMQ的死信队列：
利用DLX，当消息在一个队列中变为死信(dead message)之后，它能被重新publish到另一个exchange，这个exchange就是DLX死信队列了。
在RabbitMQ中，消息如何变成死信的？有以下几种情况：
1：消息被拒绝
消息被拒绝又分为：basic.reject和basic.nack两种
当是这两种情况下且设置了requeeu=false。也就是设置重回队列为false的情况
2：消息TTL过期
在上一篇文章中，我们讲的TTL消息的时效性。当消息超过了设置的超时时间情况
3：队列达到最大长度
同样，在上一篇中，我们讲到了在发送消息的时候，设置消息的最大上的。当发送消息的数据长度超过了设置的值之后，这种情况也成了死信队列。
在来看看rabbitmq死信队列：
DLX也是一个正常的exchange,和一般的exchange没有区别，它能在任何的队列上被指定，实际上也就是设置某个队列的属性而已；
当这个队列中有死信时候，rabbitmq就会自动的将这个消息重新发布到设置的exchange上去，进而被路由到另一个队列。
可以监听这个队列中消息做相应的处理，这个特性可以弥补rabbitmq3.0以前支持immediate参数的功能。
死信队列设置：
1 ：设置死信队列的exchange和queue,然后进行绑定(这是废话，任何一个队列都是这样的)：
Exchange：dlx.exchange
Queue：dlx.queue
Routingkey：#
2 ：然后我们进行正常的声明交换机、队列、绑定，只不过我们需要在队列加上一个参数即可。这个参数就是：arguments.put(“x-dead-letter-exchange”,”dlx.exchange”).
说明：arguments.put(“x-dad-letter-exchange”,”这里是自己定义的接收死信队列的exchange”)
这样消息在过期、requeue、队列在达到最大长度时，消息就可以直接路由到死信队列了！
代码这里就不截图了，已发布在git上。
本章节总结：