每一次提交和請求的時候都會降低吞吐量（少用）
三種模式
txselect：用於將當前channel設定為（事務）transation模式
txcmmit:提交事務
txrollback:回滾事務
**用例：
生產者：
消費者：
生產者confirm模式的原理
該模式的好處是什麼？
該模式是非同步的，能提高吞吐量。
1單條確認（效率很低）
生產者：
2：批量確認
3：非同步確認
生產者類**：
新增通道的監聽：只有訊息到達之後才會調**函式。
成功了會回掉handleack（），失敗了回掉handlenack（）
boolean multiple：表示返回的確實是否為多條記錄。basicack 方法的第二個引數 multiple 取值為 false 時，表示通知 rabbitmq 當前訊息被確認；如果為 true，則額外將比第乙個引數指定的 delivery tag 小的訊息一併確認。對同一訊息的重複確認，或者對不存在的訊息的確認，會產生 io 異常，導致通道關閉。
如果是多條，則把序號大於delevertag+1的記錄全部刪除
如果是單條則指刪除序列號為delevertag的記錄
c Rabbit 訊息確認機制
不想看細節 直接看總結 1.網路出現問題，或通道問題,程式層將會引發錯誤,捕獲錯誤資訊即可發現訊息丟失 2.路由出現問題，訊息未被路由到佇列中。有兩種方法可以獲得通知 第一種 投遞訊息時mandatory 引數設定為true 如果訊息未被路由到佇列中將會引發 basic.return 事件 第二種 ...
Publisher的訊息確認機制
在前面的文章中提到了queue和consumer之間的訊息確認機制 通過設定ack。那麼publisher能不到知道他post的message有沒有到達queue，甚至更近一步，是否被某個consumer處理呢？畢竟對於一些非常重要的資料，可能publisher需要確認某個訊息已經被正確處理。在我們...
RabbitMQ實戰 訊息確認機制之訊息的正確消費
上節中我們講了如何確保訊息的準確發布，今天我們來看看如何確保訊息的正確消費。在之前的基礎上我們對消費者 倉庫服務 進行完善。所以，首先我們將ack的方式設定為手動 spring rabbitmq host xx port 5672 username x password x listener dir...