一、消息如何保證可靠性傳輸 1.1、可能出現消息丟失的情況 　　1、Producer在把Message發送Broker的過程中，因為網絡問題等發生丟失，或者Message到了Broker，但是出了問題，沒有保存下來 　　針對這個問題，Producer可以開啟MQ的事務，如果這個過程出現異常 ...

那些情況會失敗 網絡問題有很多原因出發失敗。防火牆也可能會中斷Idle連接，網絡失敗不是很快確定的。 硬件和軟件也會導致系統崩潰。客戶端軟件保持運行，而邏輯錯誤也可能會導致channel和conne ...

一、可靠性問題分析 消息的可靠性投遞是使用消息中間件不可避免的問題，不管是使用哪種MQ都存在這種問題，接下來要說的就是在RabbitMQ中如何解決可靠性問題；在前面 在前面說過消息的傳遞過程中有三個對象參與分別是：生產者、RabbitMQ(broker)、消費者；接下 ...

1、什么是RabbitMQ？為什么要使用RabbitMQ？ RabbitMQ是一款開源的、Erlang語言編寫的、基於AMQP協議的消息中間件。 解耦：實現消費者和生產者之間的解耦 異步：將消息寫入消息隊列，非必要的業務邏輯以異步的方式 ...

消息丟失分成三種情況，可能出現生產者、RabbitMQ、消費者。 生產者丟失數據 首先要確保寫入 RabbitMQ 的消息別丟，消息隊列通過請求確認機制，保證消息的可靠傳輸。生產開啟 comfirm 模式，在生產者開啟 comfirm 模式之后，每次發送消息都會分配一個唯一的id ...

1.消費端弄丟了數據 唯一可能導致消費者弄丟數據的情況，就是說，你消費到了這個消息，然后消費者那邊自動提交了 offset，讓 Kafka 以為你已經消費好了這個消息，但其實你才剛准備處理這個消息，你還沒處理，你自己就掛了，此時這條消息就丟咯。 這不是跟 RabbitMQ 差不多嗎，大家都知道 ...

人生終將是場單人旅途，孤獨之前是迷茫，孤獨過后是成長。 楔子 本篇是消息隊列RabbitMQ的第四彈。 RabbitMQ我已經寫了三篇了，基礎的收發消息和基礎的概念我都已經寫了，學任何東西都是這樣，先基礎的上手能用，然后遇到問題再去解決，無法理解就去深入源碼，隨着時間的積累對這一 ...

RabbitMQ和Kafka都提供持久的消息保證。兩者都提供至少一次和至多一次的保證，另外，Kafka在某些限定情況下可以提供精確的一次（exactly-once）保證。 讓我們首先理解一下上述術語的含義： 至多一次投遞：消息絕對不會被重復投遞，但是消息可能丟失 至少一次投遞：消息絕對不會被 ...