RocketMQ工作流程

在RocketMQ當中，當消息的生產(chǎn)者將消息生產(chǎn)完成之后，并不會直接將生產(chǎn)好的消息直接投遞給消費者，而是先將消息投遞個中間的服務(wù)，通過這個服務(wù)來協(xié)調(diào)RocketMQ中生產(chǎn)者與消費者之間的消費速度。

那么生產(chǎn)者是如何投遞自己的消息呢？這里向大家介紹一下RocketMQ當中的一個重要組件，topic。Topic，故名思意，主題嘛，消息生產(chǎn)者在生產(chǎn)投遞消息的過程中，可以通過設(shè)定不同的topic將自身所生產(chǎn)的消息，投遞到對應(yīng)的topic當中。舉一個通俗易懂的例子，我們可以把topic想象成是一個貨物倉庫，而topic是一個貨架，對應(yīng)的種類的物品要放到對應(yīng)的貨架上。

消費者則根據(jù)自身的需求，通過不同的topic來獲取自己想要消費的消息。

RocketMQ事務(wù)消息的實現(xiàn)

RocketMQ事務(wù)消息的實現(xiàn)，其實也是非常的簡單，我們只需要弄清一個原理即可，即分階段實現(xiàn)。在RocketMQ當中，想要實現(xiàn)分階段實現(xiàn)這一功能，首先要實現(xiàn)一個機制，就是TransactionListener--事務(wù)監(jiān)聽機制。事務(wù)監(jiān)聽機制有兩個重要的方法，即executeLocalTransaction(執(zhí)行本地事務(wù))，checkLocalTransaction(回查本地事務(wù))。

RocketMQ事務(wù)消息的流轉(zhuǎn)過程其實也是十分簡單。首先，消息事務(wù)生產(chǎn)端會生生一個half消息即半消息，和正常一樣，生產(chǎn)者也是要將這個消息投遞到Broker當中，但這個Broker當中用來接收這個半消息的topic和普通的topic并不一樣，我們將這種用來接收生產(chǎn)者生產(chǎn)的half消息投遞的topic稱為half topic。特別注意,half topic對消費者來說是不可見的，即消費者無法直接從half topic當中獲取信息進行消費。

那么如何將half topic當中的消息轉(zhuǎn)移到正常的topic當中，讓消費者能夠消費呢？

首先，當Broker當中的半topic接收到這個半消息后，Broker便會返回一個ack給生產(chǎn)者，生產(chǎn)者接收到這個ack后，便會開始執(zhí)行本地事務(wù)。執(zhí)行本地事務(wù)后，會產(chǎn)生兩種結(jié)果，一種執(zhí)行成功一種執(zhí)行失敗。

事務(wù)執(zhí)行成功

當本地事務(wù)執(zhí)行成功之后，生產(chǎn)者便會將本地事務(wù)執(zhí)行成功的狀態(tài)提交個Broker，當Broker接收到這個信息時，便會將半topic當中的半消息給拿出來，放到目標topic當中，供消費者能夠進行正常消費。

事務(wù)執(zhí)行失敗

若當本地事務(wù)執(zhí)行的過程中產(chǎn)生異?；蛘邲]有執(zhí)行成功，生產(chǎn)者則會將事務(wù)進行回滾并會給Broker返回一個Rollback狀態(tài)，當Broker接收到Rollback這個狀態(tài)時，便會將半topic中的消息進行邏輯刪除，并且RocketMQ還會通過異步的方式單開一個線程，用來接收這種被Broker邏輯刪除的消息，并將這些消息進行清除。

事務(wù)執(zhí)行成功但無狀態(tài)

若本地事務(wù)執(zhí)行成功，但由于網(wǎng)絡(luò)波動，本地事務(wù)的執(zhí)行狀態(tài)未及時反饋給生產(chǎn)者或生產(chǎn)者遲遲未接收到本地事物的狀態(tài)，即處于無狀態(tài)或中間態(tài)的情況下，Broker便會啟動一個定時回查任務(wù)。Broker會調(diào)用事務(wù)監(jiān)聽器當中的checkTransaction接口，來查看當前事務(wù)的狀態(tài)，根據(jù)回查的狀態(tài)結(jié)果，來進行相應(yīng)的操作。這個事務(wù)回查機制，有次數(shù)限制，默認回查十五次，超過十五次后，便不會再來回查本地事務(wù)的狀態(tài)了。

總結(jié)

以上便是RocketMQ中事務(wù)消息的整個流程，筆者也將流程圖置于下方，希望能夠給各位小伙伴帶來幫助。筆者小，中，大廠均有面試經(jīng)驗，目前正在從事全棧開發(fā)工作，主要分享java全棧開發(fā)知識與相關(guān)的面試真題，希望能夠給大家?guī)韼椭?#xff0c;同大家共同進步。