天天看點

RabbitMQ實戰 - Confirm機制1 什麼是Confirm機制2 Confirm機制流程圖3 如何實作Confirm确認消息?4 代碼實戰

1 什麼是Confirm機制

  • 消息的确認

    Pro投遞消息後,若Broker收到消息,則會給Pro一個應答

  • Pro接收應答

    用來确定該消息是否正常地發送到Broker,這種方式也是消息可靠性投遞的核心保障

2 Confirm機制流程圖

RabbitMQ實戰 - Confirm機制1 什麼是Confirm機制2 Confirm機制流程圖3 如何實作Confirm确認消息?4 代碼實戰

Pro發送消息到Broker,Broker接收到消息後,産生回送響應

Pro中有一個Confirm Listener異步監聽響應應答

3 如何實作Confirm确認消息?

  1. 在channel上開啟确認模式:

    channel.confirmSelect()

  2. 在channel上添加監聽:

    addConfirmListener

    ,監聽成功和失敗的傳回結果,根據具體的結果對消息進行重新發送、或記錄日志等後續處理

4 代碼實戰

Con

RabbitMQ實戰 - Confirm機制1 什麼是Confirm機制2 Confirm機制流程圖3 如何實作Confirm确認消息?4 代碼實戰

Pro

RabbitMQ實戰 - Confirm機制1 什麼是Confirm機制2 Confirm機制流程圖3 如何實作Confirm确認消息?4 代碼實戰

檢驗 server 是否啟動

lsof -i:5672

RabbitMQ實戰 - Confirm機制1 什麼是Confirm機制2 Confirm機制流程圖3 如何實作Confirm确認消息?4 代碼實戰

啟動Con,檢查管控台

RabbitMQ實戰 - Confirm機制1 什麼是Confirm機制2 Confirm機制流程圖3 如何實作Confirm确認消息?4 代碼實戰

啟動Pro

RabbitMQ實戰 - Confirm機制1 什麼是Confirm機制2 Confirm機制流程圖3 如何實作Confirm确認消息?4 代碼實戰