資源簡介
先從概念解釋上搞清楚這個定義，死信，顧名思義就是無法被消費的消息，字面意思可以這樣理解，一般來說，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.xm
?????目錄???????????0??2019-08-28?09:45??rabbitmq_pro\.idea\inspectionProfiles\
?????文件????????1444??2019-08-28?09:45??rabbitmq_pro\.idea\inspectionProfiles\Project_Default.xm
?????文件?????????513??2019-08-28?09:45??rabbitmq_pro\.idea\misc.xm
?????文件???????26069??2019-08-28?18:23??rabbitmq_pro\.idea\workspace.xm
?????文件?????????714??2019-08-28?09:48??rabbitmq_pro\pom.xm
?????文件??????????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個文件信息
評論
共有 條評論