RocketMq的事務(wù)消息是什么

本篇內(nèi)容介紹了“RocketMq的事務(wù)消息是什么”的有關(guān)知識，在實際案例的操作過程中，不少人都會遇到這樣的困境，接下來就讓小編帶領(lǐng)大家學(xué)習(xí)一下如何處理這些情況吧！希望大家仔細閱讀，能夠?qū)W有所成！

事務(wù)消息概念介紹

   Half(Prepare)Message

消息不能傳遞，當(dāng)消息成功發(fā)送到Broker之后，Broker沒有收到Producer的二次確認事件，消息被broker標(biāo)記為暫時不能派發(fā)，這種狀態(tài)下的消息就是Half(Prepare)Message。

   消息狀態(tài)校驗

網(wǎng)絡(luò)閃斷和Productor應(yīng)用服務(wù)重啟，都會導(dǎo)致事務(wù)消息二次確認事件的丟失，當(dāng)broker發(fā)現(xiàn)消息一直處于Half(Prepare)Message狀態(tài)，就會向Productor應(yīng)用發(fā)送請求，確認消息的最終狀態(tài)（派送還是回滾）。

   事務(wù)消息執(zhí)行流程：

1.Producer向Broker發(fā)送Half(Prepare)Message

2.發(fā)送Half(Prepare)Message success，執(zhí)行本地事務(wù)

3.根據(jù)本地事務(wù)執(zhí)行結(jié)果，想Broker發(fā)送提交或者回滾消息

4.如果提交或者回滾消息丟失或者Producer執(zhí)行本地事務(wù)期間掛起，Broker會給同一組類的所有producer發(fā)送check消息，確認事務(wù)最終狀態(tài)

5.Producer會根據(jù)本地事務(wù)狀態(tài)回復(fù)提交/回滾消息

6.已提交的消息將傳遞給訂閱的Consumer，但Broker服務(wù)器將丟棄已回滾的消息

詳細設(shè)計

    Rocketmq為了抽象存儲的底層實現(xiàn)，所有事務(wù)性消息操作都集中在事務(wù)服務(wù)接口上。 RocketMQ提供了一個帶有自己的存儲系統(tǒng)的默認實現(xiàn)，我們使用事務(wù)橋來實現(xiàn)我們的事務(wù)存儲邏輯，而不是直接修改RocketMQ的存儲層。

      發(fā)送事務(wù)消息

     發(fā)送事務(wù)消息時序圖，以及事務(wù)消息是如何兩階段提交的。

     事務(wù)消息校驗

    事務(wù)消息檢驗邏輯時序圖，如果事務(wù)消息一直處于Half(Prepare)Message status，Broker就會向producer發(fā)送確認消息，驗證事務(wù)消息的最終狀態(tài)。

“RocketMq的事務(wù)消息是什么”的內(nèi)容就介紹到這里了，感謝大家的閱讀。如果想了解更多行業(yè)相關(guān)的知識可以關(guān)注億速云網(wǎng)站，小編將為大家輸出更多高質(zhì)量的實用文章！