天天看點

RabbitMQ實戰-消費端ACK、NACK及重回隊列機制(下)2 消費端的重回隊列3 代碼實戰

2 消費端的重回隊列

重回隊列針對沒有處理成功的消息,将消息重新投遞給Broker。

重回隊列會把消費失敗的消息重新添加到隊列尾端,供Con重新消費。

一般在實際應用中,都會關閉重回隊列,即設定為false。

3 代碼實戰

  • Con,關閉自動簽收功能
  • RabbitMQ實戰-消費端ACK、NACK及重回隊列機制(下)2 消費端的重回隊列3 代碼實戰
  • 自定義Con,對第一條消息(序号0)進行NACK,并設定重回隊列
  • RabbitMQ實戰-消費端ACK、NACK及重回隊列機制(下)2 消費端的重回隊列3 代碼實戰
  • Pro 對消息設定序号,以便區分
  • RabbitMQ實戰-消費端ACK、NACK及重回隊列機制(下)2 消費端的重回隊列3 代碼實戰
  • 啟動Con,檢視管控台
  • RabbitMQ實戰-消費端ACK、NACK及重回隊列機制(下)2 消費端的重回隊列3 代碼實戰
  • RabbitMQ實戰-消費端ACK、NACK及重回隊列機制(下)2 消費端的重回隊列3 代碼實戰
  • 啟動Pro,這裡第一條消息由于我們調用了NACK,并且設定了重回隊列,是以會導緻該條消息一直重複發送,消費端就會一直循環消費
  • RabbitMQ實戰-消費端ACK、NACK及重回隊列機制(下)2 消費端的重回隊列3 代碼實戰
  • RabbitMQ實戰-消費端ACK、NACK及重回隊列機制(下)2 消費端的重回隊列3 代碼實戰