阿里云GTS-分布式事務解決方案

1、GTS-分布式事務全新解決方案功能架構(gòu)典型場景實踐操作產(chǎn)品簡介GTS是一款分布式事務中間件， 是一站式的分布式事務解決方案。產(chǎn)品簡介-GTS是什么跨庫事務服務化事務消息事務混合事務阻塞協(xié)議，影響系統(tǒng)吞吐和可伸縮性性能不理想，很難滿足互聯(lián)網(wǎng)大并發(fā)需求缺乏容錯機制實現(xiàn)復雜，各種異常情況難于處理要求每個方案實現(xiàn)一個反向的回滾接口運維成本高，擴現(xiàn)移植性不理想要求應用與消息系統(tǒng)緊耦合，增加開發(fā)成本要求業(yè)務實現(xiàn)冪等最終一致性，適用場景受限XA方案接口標準化補償方案符合業(yè)務需求消息方案實現(xiàn)相對簡單產(chǎn)品簡介-GTS與其他解決方案對比產(chǎn)品簡介-GTS與其他解決方案對比GTS資源1資源2資源n資源層應用系統(tǒng)2應用

2、系統(tǒng)n應用層應用系統(tǒng)1產(chǎn)品簡介-GTS優(yōu)勢可以解決分布式數(shù)據(jù)庫、跨數(shù)據(jù)庫、服務化、消息系統(tǒng)場景下的分布式事務問題一行注解即可實現(xiàn)事務接入，也提供API 接入模式使用門檻低，節(jié)省開發(fā)和運維成本高達傳統(tǒng)分布式事務 10 倍性能，4c8g集群可達1.5萬TPS。熱點數(shù)據(jù)高效處理，無懼數(shù)據(jù)沖突支持應用宕機、節(jié)點故障等各類異常情況下均可保持數(shù)據(jù)嚴格一致，支持同城主備及兩地三中心部署。產(chǎn)品簡介-產(chǎn)品歷史2015-12發(fā)布2.02017-02阿里云公測2018-05正式商用產(chǎn)品簡介-GTS商用5月21日正式商業(yè)，首發(fā)1月內(nèi)購買，低至七折GTS實例規(guī)格分為5TPS(免費版)、20TPS、100TPS、200T

3、PS、500TPS、2000TPS和 5000TPS。功能架構(gòu)-GTS事務模型全局事務分支事務1分支事務2分支事務3分支事務nxidbranchid功能架構(gòu)-事務協(xié)議RMRMRMRMRMGTSServerClusterxidBeginTXxidGlobalcommit/rollbackRegisterbranchwithxidbranchidReportbranchstatusBranchcommit/rollback功能架構(gòu)-容錯機制（服務節(jié)點宕機）RMS3S1S2RMRMGlobalTransactionAPP1APP2APP31.Failed2.Globalrollback3.Rollb

4、ack4.Rollback功能架構(gòu)-容錯機制（應用節(jié)點宕機）APP1RMAPP1RMAPP1RMDB1APP2RMAPP2RMAPP2RMDB2GTS功能架構(gòu)-擴展機制S3S1S2AppAppAppAppAppAppAppAppAppAppAppAppAppAppAppAppAppAppAppAppAppAppAppApp功能架構(gòu)-擴展機制S3S1S2AppAppAppAppAppAppS3S1S2S3S1S2AppAppAppAppAppAppAppAppAppAppAppApp功能架構(gòu)-AT&MTAT自動模式MT手動模式兩種模式完全兼容，可以組合使用強一致高效無侵入支持廣泛業(yè)務層自己維護事

5、務TCC模式的支持非事務性資源上的事務應用場景-解決跨數(shù)據(jù)庫的事務問題應用場景-解決微服務調(diào)用的事務問題應用場景-解決多系統(tǒng)集成的事務問題應用場景-解決混合事務問題DRDSMQEDAS應用案例車況檢查 物聯(lián)網(wǎng)系統(tǒng) 運維平臺生成訂單信息 訂單系統(tǒng)狀態(tài)變更 車輛系統(tǒng)推送訂單信息 MQ （ 流分析平臺、顯示大屏）鎖車 物聯(lián)網(wǎng)系統(tǒng) 運維平臺結(jié)束訂單 訂單系統(tǒng)推送訂單信息 MQ （ 流分析平臺、顯示大屏）獲取優(yōu)惠信息 優(yōu)惠系統(tǒng)扣款 支付系統(tǒng)實踐操作-AT模式TxcTransaction(timeout=60000*3)publicvoidtransfer(intmoney)throwsException

6、/A賬戶從db1減錢jdbcTemplate1.update(updateuser_money_asetmoney=money-?,money);/B賬戶從db2加錢setmoney=money+?,money);jdbcTemplate2.update(updateuser_money_b/余額不足時拋異常，GTS會回滾前兩次操作intmoney_a=getMoney(jdbcTemplate1,user_money_a); if(money_a0)thrownewRuntimeException(Balanceisnotenough.);實踐操作-AT模式EDAS客戶端TxcTransac

7、tion(appName = myapp2)publicvoidmoneyChange(intmoney) throwsSQLException /測試先加后減incMoneyService.incMoney(money); decMoneyService.decMoney (money);實踐操作-AT模式EDAS服務端publicintincMoney(intmoney)throwsSQLException if(getMoney()=-1)return-1;Statementstatement=connection.createStatement(); StringBuildersb=n

8、ewStringBuilder();sb.append(updateuser_money_incsetmoney=money+).append(money);statement.execute(sb.toString(); statement=connection.createStatement();ResultSetresultSet=statement.executeQuery(select*fromuser_money_inc);if(resultSet.next()money=resultSet.getInt(money);/adjustlevelupdateLevelService.

9、updateLevel(money);returnmoney;實踐操作-AT模式EDAS配置文件實踐操作-MT模式TxcTransaction(timeout=60000)publicvoidrunBussiness(intid,intmoney,MtServiceRollinmtServiceRollin,MtServiceRolloutmtServiceRollout) mtServiceRollout.rollout(null,0,id,money); mtServiceRollin.rollin(null,0,id,money);publicinterfaceMtServiceRolloutMtBranch(name=app1.reserve.rollout,commitMethod=commitRollout, rollbackMethod=rollbackRollout)publicvoidrollout(StringtxId,longbranchId,intid,intmon