design 02 high level 01 ipaas - transaction平臺(tái)分布式事務(wù)圖before_第1頁
design 02 high level 01 ipaas - transaction平臺(tái)分布式事務(wù)圖before_第2頁
design 02 high level 01 ipaas - transaction平臺(tái)分布式事務(wù)圖before_第3頁
design 02 high level 01 ipaas - transaction平臺(tái)分布式事務(wù)圖before_第4頁
design 02 high level 01 ipaas - transaction平臺(tái)分布式事務(wù)圖before_第5頁
已閱讀5頁,還剩3頁未讀, 繼續(xù)免費(fèi)閱讀

下載本文檔

版權(quán)說明:本文檔由用戶提供并上傳,收益歸屬內(nèi)容提供方,若內(nèi)容存在侵權(quán),請進(jìn)行舉報(bào)或認(rèn)領(lǐng)

文檔簡介

Application

JVMApp1transaction

beginlocal

DTMinsert

sql(db1)KafkaDTM

centerDBSrouteinsert

sql(db1)insert

sqlexecuteinsert

sql(db2)transaction

commitcommitlabelTXIDcommit

labelDBSdb1

commitdb2

commitdb1confirmTXID:db1confirmdb2confirmTXID:db2confirmtx

logarchivedDTM

LOG

STORAGE

(MONGODB)Application

JVMApp1transaction

beginlocal

DTMgen

TXIDinsert

sql(db1)KafkaDTM

centerbegin

tx

logDRDSrouteinsert

sql(db1)send

execute

sqlTXID:

sql

stmt,sql

paraminsert

sqlexecuteinsert

sql(db2)DRDS或DTM

errortransactionrollbackrollbacklabelTXIDrollback

labelDRDSdb1

rollbackdb2

rollbackdb1confirmTXID:db1confirmdb2confirmTXID:db2confirmtx

logarchivedDTM

LOG

STORAGE

(MONGODB)Application

JVMApp1transaction

beginlocal

DTMgen

TXIDinsert

sql(db1)KafkaDTM

centerbegin

tx

logDRDSrouteinsert

sql(db1)send

execute

sqlTXID:

sql

stmt,sql

paraminsert

sqlexecuteinsert

sql(db2)TXID:

sql

stmt,sql

paramDRDS、DTM同上transaction

commitcommitlabelTXIDcommit

labelDRDSdb1

commitdb2

commit

errdb1confirmTXID:db1confirmDTM

LOG

STORAGE

(MONGODB)DTM

scannerscan1.DTMcommitlabelmittimewindowdb2commit(not

confirm)jdbc

to

db2insert

sql(db2)execute,commitTXID:db2confirmtx

logarchivedApplication

JVMApp1transaction

beginlocal

DTMKafkaDTM

centerinsert

sql(db2)transaction

commitcommitlabelTXIDcommit

labelDRDSdb1

commitdb2

commitdb1confirmTXID:db1confirmdb2confirmTXID:db2confirmDTM

LOG

STORAGE

(MONGODB)insert

sql(db1)call

Serv2Application

JVM2TXID:Serv2been

sendsend

Serv2

msgcall

Serv2

methodtx

logarchivedcall

Serv2confirmApplication

JVMApp1transaction

beginlocal

DTMgen

TXIDKafkaDTM

centerbegin

tx

loginsert

sql(db2)TXID:

sql

stmt,sql

paramDRDS、DTMtransaction

commitcommitlabelTXIDcommit

labelDRDSdb1

commitdb2

commitdb1confirmTXID:db1confirmdb2confirmTXID:db2confirmDTM

LOG

STORAGE

(MONGODB)insert

sql(db1)TXID:

sql

stmt,sql

paramDRDS、DTMcall

Serv2sendServ

msgTXID:

caller,

provider,

paramDTM

scannerscan1.DTMcommitlabel2.findcrossAppmsgmittimewindowsend

msg

to

ProviderApplication

JVM2tx

log

can’t

archivedtx

logarchivedsend

errorsetsubTXIDexec

subTXIDlocal

DTMcommit

sub

TXIDcall

Serv2

confirmApplication

JVMApp1transaction

beginlocal

DTMgen

TXIDinsert

sql(db2)DRDS、DTMtransaction

commitcommitlabelinsert

sql(db1)DRDS、DTMcall

Serv2serviceproviderApplication

JVM2Application

JVM3call

Serv2serviceprovidercommitholdcommitholdzookeeper

DTM

coordinatorset

commit=truedb1/db2commitdb1/db2confirmjvm2

DTMcommitjvm2

DTMconfirmjvm2

DTMcommitjvm2

DTMconfirmzookeeper

notifyshare

TXIDshare

TXIDApplication

JVMApp1transaction

beginlocal

DTMgen

TXIDinsert

sql(db1)DRDS、DTMcall

Serv2serviceproviderApplication

JVM2Application

JVM3call

Serv2serviceproviderrollbackDTM

coordinatorerrorshare

TXIDshare

TXIDlisteningzookeeper

pathreturn

remote

exceptiontransactionrollbackrollbacklabelDRDSdb1

rollbackdb2

rollbackdb1confirmdb2confirmApplication

JVMApp1transaction

beginlocal

DTMgen

TXIDinsert

sql(db2)DRDS、DTMtransaction

commitcommitlabelinsert

sql(db1)DRDS、DTMcall

Serv2serviceproviderApplication

JVM2Application

JVM3call

Serv2serviceprovidercommitholdcommitholdzookeeper

DTM

coordinatorerrorset

commit=trueerrorshare

TXID

溫馨提示

  • 1. 本站所有資源如無特殊說明,都需要本地電腦安裝OFFICE2007和PDF閱讀器。圖紙軟件為CAD,CAXA,PROE,UG,SolidWorks等.壓縮文件請下載最新的WinRAR軟件解壓。
  • 2. 本站的文檔不包含任何第三方提供的附件圖紙等,如果需要附件,請聯(lián)系上傳者。文件的所有權(quán)益歸上傳用戶所有。
  • 3. 本站RAR壓縮包中若帶圖紙,網(wǎng)頁內(nèi)容里面會(huì)有圖紙預(yù)覽,若沒有圖紙預(yù)覽就沒有圖紙。
  • 4. 未經(jīng)權(quán)益所有人同意不得將文件中的內(nèi)容挪作商業(yè)或盈利用途。
  • 5. 人人文庫網(wǎng)僅提供信息存儲(chǔ)空間,僅對用戶上傳內(nèi)容的表現(xiàn)方式做保護(hù)處理,對用戶上傳分享的文檔內(nèi)容本身不做任何修改或編輯,并不能對任何下載內(nèi)容負(fù)責(zé)。
  • 6. 下載文件中如有侵權(quán)或不適當(dāng)內(nèi)容,請與我們聯(lián)系,我們立即糾正。
  • 7. 本站不保證下載資源的準(zhǔn)確性、安全性和完整性, 同時(shí)也不承擔(dān)用戶因使用這些下載資源對自己和他人造成任何形式的傷害或損失。

最新文檔

評論

0/150

提交評論