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

異步消息異步刷盤，先將消息存于緩沖區(qū)，達(dá)到一定大小才進(jìn)行刷盤，存在消息丟失風(fēng)險(xiǎn)。

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

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

?