Seata執(zhí)行流程
正常提交流程
image
- 在哪里開(kāi)啟了全局事務(wù)疮鲫，TM就在那里
-
@GlobalTransactional這個(gè)方法是開(kāi)啟全局事務(wù)的起點(diǎn)，向TC開(kāi)啟全局事務(wù) - 以全局事務(wù)ID注冊(cè)分支事務(wù)返回分支事務(wù)ID
- 執(zhí)行業(yè)務(wù)數(shù)據(jù)翎碑，上報(bào)分支事務(wù)處理結(jié)果
- 提交全局事務(wù)
- 分支事務(wù)在一階段已經(jīng)提交了
- 所在提交的時(shí)候不會(huì)再扣減金額
- 只需要把undo_log刪除掉
回滾流程
image
- 和正常提交流程一樣辅愿，但是分支事務(wù)在提交的時(shí)候可能會(huì)出錯(cuò)，這時(shí)候這個(gè)代理會(huì)攔截到這個(gè)錯(cuò)誤，然后向TC報(bào)告
- TC就會(huì)知道這個(gè)全局事務(wù)有一個(gè)分支出錯(cuò)了琅豆，這時(shí)候就進(jìn)行回滾
- TM向TC提交回滾全局事務(wù)
- 然后TC會(huì)向各個(gè)RM發(fā)起回滾
- undo_log記錄原始數(shù)據(jù)，及修改后的數(shù)據(jù)
- 解析undo_log篓吁，執(zhí)行反向操作
- 上報(bào)回滾狀態(tài)
要點(diǎn)說(shuō)明
- 1.每一個(gè)RM使用DataSourceProxy連接數(shù)據(jù)庫(kù)茫因，其目的是使用ConnectionProxy，使用數(shù)據(jù)源和數(shù)據(jù)連接代理的目的就是在第一階段將undo_log和業(yè)務(wù)數(shù)據(jù)放在一個(gè)本地事務(wù)提交杖剪，這樣就保存了只要業(yè)務(wù)操作就一定有undo_log冻押。
- 2.在第一個(gè)階段undo_log中存放了數(shù)據(jù)修改前和修改后的值，為了事務(wù)回滾作好準(zhǔn)備盛嘿，所以第一階段完成就已經(jīng)將分支事務(wù)提交洛巢，也就釋放了鎖資源。
- 3.TM開(kāi)啟全局事務(wù)開(kāi)始次兆，將XID全局事務(wù)ID放在事務(wù)上下文中稿茉，通過(guò)feign調(diào)用也將XID傳入下游分支事務(wù)，每個(gè)分支事務(wù)將自己的Branch ID分支事務(wù)ID與XID關(guān)聯(lián)芥炭。
- 4.第二階段全局事務(wù)提交漓库，TC會(huì)通知各各分支參與者提交分支事務(wù)，在第一個(gè)階段就已經(jīng)提交了分支事務(wù)蚤认，這里各各參與者只需要?jiǎng)h除undo_log即可米苹，并且可以異步執(zhí)行，第二階段很快可以完成砰琢。
- 5.第二階段全局事務(wù)回滾，TC會(huì)通知各各分支參與者回滾分支事務(wù)良瞧，通過(guò)XID和Branch ID找到相應(yīng)的回滾日志陪汽，通過(guò)回滾日志生成反向的SQL并執(zhí)行，以完成分支事務(wù)回滾到之前的狀態(tài)褥蚯，如果回滾失敗則會(huì)重試回滾操作挚冤。
