RabbitMq高級特性之死信佇列 又稱 死信交換機 DLX
介紹
當訊息成為 Dead message 后,會重新發送到另一個交換機,這個交換機就是 DLX(死信交換機)
訊息成為死信的情況公有三種:
- 佇列訊息長度達到限制
- 消費者拒接消費訊息 basicNack/basicReject,并且不把訊息重新放回原目標佇列,requeue=false;
- 原佇列訊息存在訊息過期設定,訊息達到過期時間
前提
完成 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();
}
}
二、測驗
- 如有topic_queue已存在,請洗掉
- 執行ProducerTest.java單元測驗
- 過期的死信佇列會跑到DLX_QUEUE佇列中
三、小結
- 死信佇列也可以創建一個消費者來訊息死信訊息
- 可以在RabbitMqConfig.java檔案中的itemQueue()方法中設定佇列的最大限度,QueueBuilder.maxLendth(5); 當出入大于5個訊息,多余的會丟到死信佇列中
- channel.basicNack(deliveryTag, true, false);確認訊息但是不發送回原目標佇列,會丟到死信佇列中
轉載請註明出處，本文鏈接：https://www.uj5u.com/houduan/134845.html
標籤：Java