日本免费高清视频-国产福利视频导航-黄色在线播放国产-天天操天天操天天操天天操|www.shdianci.com

學無先后,達者為師

網(wǎng)站首頁 編程語言 正文

RocketMQ消息丟失問題

作者:數(shù)據(jù)驅(qū)動生活 更新時間: 2024-01-06 編程語言

同步消息要同步刷盤才完成一次消息發(fā)送,一般不會消息丟失,但會增加一定的延遲。

異步消息異步刷盤,先將消息存于緩沖區(qū),達到一定大小才進行刷盤,存在消息丟失風險。

實際開發(fā)中一般使用異步消息,為防止消息丟失通常自己對消息進行持久化:日志記錄在文件或記錄數(shù)據(jù)庫等。

生產(chǎn)者發(fā)送消息后將消息記錄在MySQL并添加狀態(tài),消費者處理完消息后更新MySQL中消息的狀態(tài),最后通過定時任務(wù)將設(shè)定時長內(nèi)未消費的消息進行補發(fā)避免消息丟失,同時防止重復消費,可參考《RocketMQ重復消費問題》。


?

原文鏈接:https://blog.csdn.net/m0_62129859/article/details/135074832

  • 上一篇:沒有了
  • 下一篇:沒有了
欄目分類
最近更新