利用DLX,当消息在一个队列中变成死信后,它能被重新发布到另一个Exchange中,这个Exchange就是DLX。 本质就是该消息不会再被任何消费端消费(但你可以自定义某消费者单独处理这些死信)。
basic.reject
/basic.nack
),且requeue = false
DLX亦为一个普通的Exchange,它能在任何队列上被指定,实际上就是设置某个队列的属性
immediate
参数的功能dlx.exchange
dlx.queue
#
只不过需要在队列加上一个参数:
arguments.put(" x-dead-letter-exchange","dlx.exchange");
这样消息在发生DLX产生条件时,消息即可直接路由到DLX。
实际环境我们还需要对死信队列进行一个监听和处理,当然具体的处理逻辑和业务相关,这里只是简单演示死信队列是否生效。