介紹
Seata 是阿里巴巴開源的分布式事務中間件,一種分布式事務解決方案,具有高性能和易于使用的微服務架構。
初衷
對業(yè)務無侵入:即減少技術架構上的微服務化所帶來的分布式事務問題對業(yè)務的侵入
高性能:減少分布式事務解決方案所帶來的性能消耗
分布式事務定義
分布式事務是一個全局事務,由一批分支事務組成,通常分支事務只是本地事務。
設計
Seata中有兩種分布式事務實現(xiàn)方案,AT和TCC。
AT
AT模式是基于XA事務演進而來,核心是對業(yè)務無侵入,是一種改進后的兩階段提交,需要數(shù)據(jù)庫支持。
基本組件:
事務協(xié)調器(TC):事務協(xié)調器,維護全局事務的運行狀態(tài),負責協(xié)調并驅動全局事務的提交或回滾。
Transaction Manager(TM):?控制全局事務的邊界,負責開啟一個全局事務,并最終發(fā)起全局提交或全局回滾的決議。
資源管理器(RM):控制分支事務,負責分支注冊、狀態(tài)匯報,并接收事務協(xié)調器的指令,驅動分支(本地)事務的提交和回滾。
處理流程:
TM要求TC開始新的全局事務。TC生成表示全局事務的XID。
XID通過微服務的調用鏈傳播。
RM將本地事務注冊為XID到TC的相應全局事務的分支。
TM要求TC提交或回滾XID的相應全局事務。
TC在XID的相應全局事務下驅動所有分支事務以完成分支提交或回滾。
TCC
Seata要求每個接口實現(xiàn)prepare、commit、rollback。
與 AT 模式一樣,在運行時,該切面會攔截所有對 TCC 接口的調用。每調用一次 Try 接口,切面會先向 TC 注冊一個分支事務,然后才去執(zhí)行原來的 RPC 調用。當請求鏈路調用完成后,TC 通過分支事務的資源 ID 回調到正確的參與者去執(zhí)行對應 TCC 資源的 Confirm 或 Cancel 方法。
初步操作 Try:完成所有業(yè)務檢查,預留必須的業(yè)務資源。
確認操作 Confirm:真正執(zhí)行的業(yè)務邏輯,不做任何業(yè)務檢查,只使用 Try 階段預留的業(yè)務資源。因此,只要 Try 操作成功,Confirm 必須能成功。另外,Confirm 操作需滿足冪等性,保證一筆分布式事務能且只能成功一次。
取消操作 Cancel:釋放 Try 階段預留的業(yè)務資源。同樣的,Cancel 操作也需要滿足冪等性。
Seata Server安裝
1.下載最新版本的 Seata Sever
https://github.com/seata/seata/releases
2. 解壓并啟動 Seata server
unzip?seata-server-xxx.zip
cd?distribution
sh?./bin/seata-server.sh?8091?file
示例
場景:
把數(shù)據(jù)庫zeroa中proxy表的一條數(shù)據(jù)轉移到數(shù)據(jù)庫zerob中proxy表里面。
模塊:
zero-discovery-server:注冊中心
zero-gateway-server:服務網(wǎng)關
zero-consumer:服務消費者
zero-provider-a:服務提供者A
zero-provider-b:服務提供者B
架構及版本:
Spring-cloud:Finchley.BUILD-SNAPSHOT
spring-cloud-starter-netflix-eureka-server:2.0.4.BUILD-SNAPSHOT
spring-cloud-starter-netflix-eureka-client:2.0.4.BUILD-SNAPSHOT
spring-cloud-starter-gateway:2.0.4.BUILD-SNAPSHOT
spring-cloud-starter-openfeign:2.0.0.RELEASE
spring-boot:2.0.0.RELEASE
spring-boot-starter-data-jpa:2.0.0.RELEASE
spring-cloud-alibaba-seata:0.9.1.BUILD-SNAPSHOT
seata-all:0.6.1
mysql-connector-java:8.0.11
druid-spring-boot-starter:1.1.18
mysql:5.7
seata-server-0.6.1
實現(xiàn):
zero-gateway-server
配置application.yml
zero-provider-a:
配置application.yml
File.conf
主要配置應用名稱和seata server地址
vgroup_mapping.${spring.application.name}-fescar-service-group="default"
default.grouplist = "127.0.0.1:8091"
Registry.conf
編寫Entity
編寫Repository
編寫Service
編寫代碼Controller
DataSource
zero-provider-b
配置同zero-provider-a工程,編寫相應的業(yè)務邏輯。
在處理添加業(yè)務時,拋出異常。
zero-consumer
配置同zero-provider-a工程,編寫相應的業(yè)務邏輯。
feignClient
feignclient
Service
Controller
測試
啟動Seata Server
啟動Mysql,并初始化(每個庫都要創(chuàng)建undo_log表)
DROP?SCHEMA?IF?EXISTS?zeroa;
CREATE?SCHEMA?zeroa;
USE?zeroa;
CREATE?TABLE?`undo_log`?(
??`id`?bigint(20)?NOT?NULL?AUTO_INCREMENT,
??`branch_id`?bigint(20)?NOT?NULL,
??`xid`?varchar(100)?NOT?NULL,
??`context`?varchar(128)?NOT?NULL,
??`rollback_info`?longblob?NOT?NULL,
??`log_status`?int(11)?NOT?NULL,
??`log_created`?datetime?NOT?NULL,
??`log_modified`?datetime?NOT?NULL,
??`ext`?varchar(100)?DEFAULT?NULL,
??PRIMARY?KEY?(`id`),
??UNIQUE?KEY?`ux_undo_log`?(`xid`,`branch_id`)
)?ENGINE=InnoDB?AUTO_INCREMENT=1?DEFAULT?CHARSET=utf8;
DROP?SCHEMA?IF?EXISTS?zerob;
CREATE?SCHEMA?zerob;
USE?zerob;
CREATE?TABLE?`undo_log`?(
??`id`?bigint(20)?NOT?NULL?AUTO_INCREMENT,
??`branch_id`?bigint(20)?NOT?NULL,
??`xid`?varchar(100)?NOT?NULL,
??`context`?varchar(128)?NOT?NULL,
??`rollback_info`?longblob?NOT?NULL,
??`log_status`?int(11)?NOT?NULL,
??`log_created`?datetime?NOT?NULL,
??`log_modified`?datetime?NOT?NULL,
??`ext`?varchar(100)?DEFAULT?NULL,
??PRIMARY?KEY?(`id`),
??UNIQUE?KEY?`ux_undo_log`?(`xid`,`branch_id`)
)?ENGINE=InnoDB?AUTO_INCREMENT=1?DEFAULT?CHARSET=utf8;
啟動
zero-discovery-server
zero-gateway-server
zero-provider-a
zero-provider-b
zero-consumer
添加數(shù)據(jù)
正常執(zhí)行事務
可在兩張表中查看數(shù)據(jù)(a庫中刪除id=2的數(shù)據(jù),b庫中添加了一條數(shù)據(jù))。
執(zhí)行事務回滾
查看數(shù)據(jù)庫數(shù)據(jù)(沒有變化)。
另外有需要云服務器可以了解下創(chuàng)新互聯(lián)cdcxhl.cn,海內外云服務器15元起步,三天無理由+7*72小時售后在線,公司持有idc許可證,提供“云服務器、裸金屬服務器、高防服務器、香港服務器、美國服務器、虛擬主機、免備案服務器”等云主機租用服務以及企業(yè)上云的綜合解決方案,具有“安全穩(wěn)定、簡單易用、服務可用性高、性價比高”等特點與優(yōu)勢,專為企業(yè)上云打造定制,能夠滿足用戶豐富、多元化的應用場景需求。
名稱欄目:開源分布式事務中間件Seata使用指南-創(chuàng)新互聯(lián)
轉載來于:http://chinadenli.net/article18/dsgigp.html
成都網(wǎng)站建設公司_創(chuàng)新互聯(lián),為您提供軟件開發(fā)、微信小程序、App開發(fā)、標簽優(yōu)化、網(wǎng)站建設、網(wǎng)頁設計公司
聲明:本網(wǎng)站發(fā)布的內容(圖片、視頻和文字)以用戶投稿、用戶轉載內容為主,如果涉及侵權請盡快告知,我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場,如需處理請聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內容未經允許不得轉載,或轉載時需注明來源: 創(chuàng)新互聯(lián)