一、RabbitMQ 1）生產者弄丟了數據 　　生產者將數據發送到rabbitmq的時候，可能因為網絡問題導致數據就在半路給搞丟了。 1.可以選擇用rabbitmq提供的事務功能，在生產者發送數據之前開啟rabbitmq事務（channel.txSelect），然后發送 ...

消息隊列 - 關於消息隊列的消息丟失問題的一點思考 　　 　　使用消息中間件必須面對的兩大問題 - 消息丟失 和 消息重復。 　　 消息丟失的解決辦法主要是通過消息重發的補償手段，消息重發后導致消息重復，消息重復需要使用冪等解決。 　　　 　　消息從生產到消費，一般需要 ...

消息堆積 　為什么會產生消息堆積？ 　　　　大多數是因為Consumer 出問題了，沒有及時發現，或者故障恢復需要較長時間，導致大量消息積壓在消息隊列中。 消息隊列堆積會造成什么后果？ 消息被丟棄 磁盤滿了 海量消息需要處理 　解決方案： 增加消費者 ...

大家好，我是 yes。 最近我一直扎在消息隊列實現細節之中無法自拔，已經寫了 3 篇Kafka源碼分析，還剩很多沒肝完。之前還存着RocketMQ源碼分析還沒整理。今兒暫時先跳出來盤一盤大方向上的消息隊列有哪些核心注意點。 核心點有很多，為了更貼合實際場景，我從常見的面試問題入手 ...

RabbitMQ 生產者弄丟了數據 　　生產者將數據發送到RabbitMQ的時候，可能數據就在半路給搞丟了，因為網絡啥的問題，都有可能。 　　此時可以選擇用RabbitMQ提供的事務功能，就是生產者發送數據之前開啟RabbitMQ事務（channel.txSelect ...

消息隊列防止消息不丟失 1、 生產者發送消息到broker失敗；生產者使用事務消息。 2、 Broker集群主從同步失敗；兩階段提交，多數節點成功后提交。 3、 MQ異步刷盤，可能會消息丟失；改為同步刷盤。 4、 Broker發送消息到消費者失敗；消費者ack機制。 5、 MQ集群 ...

使用消息隊列，繞不開的一個問題就是如何保證消息不丟失，現在主流的消息中間件都提供了完整的消息可靠性保證機制，可以確保消息的可靠傳遞，本文以rocketMq為例介紹如何保證消息不丟失，其他消息隊列類似。原文地址 消息傳遞過程 基本上所有的消息都划分為三個階段生產、存儲、消費，如下圖 ...

一、消息重復現象 　　在 MQTT 協議中，給出了三種傳遞消息時能夠提供的服務質量標准： At most once:最多一次，這種情況會丟失部分數據，一般日志收集這種對數據不嚴格的可以使用 At least once:最少一次，這種會導致一條消息重復 ...