参考demo：G:\学习资料\java\java学习文档\java技术文档\消息队列文档\rabbimitmq\cd-xufei-rabbiitmq-parent\cd-xufei-rabbitmq-01 => dl

死信队列的逻辑：

什么是死信?

产生死信的三种情况：

• 队列满了 ----> 如果再出现消息往队列中放 那么就会出现消息死信
• RabbitMQ 拒绝了这个消息(消息没有地方去) -----> 也出现了死信
• TTL中时间满了 那么这个消息 没地方去 也将成为死信

其实就是普通队列，需要将其他普通队列添加死信队列的属性，这样其他队列产生死信的时候，就会将这些消息放到关联的死信队列中，这样我们的消费者就能从死信队列中消费消息了

生产者示例：

public class Producer {

    /**
     * 申明了一个交换机的名字
     */
    private static final String EXCHANGE_NAME = "exchange_dl";

    public static void main(String[] args) throws Exception {
        Connection connection = ConnectionUtils.getConnection();
        Channel channel = connection.createChannel();
        // 需要申明咋们的交换机
        /**
         * 第一个参数：交换机的名字
         * 第二个参数：交换机的类型  这里要注意  发布订阅模型的话 这里的类型是不能乱写的 只能是 fanout
         */
        channel.exchangeDeclare(EXCHANGE_NAME, "fanout");
        // 接下来发送数据到交换机
        channel.basicPublish(EXCHANGE_NAME, "", null, ("模拟死信队列").getBytes());
    }
}

消费者示例：

public class Consumer1 {

    /**
     * 申明了一个交换机的名字
     */
    private static final String EXCHANGE_NAME = "exchange_dl";
    /**
     * 与交换机绑定的这个队列
     */
    private static final String QUEUE_NAME = "exchange_dl_queue";

    // 下面设置死信的交换机 和死信的队列
    /**
     * 死信的交换机
     */
    private static final String DLX_EXCHANGE_NAME = "exchange_dlx_0001";
    /**
     * 死信的队列
     */
    private static final String DLX_QUEUE_NAME = "exchange_dlx_0001_queue";


    public static void main(String[] args) throws Exception {
        // 获取连接
        Connection connection = ConnectionUtils.getConnection();
        Channel channel = connection.createChannel();

        Map<String, Object> maps = new HashMap<>();
        maps.put("x-message-ttl", 5000);// 要将正常的队列设置成TTL队列
        // 给普通队列 添加一个死信队列的属性 后面的名字是死信队列交换机的名称
        maps.put("x-dead-letter-exchange", DLX_EXCHANGE_NAME);

        // 申明队列
        channel.queueDeclare(QUEUE_NAME, false, false, false, maps);
        // 申明交换机
        channel.exchangeDeclare(EXCHANGE_NAME, "fanout");
        // 下面将队列绑定到交换机
        /**
         * 第一个参数：队列的名字
         * 第二个参数：交换机的名字
         * 第三个参数：路由的这个key
         */
        channel.queueBind(QUEUE_NAME, EXCHANGE_NAME, "xff");


        // 申明死信的交换机
        // 申明队列
        channel.queueDeclare(DLX_QUEUE_NAME, false, false, false, maps);
        // 申明交换机
        channel.exchangeDeclare(DLX_EXCHANGE_NAME, "fanout");
        // 将死信的队列和死信的交换机绑定到一起
        channel.queueBind(DLX_QUEUE_NAME, DLX_EXCHANGE_NAME, "xff");


        // 申明一个消费者
        DefaultConsumer defaultConsumer = new DefaultConsumer(channel) {
            @Override
            public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {
                System.out.println("接受了来自死信队列的数据:" + new String(body));
            }
        };

        // 将消费者 绑定到 死信队列
        channel.basicConsume(DLX_QUEUE_NAME, true, defaultConsumer);
    }
}