RocketMQ 源碼分析 13 事務消息01

 executeLocalTransaction:方法,記錄本地事務的事務狀態,這裏其實現就是循環設置事務消息的狀態爲0,1,2,demo中是把消息的狀態數據存放在一個Map中,實際應用,應該會持久化消息的事務狀態,例如數據庫或緩存。 其關鍵是checkLocalTransaction,會查本地事務表,判斷事務的狀態如爲0:UNKNOW,1:COMMIT_MESSAGE;ROLLBACK_MESS
相關文章
相關標籤/搜索