rabbitmq_pro.zip

先从概念解释上搞清楚这个定义，死信，顾名思义就是无法被消费的消息，字面意思可以这样理解，一般来说，producer将消息投递到broker或者直接到queue里了，consumer从queue取出消息进行消费，但某些时候由于特定的原因导致queue中的某些消息无法被消费，这样的消息如果没有后续的处理，就变成了死信，有死信，自然就有了死信队列；

package com.congge.rabbit.deatqueue;


import com.rabbitmq.client.AMQP;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.DefaultConsumer;
import com.rabbitmq.client.Envelope;

import java.io.IOException;
import java.util.HashMap;
import java.util.Map;

public class Consumer {

    public static void main（String[] args） throws Exception{

        final Channel channel = RabbitUtil.getChannel（）;
        String exchangeName = “test_ack_exchange“;
        String exchangeType=“topic“;
        final String queueName = “test_ack_queue“;
        String routingKey = “ack.#“;

        //死信队列配置  ----------------
        String deadExchangeName = “dead_exchange“;
        String deadQueueName = “dead_queue“;
        String deadRoutingKey = “#“;
        //死信队列配置  

 属性            大小     日期    时间   名称
----------- ---------  ---------- -----  ----
     目录           0  2019-08-28 10:37  rabbitmq_pro\
     目录           0  2019-08-28 18:23  rabbitmq_pro\.idea\
     文件          10  2019-08-28 09:45  rabbitmq_pro\.idea\.name
     文件         533  2019-08-28 09:45  rabbitmq_pro\.idea\compiler.xml
     目录           0  2019-08-28 09:45  rabbitmq_pro\.idea\inspectionProfiles\
     文件        1444  2019-08-28 09:45  rabbitmq_pro\.idea\inspectionProfiles\Project_Default.xml
     文件         513  2019-08-28 09:45  rabbitmq_pro\.idea\misc.xml
     文件       26069  2019-08-28 18:23  rabbitmq_pro\.idea\workspace.xml
     文件         714  2019-08-28 09:48  rabbitmq_pro\pom.xml
     文件          80  2019-08-28 09:45  rabbitmq_pro\rabbitmq_pro.iml
     目录           0  2019-08-28 09:45  rabbitmq_pro\src\
     目录           0  2019-08-28 09:45  rabbitmq_pro\src\main\
     目录           0  2019-08-28 09:49  rabbitmq_pro\src\main\java\
     目录           0  2019-08-28 09:49  rabbitmq_pro\src\main\java\com\
     目录           0  2019-08-28 09:49  rabbitmq_pro\src\main\java\com\congge\
     目录           0  2019-08-28 12:37  rabbitmq_pro\src\main\java\com\congge\rabbit\
     目录           0  2019-08-28 11:21  rabbitmq_pro\src\main\java\com\congge\rabbit\deatqueue\
     文件        2945  2019-08-28 11:21  rabbitmq_pro\src\main\java\com\congge\rabbit\deatqueue\Consumer.java
     文件        1317  2019-08-28 11:01  rabbitmq_pro\src\main\java\com\congge\rabbit\deatqueue\Producer.java
     文件         932  2019-08-28 10:01  rabbitmq_pro\src\main\java\com\congge\rabbit\deatqueue\RabbitUtil.java
     目录           0  2019-08-28 18:18  rabbitmq_pro\src\main\java\com\congge\rabbit\maxlength\
     文件        1431  2019-08-28 18:15  rabbitmq_pro\src\main\java\com\congge\rabbit\maxlength\Consumer.java
     文件        2629  2019-08-28 18:00  rabbitmq_pro\src\main\java\com\congge\rabbit\maxlength\MaxConsumer.java
     文件        1564  2019-08-28 18:06  rabbitmq_pro\src\main\java\com\congge\rabbit\maxlength\MaxProducer.java
     文件        2103  2019-08-28 18:18  rabbitmq_pro\src\main\java\com\congge\rabbit\maxlength\Producer.java
     目录           0  2019-08-28 11:34  rabbitmq_pro\src\main\java\com\congge\rabbit\returnqueue\
     文件        2290  2019-08-28 11:27  rabbitmq_pro\src\main\java\com\congge\rabbit\returnqueue\Consumer.java
     文件        1325  2019-08-28 11:34  rabbitmq_pro\src\main\java\com\congge\rabbit\returnqueue\Producer.java
     目录           0  2019-08-28 12:33  rabbitmq_pro\src\main\java\com\congge\rabbit\ttl\
     文件        1415  2019-08-28 12:33  rabbitmq_pro\src\main\java\com\congge\rabbit\ttl\Consumer.java
     文件        1898  2019-08-28 11:41  rabbitmq_pro\src\main\java\com\congge\rabbit\ttl\Producer.java
............此处省略30个文件信息