2023-07-12：RocketMQ如何做到消息不丟失？

答案2023-07-12：

RocketMQ通過刷盤機(jī)制、消息拉取機(jī)制和ACK機(jī)制等多種方式來確保消息投遞的可靠性，防止消息丟失。

1.刷盤機(jī)制

RocketMQ中的消息分為內(nèi)存消息和磁盤消息，內(nèi)存消息在Broker內(nèi)存中進(jìn)行讀寫，磁盤消息則保存在磁盤上。RocketMQ支持同步刷盤和異步刷盤兩種方式，通過刷盤機(jī)制可以確保消息在Broker宕機(jī)時(shí)不會丟失。在同步刷盤模式下，消息寫入磁盤時(shí)，會等待磁盤的寫入完成才返回寫入成功的響應(yīng)。在異步刷盤模式下，消息寫入磁盤后立即返回寫入成功的響應(yīng)，但不等待磁盤寫入完成。

2.ACK 機(jī)制

在 RocketMQ 中，Producer 發(fā)送消息后，Broker 會返回 ACK 確認(rèn)信號，表示消息已成功發(fā)送。如果 Broker 未收到 ACK 確認(rèn)信號，則會嘗試重新發(fā)送消息，直到收到確認(rèn)。

RocketMQ 采用主從復(fù)制機(jī)制，每個(gè)消息隊(duì)列都有一個(gè)主節(jié)點(diǎn)和多個(gè)從節(jié)點(diǎn)。主節(jié)點(diǎn)負(fù)責(zé)消息的寫入和讀取，從節(jié)點(diǎn)負(fù)責(zé)備份數(shù)據(jù)。當(dāng)主節(jié)點(diǎn)宕機(jī)時(shí)，從節(jié)點(diǎn)會自動(dòng)接管主節(jié)點(diǎn)的工作，確保消息不會丟失。

3.消息存儲機(jī)制

RocketMQ默認(rèn)采用雙寫模式存儲消息，即將消息同時(shí)寫入內(nèi)存和磁盤，然后異步將內(nèi)存中的消息刷盤到磁盤中。這種方式確保了消息的可靠性，即使系統(tǒng)宕機(jī)，也盡可能地避免消息丟失。

此外，RocketMQ還提供了多種機(jī)制來保證消息不丟失，例如事務(wù)消息、延遲消息、順序消息等，可以根據(jù)業(yè)務(wù)需求選擇和使用。

值得注意的是，為了保證消息的可靠性，RocketMQ發(fā)送消息的速度可能受到一定的限制，需要在消息可靠性和性能之間做出權(quán)衡。