• 一、場景
   

1. 當訊息的投送方把訊息投遞出去，卻不知道訊息是否投遞成功了。如果訊息投送方不管的話，勢必對系統的造成可靠性的影響。
2. 可是如果要保證系統的可靠性，訊息投靠方，如何知道訊息是否投放成功了呢？
3. 這個就需要訊息的確認機制，我們來看下rabbitMQ的訊息去人機制是如何做的。
    

• 二、原理：上圖
   

• 三、原理解析
   

1. 訊息的確認分兩部分：rabbitMQ確認生產者投遞的訊息 和 消費者確認 rabbitMQ伺服器的訊息
    
2. 首先說RabbitMQ對生產者的確認，總共分為兩種模式分別為 同步模式 與 非同步模式。
   
   (1)  同步模式分為 單條訊息確認 與 批量確認。
   
   　　①  單條訊息確認： channel.waitForConfirms() 普通傳送方確認模式；訊息到達交換器，就會返回true。
   
   　　②  批量訊息確認： channel.waitForConfirmsOrDie()批量確認模式；使用同步方式等所有的訊息傳送之後才會執行後面程式碼，只要有一個訊息未到達交換器就會丟擲IOException異常。
    

　　　 (2) 非同步模式為生產者 非同步監聽訊息確認。
 

　　　　　　非同步監聽訊息確認：channel.addConfirmListener()非同步監聽傳送方確認模式；如何使用，參見程式碼no-spring模組包cn.enjoyedu. producerconfirm中。
 

　　  3. 其次說下消費者對RabbitMQ 訊息確認。總共分為兩種方式 分別為 手動確認 和 自動確認。
 

　　　　　　消費者收到的每一條訊息都必須進行確認。訊息確認後，RabbitMQ才會從佇列刪除這條訊息，RabbitMQ不會為未確認的訊息設定超時時間，它判斷此訊息是否需要重新投遞給消費者的唯一依據是消費該消的消費者連線是否已經斷開。

　　　　這麼設計的原因是RabbitMQ允許消費者消費一條訊息的時間可以很久很久。
 

　　　　(1)　自動確認：

　　消費者在宣告佇列時，可以指定autoAck引數，當autoAck=true時，一旦消費者接收到了訊息，就視為自動確認了訊息。如果消費者在處理訊息的過程中，出了錯，就沒有什麼辦法重新處理這條訊息，所以我們很多時候，

需要在訊息處理成功後，再確認訊息，這就需要手動確認。

  (2)  手動確認：　　　　

　　　　　　　　 ①當autoAck=false時，RabbitMQ會等待消費者顯式發回ack訊號後才從記憶體(和磁碟，如果是持久化訊息的話)中移去訊息。否則，RabbitMQ會在佇列中訊息被消費後立即刪除它。
 

　　　　　　　　 ②採用訊息確認機制後，只要令autoAck=false，消費者就有足夠的時間處理訊息(任務)，不用擔心處理訊息過程中消費者程序掛掉後訊息丟失的問題，因為RabbitMQ會一直持有訊息直到消費者顯式呼叫basicAck為止。
 

　　③當autoAck=false時，對於RabbitMQ伺服器端而言，佇列中的訊息分成了兩部分：一部分是等待投遞給消費者的訊息；一部分是已經投遞給消費者，但是還沒有收到消費者ack訊號的訊息。如果伺服器端一直沒有收到消費

者的ack訊號，並且消費此訊息的消費者已經斷開連線，則伺服器端會安排該訊息重新進入佇列，等待投遞給下一個消費者（也可能還是原來的那個消費者）。
 

   ④通過執行程式，啟動兩個消費者A、B，都可以收到訊息，但是其中有一個消費者A不會對訊息進行確認，當把這個消費者A關閉後，消費者B又會收到本來發送給消費者A的訊息。所以我們一般使用手動確認的方法是，將訊息的處理放在try/catch語句塊中，成功處理了，就給RabbitMQ一個確認應答，如果處理異常了，就在catch中，進行訊息的拒絕

• 如果有什麼不足歡迎討論！

鄭州男科醫院哪裡好

鄭州婦科醫院

鄭州做人流價格是多少錢

鄭州婦科醫院哪家好