RabbitMq高級特性之死信隊列 通俗易懂 超詳細 【內含案例】

RabbitMq高級特性之死信隊列 又稱 死信交換機 DLX

介紹

當消息成為 Dead message 后,會重新發送到另一個交換機,這個交換機就是 DLX(死信交換機)

消息成為死信的情況公有三種:

1. 隊列消息長度達到限制
2. 消費者拒接消費消息 basicNack/basicReject,並且不把消息重新放回原目標隊列,requeue=false;
3. 原隊列消息存在消息過期設置,消息達到過期時間

前提

完成 RabbitMq高級特性之TTL過期設置

代碼展示

一、更改RabbitMqConfig.java文件

import org.springframework.amqp.core.*;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * RabbitMq 配置類
 */
@Configuration
public class RabbitMqConfig {
    private static final String TOPIC_EXCHANGE_NAME = "topic_exchange";
    private static final String TOPIC_QUEUE_NAME = "topic_queue";
    
    public static final String DLX_EXCHANGE = "dlx_exchange";
    public static final String DLX_QUEUE = "dlx_queue";
    public static final String DLX_ROUTING_KEY = "dlx";


    /**
     * 創建 交換機
     * @return
     */
    @Bean
    public Exchange itemTopicExchange(){
        return ExchangeBuilder.topicExchange(TOPIC_EXCHANGE_NAME).build();
    }
    
    @Bean
    public Exchange DlxExchange(){
        return ExchangeBuilder.directExchange(DLX_EXCHANGE).build();
    }

    /**
     * 創建 隊列
     * @return
     */
    @Bean
    public Queue itemQueue(){
        //QueueBuilder.durable(TOPIC_QUEUE_NAME).withArgument("x-message-ttl",3000).build();
        //與下句代碼 效果一致 寫一個就可以
        //與死信交換機綁定
        return QueueBuilder.durable(TOPIC_QUEUE_NAME).ttl(3000).deadLetterExchange(DLX_EXCHANGE).deadLetterRoutingKey(DLX_ROUTING_KEY).build();
    }
    
    @Bean
    public Queue dlxQueue(){
        return QueueBuilder.durable(DLX_QUEUE).build();
    }

    /**
     * 綁定 交換機與隊列
     * @param exchange
     * @param queue
     * @return
     */
    @Bean
    public Binding itemQueueExchange(@Qualifier("itemTopicExchange") Exchange exchange, @Qualifier("itemQueue") Queue queue){
        return BindingBuilder.bind(queue).to(exchange).with("item.#").noargs();
    }
    
    @Bean
    public Binding itemQueueExchange(@Qualifier("dlxExchange") Exchange exchange, @Qualifier("dlxQueue") Queue queue){
        return BindingBuilder.bind(queue).to(exchange).with(DLX_ROUTING_KEY).noargs();
    }

}

二、測試

1. 如有topic_queue已存在,請刪除
2. 執行ProducerTest.java單元測試
3. 過期的死信隊列會跑到DLX_QUEUE隊列中

三、小結

1. 死信隊列也可以創建一個消費者來消息死信消息
2. 可以在RabbitMqConfig.java文件中的itemQueue()方法中設置隊列的最大限度,QueueBuilder.maxLendth(5); 當出入大於5個消息,多余的會丟到死信隊列中
3. channel.basicNack(deliveryTag, true, false);確認消息但是不發送回原目標隊列,會丟到死信隊列中