9.死信队列

文章参考：Rabbit实战指南

死信队列

DLX，全称为Dead-Letter-Exchange，可以称之为死信交换器。当消息在一个队列中变成死信之后，它能被重新被发送到另一个交换器中，这个交换器就是DLX，绑定DLX的队列就是死信队列。

消息变成死信一般由以下几种情况：

• 消息被拒绝(Basic.Reject/Bsic.Nack)，并且设置requeue参数为false；
• 消息过期；
• 队列达到最大长度。

DLX也是一个正常的交换器，和一般的交换器没有区别，它能在任何的队列上被指定，实际上就
是设置某个队列的属性。当这个队列中存在死信时，RabbitMQ就会自动地将这个消息重新发布到设置
的DLX上去，进而被路由到另一一个队列，即死信队列。可以监听这个队列中的消息以进行相应的处理，这个特性与将消息的TTL设置为0配合使用可以弥补immediate参数的功能。

通过在channel.queueDeclare方法中设置x-dead-letter-exchange参数来为这个队列添加DLX：

channel.exchangeDeclare("dlx_exchange","direct");//创建DLX:dlx_exchange
Map<String,Object> args = new HashMap<>();
args.put("x-dead-letter-exchange","dlx_exchange");
//为队列myqueue添加DLX
channel.queueDeclare("myqueue",false,false,false,args);

也可以为这个DLX指定路由键，如果没有特殊指定，则使用原队列的路由键：

args.put("x-dead-letter-routing-key","dlx-routing-key");

下面创建一个队列，为其设置TTL(过期时间)和DLX(死信交换器)等：

channel.exchangeDeclare("exchange.dlx","direct",true);
channel.exchangeDeclare("exchange.normal","fanout",true);
Map<String,Object> args1 = new HashMap<String,Object>();
args1.put("x-message-ttl",10000);
args1.put("x-dead-letter-exchange","exchange.dlx");
args1.put("x-dead-letter-routing-key","routingkey");
channel.queueDeclare("queue.normal",true,false,false,args1);
channel.queueBind("queue.normal","exchange.normal","");
channel.queueDeclare("queue.dlx",true,false,false,null);
channel.queueBind("queue.dlx","exchange.dlx","routingkey");
channel.basicPublish("exchange.normal","rk",MessageProperties.PERSISTENT_TEXT_PLAIN,"dlx".getBytes());

这里创建了两个交换器exchange.normal和exchange.dlx，分别绑定了两个队列queue.normal和queue.dlx。

生产者首先发送一条携带路由键为“rk”的消息，然后经过交换器exchange.normal顺利存储到队列queue.normal中。由于队列设置了过期时间为10s，在这10s内没有消费者消费这条信息，那么判定这条消息为过期。由于设置了DLX，过期时，消息被丢给交换器exchange.dlx，最后信息被存储在queue.dlx这个死信队列中。