1 什么是DLX?
利用DLX,当消息在一个队列中变成死信后,它能被重新发布到另一个Exchange中,这个Exchange就是DLX。
本质就是该消息不会再被任何消费端消费(但你可以自定义某消费者单独处理这些死信)。
2 DLX产生场景
- 消息被拒绝(
basic.reject
/basic.nack
),且requeue = false
- 消息因TTL过期
- 队列达到最大长度,先入队的消息会被删除
3 死信的处理过程
DLX亦为一个普通的Exchange,它能在任何队列上被指定,实际上就是设置某个队列的属性
- 当某队列中有死信时,RabbitMQ会自动地将该消息重新发布到设置的Exchange,进而被路由到另一个队列
- 可以监听这个队列中的消息做相应的处理。该特性可以弥补RabbitMQ 3.0以前支持的
immediate
参数的功能
4 DLX的配置
4.1 设置DLX的exchange和queue并绑定
- Exchange:
dlx.exchange
- Queue:
dlx.queue
- RoutingKey:
4.2 正常声明交换机、队列、绑定
只不过需要在队列加上一个参数:
arguments.put(" x-dead-letter-exchange","dlx.exchange");
arguments.put(" x-dead-letter-exchange","dlx.exchange");
5 代码实战
自定义Con
Pro
Con
启动Con,查看管控台