死信队列解释：

RabbitMQ的死信队列(DEAD Letter Queue,简称DLQ)，是一种用于消息处理失败或者无法路由的机制。它允许将无法正常消费的消息路由到另一个队列，以便于后续处理、排查。

出现死信队列的情况：

1、消息处理失败：消息没有正常被消费，消费代码出现异常无法正常处理一条消息时，该条消息可以标记为死信。

2、消息过期：RabbitMQ中消息可以设置过期时间,如果在规定时间内没有被消费，它可以被认为是死信并被发送到死信队列。

3、消息被拒绝：当消费者明确拒绝一条消息时，它可以被标记为死信并发送到死信队列。

4、消息无法路由：当消息不能被路由到任何队列时，例：没有绑定关系或者是路由键，消息可以被发送到死信队列。

当消息变成“死信”之后，如果配置了死信队列，那么它将会被发送到死信交换机，死信交换机将死信发送到一个队列上，这个队列就是死信队列。如果没有配置死信队列，那么这个消息将会被丢弃。

配置死信队列步骤：

1、创建死信队列：用来存储死信消息的队列

2、创建死信交换机：定义一个死信交换机

3、死信队列和死信交换机进行绑定：将死信队列和死信交换机进行绑定，以便消息发送到死信队列上

4、在主队列上配置死信属性：通过设置"x-dead-letter-exchange","x-dead-letter-routing-key"属性指定死信消息应该被发送到那个交换机和路由键

代码如下：

import org.springframework.amqp.core.*;
import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;import java.util.*;@Configuration
public class RabbitmqConfig {//配置死信队列和死信交换机@Beanpublic DirectExchange directExchange(){return new DirectExchange("dead-letter-change");}//配置死信队列@Beanpublic Queue deadLetterQueue(){return new Queue("dead-letter-queue");}//死信队列绑定死信交换机@Beanpublic Binding deadLetterBinding(){return BindingBuilder.bind(deadLetterQueue()).to(directExchange()).with("dead-letter-routing-key");}//主队列的交换机@Beanpublic DirectExchange mainExchange(){return new DirectExchange("main-exchange");}//主队列@Beanpublic Queue mainQueue(){Map<String,Object> args = new HashMap<>();//声明当前队列绑定的死信交换机args.put("x-dead-letter-exchange","dead-letter-change");//声明当前队列绑定的死信路由keyargs.put("x-dead-letter-routing-key","dead-letter-routing-key");return QueueBuilder.durable("main-queue").withArguments(args).build();}//绑定主队列到主交换机@Beanpublic Binding binding(){return BindingBuilder.bind(mainQueue()).to(mainExchange()).with("main-routing-key");}
}

消费者分别监听主队列和死信队列(代码如下)：

//消费者监听死信队列@Component
public class DeadLetterMsgReceiver {@RabbitListener(queues = "dead-letter-queue")public void receiverA(Message message, Channel channel) throws IOException {System.out.println("死信消息:"+new String(message.getBody()));channel.basicAck(message.getMessageProperties().getDeliveryTag(),false);}
}//消费者监听主队列
@Component
public class MainMsgReceiver {@RabbitListener(queues = "main-queue")public void receiverA(Message message, Channel channel) throws IOException {System.out.println("普通消息:"+new String(message.getBody()));channel.basicAck(message.getMessageProperties().getDeliveryTag(),false);}
}