分布式事務之解決方案（XA和2PC）-有解無憂

3. 分布式事務解決方案之2PC（兩階段提交）

針對不同的分布式場景業界常見的解決方案有2PC、TCC、可靠訊息最終一致性、最大努力通知這幾種，

3.1. 什么是2PC

2PC即兩階段提交協議，是將整個事務流程分為兩個階段，準備階段（Prepare phase）、提交階段（commit phase），2是指兩階段，P是指準備階段，C是提交階段，
舉例：張三和李四好久不見，老友約起聚餐，飯店老板要求先買單，才能出票，這時張三和李四分別抱怨近況不如意，囊腫羞澀，都不愿意請客，這時只能AA，只有張三和李四都付款，老板才能出票安排就餐，但由于張三和李四都是鐵公雞，形成兩尷尬的一幕：
準備階段：老板要求張三付款，張三付款，老板要求李四付款，李四付款，
提交階段：老板出票，兩人拿票紛紛落座就餐，
例子中形成兩一個事務，若張三或李四其中一個拒絕付款，或錢不夠，店老板都不會給出票，并且會把已收款退回，
整個事務程序由事務管理器和參與者組成，店老板就是事務管理器，張三、李四就是事務參與者，事務管理器負責決策整個分布式事務的提交和回滾，事務參與者負責自己本地事務的提交和回滾，
在計算機中部分關系資料庫如Oracle、MySQL支持兩階段提交協議，如下圖：
1. 準備階段（Prepare phase）：事務管理器給每個參與者發送Prepare訊息，每個資料庫參與者在本地執行事務，并寫本地的Undo/Redo日志，此時事務沒有提交，
（Undo日志是記錄修改前的資料，用于資料庫回滾，Redo日志是記錄修改后的資料，用于提交事務后寫入資料檔案）
2. 提交階段（commit phase）：如果事務管理器收到兩參與者的執行失敗或者超時訊息時，直接給每個參與者發送回滾（Rollback）訊息；否則，發送提交（Commit）訊息；參與者根據事務管理器的指令執行提交或者回滾操作，并釋放事務處理程序中使用的鎖資源，注意：必須在最后階段釋放鎖資源，
下圖展示兩2PC的兩個階段，分成功和失敗兩個情況說明：
成功情況：
在這里插入圖片描述
失敗情況：

3.2. 解決方案

3.2.1 XA方案

2PC的傳統方案是在資料庫層面實作的，如Oracle、MySQL都支持2PC協議，為了統一標準減少行業內不必要的對接成本，需要制定標準化的處理模型及介面標準，國際開放標準組織Open Group定義分布式事務處理模型DTP（Distributed Transaction Processing Reference Model），
為了讓大家更明確XA方案的內容，下面新用戶注冊送積分為例來說明：
在這里插入圖片描述
執行流程如下：
1、應用程式（AP）持有用戶庫和積分庫兩個資料源，
2、應用程式（AP）通過TM通知用戶庫RM新增用戶，同時通知積分庫RM為該用戶新增積分，RM此時并未提交事務，此時用戶和積分資源鎖定，
3、TM收到執行回復，只要有一方失敗則分別向其他RM發起回滾事務，回滾完畢，資源鎖釋放，
4、TM收到執行回復，全部成功，此時向所有RM發起提交事務，提交完畢，資源鎖釋放，
DTP模型定義如下角色：

AP(Application Program) : 既應用程式，可以理解為使用DTP分布式事務的程式，
RM(Resource Manager) : 即資源管理器，可以理解為事務的參與者，一般情況下是指一個資料庫實體，通過資源管理器對該資料庫進行控制，資源管理器控制著分支事務，
TM(Transaction Manager) : 事務管理器，負責協調和管理事務，事務管理器控制著全域事務，管理事務生命周期，并協調各個RM，全域事務是指分布式事務處理環境中，需要操作多個資料庫共同完成一個作業，這個作業即是一個全域事務，
DTP模型定義TM和RM之間通訊的介面規范叫XA，簡單理解為資料庫提供的2PC介面協議，基于資料庫的XA協議來實作2PC又稱為XA方案，
以上三個角色之間的互動方式如下：
1）TM向AP提供應用程式編程介面，AP通過TM提交及回滾事務，
2）TM交易中間件通過XA介面來通知RM資料庫事務的開始、結束以及提交、回滾等，
總結：
整個2PC的事務流程涉及到三個角色AP、RM、TM，AP指的是使用2PC分布式事務的應用程式；RM指的是資源管理器，它控制著分支事務；TM指的是事務管理器，它控制著整個全域事務，
1）在準備階段RM執行實際的業務操作，但不提交事務，資源鎖定；
2）在提交階段TM會接收RM在準備階段的執行回復，只要有任一個RM執行失敗，TM會通知所有RM執行回滾操作，否則，TM將會通知所有RM提交該事務，提交階段結束資源鎖釋放，
XA方案的問題：
1、需要本地資料庫支持XA協議，
2、資源鎖需要等到兩個階段結束才釋放，性能較差，

3.2.2 Seata方案

Seata是阿里中間件團隊發起的開源專案Fescar，后更名Seata，它是一個是開源的分布式事務框架，傳統2PC的問題在Seata中得到了解決，它通過對本地關系資料庫的分支事務的協調來驅動完成全域事務，是作業在應用層的中間件，主要優點是性能較好，且不長時間占用連接資源，它以高效并且對業務0入侵的方式解決微服務場景下面臨的分布式事務問題，它目前提供AT模式（即2PC）及TCC模式的分布式事務解決方案，
Seata的設計思想如下：
Seata的設計目標其一是對業務無入侵，因此從業務無入侵的2PC方案著手，在傳統2PC的基礎上演進，并解決2PC方案面臨的問題，
Seata把一個分布式事務理解成一個包含來若干分支事務的全域事務，全域事務的職責是協調其下管轄的分支事務達成一致，要么一起成功提交，要么一起失敗回滾，此外，通常分支事務本身就是一個關系資料庫的本地事務，下圖是全域事務與分支事務的關系圖：
在這里插入圖片描述
與傳統2PC的模型類似，Seata定義了三個組件來協議分布式事務的處理程序：

Transaction Coordinator（TC）：事務協調器，它是獨立的中間件，需要獨立部署運行，它維護全域事務的運行狀態，接收TM指令發起全域事務的提交與回滾，負責與RM通信協調各個分支事務的提交或回滾，
Transaction Manager（TM）：事務管理器，TM需要嵌入應用程式中作業，它負責開啟一個全域事務，并最終向TC發起全域提交或全域回滾的指令，
Resource Manager（RM）：控制分支事務，負責分支注冊、狀態匯報，并接收事務協調器TC的指令，驅動分支（本地）事務的提交和回滾，
還拿新用戶注冊送積分舉例Seata的分布式事務程序：

具體的執行流程如下：

用戶服務的TM向TC申請開啟一個全域事務，全域事務創建成功并生成一個全域唯一的XID，
用戶服務的RM向TC注冊分支事務，該分支事務在用戶服務執行新增用戶邏輯，并將其納入XID對應全域事務的管轄，
用戶服務執行分支事務，向用戶表插入一條記錄，
邏輯執行到遠程呼叫積分服務時（XID在微服務呼叫鏈路的背景關系中傳播），積分服務的RM向TC注冊分支事務，該分支事務執行增加積分的邏輯，并將其納入XID對應全域事務的管轄，
積分服務執行分支事務，向積分記錄表插入一條記錄，執行完畢后，回傳用戶服務，
用戶服務分支事務執行完畢，
TM向TC發起針對XID的全域提交或回滾決議，
TC調度XID下管轄的全部分支事務完成提交或回滾請求，

Seata實作2PC與傳統2PC的差別：
架構層次方面，傳統2PC方案的RM實際上是在資料庫層，RM本質上就是資料庫自身，通過XA協議實作，而Seata的RM是以jar包的形式作為中間件層部署在應用程式的這一側的，
兩階段提交方面，傳統2PC無論第二階段的決議是commit還是rollbcak，事務性資源的鎖都要保持到Phase2完成才釋放，而Seata的做法是在Phase1就將本地事務提交，這樣就可以省去Phase2持鎖的時間，整體提高效率，

3.3. Seata實作2PC事務

3.3.1. 業務說明

本實體通過Seata中間件實作分布式事務，模擬兩個賬戶的轉賬交易程序，兩個賬戶在兩個不同的銀行（張三在bank1、李四在bank2），bank1和bank2是兩個微服務，交易程序中，張三給李四轉賬制定金額，
上述交易步驟，要么一起成功，要么一起失敗，必須是一個整體性的事務，
在這里插入圖片描述

3.3.2.程式組成部分

本實體程式組成部分如下：
資料庫：MySQL-5.7.25
包括bank1和bank2兩個資料庫，
JDK：1.8
微服務框架：spring-boot-2.1.3、spring-cloud-Greenwich.RELEASE
seata客戶端（RM、TM）：spring-cloud-alibaba-seata-2.1.0RELEASE
seata服務端(TC):seata-server-0.7.1
微服務及資料庫的關系：
dtx/dtx-seata-demo/seata-demo-bank1 銀行1，操作張三賬戶，鏈接資料庫bank1
dtx/dtx-seata-demo/seata-demo-bank2 銀行2，操作李四賬戶，鏈接資料庫bank2
服務注冊中興：dtx/discover-server
本實體程式技術架構如下：
在這里插入圖片描述
互動流程如下：
1、請求bank1進行轉賬，傳入轉賬金額，
2、bank1減少轉賬金額，呼叫bank2，傳入轉賬金額，

3.3.3.創建資料庫

bank1庫，包含張三賬戶

CREATE DATABASE /*!32312 IF NOT EXISTS*/`bank1` /*!40100 DEFAULT CHARACTER SET utf8 */;

USE `bank1`;

/*Table structure for table `account_info` */

DROP TABLE IF EXISTS `account_info`;

CREATE TABLE `account_info` (
  `id` bigint(20) NOT NULL AUTO_INCREMENT,
  `account_name` varchar(100) COLLATE utf8_bin DEFAULT NULL COMMENT '戶主姓名',
  `account_no` varchar(100) COLLATE utf8_bin DEFAULT NULL COMMENT '銀行卡號',
  `account_password` varchar(100) COLLATE utf8_bin DEFAULT NULL COMMENT '帳戶密碼',
  `account_balance` double DEFAULT NULL COMMENT '帳戶余額',
  PRIMARY KEY (`id`) USING BTREE
) ENGINE=InnoDB AUTO_INCREMENT=3 DEFAULT CHARSET=utf8 COLLATE=utf8_bin ROW_FORMAT=DYNAMIC;

/*Data for the table `account_info` */

insert  into `account_info`(`id`,`account_name`,`account_no`,`account_password`,`account_balance`) values (2,'張三','1',NULL,1000);

/*Table structure for table `de_duplication` */

DROP TABLE IF EXISTS `de_duplication`;

CREATE TABLE `de_duplication` (
  `tx_no` varchar(64) COLLATE utf8_bin NOT NULL,
  `create_time` datetime DEFAULT NULL,
  PRIMARY KEY (`tx_no`) USING BTREE
) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_bin ROW_FORMAT=DYNAMIC;

/*Data for the table `de_duplication` */

/*Table structure for table `local_cancel_log` */

DROP TABLE IF EXISTS `local_cancel_log`;

CREATE TABLE `local_cancel_log` (
  `tx_no` varchar(64) NOT NULL COMMENT '事務id',
  `create_time` datetime DEFAULT NULL,
  PRIMARY KEY (`tx_no`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

/*Data for the table `local_cancel_log` */

/*Table structure for table `local_confirm_log` */

DROP TABLE IF EXISTS `local_confirm_log`;

CREATE TABLE `local_confirm_log` (
  `tx_no` varchar(64) NOT NULL COMMENT '事務id',
  `create_time` datetime DEFAULT NULL,
  PRIMARY KEY (`tx_no`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

/*Data for the table `local_confirm_log` */

/*Table structure for table `local_trade_log` */

DROP TABLE IF EXISTS `local_trade_log`;

CREATE TABLE `local_trade_log` (
  `tx_no` bigint(20) NOT NULL,
  `create_time` datetime DEFAULT NULL,
  PRIMARY KEY (`tx_no`) USING BTREE
) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_bin ROW_FORMAT=DYNAMIC;
DROP TABLE IF EXISTS `local_try_log`;

CREATE TABLE `local_try_log` (
  `tx_no` varchar(64) NOT NULL COMMENT '事務id',
  `create_time` datetime DEFAULT NULL,
  PRIMARY KEY (`tx_no`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

/*Data for the table `local_try_log` */

/*Table structure for table `undo_log` */

DROP TABLE IF EXISTS `undo_log`;

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=167 DEFAULT CHARSET=utf8;

/*Data for the table `undo_log` */

insert  into `undo_log`(`id`,`branch_id`,`xid`,`context`,`rollback_info`,`log_status`,`log_created`,`log_modified`,`ext`) values (166,2019228885,'192.168.1.101:8888:2019228047','serializer=jackson','{}',1,'2019-08-11 15:16:43','2019-08-11 15:16:43',NULL);

bank2庫，包含李四賬戶

CREATE DATABASE /*!32312 IF NOT EXISTS*/`bank2` /*!40100 DEFAULT CHARACTER SET utf8 */;

USE `bank2`;

/*Table structure for table `account_info` */

DROP TABLE IF EXISTS `account_info`;

CREATE TABLE `account_info` (
  `id` bigint(20) NOT NULL AUTO_INCREMENT,
  `account_name` varchar(100) COLLATE utf8_bin DEFAULT NULL COMMENT '戶主姓名',
  `account_no` varchar(100) COLLATE utf8_bin DEFAULT NULL COMMENT '銀行卡號',
  `account_password` varchar(100) COLLATE utf8_bin DEFAULT NULL COMMENT '帳戶密碼',
  `account_balance` double DEFAULT NULL COMMENT '帳戶余額',
  PRIMARY KEY (`id`) USING BTREE
) ENGINE=InnoDB AUTO_INCREMENT=4 DEFAULT CHARSET=utf8 COLLATE=utf8_bin ROW_FORMAT=DYNAMIC;

/*Data for the table `account_info` */

insert  into `account_info`(`id`,`account_name`,`account_no`,`account_password`,`account_balance`) values (3,'李四的賬戶','2',NULL,0);

/*Table structure for table `de_duplication` */

DROP TABLE IF EXISTS `de_duplication`;

CREATE TABLE `de_duplication` (
  `tx_no` varchar(64) COLLATE utf8_bin NOT NULL,
  `create_time` datetime DEFAULT NULL,
  PRIMARY KEY (`tx_no`) USING BTREE
) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_bin ROW_FORMAT=DYNAMIC;

/*Data for the table `de_duplication` */

/*Table structure for table `local_cancel_log` */

DROP TABLE IF EXISTS `local_cancel_log`;

CREATE TABLE `local_cancel_log` (
  `tx_no` varchar(64) NOT NULL COMMENT '事務id',
  `create_time` datetime DEFAULT NULL,
  PRIMARY KEY (`tx_no`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

/*Data for the table `local_cancel_log` */

/*Table structure for table `local_confirm_log` */

DROP TABLE IF EXISTS `local_confirm_log`;

CREATE TABLE `local_confirm_log` (
  `tx_no` varchar(64) NOT NULL COMMENT '事務id',
  `create_time` datetime DEFAULT NULL
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

/*Data for the table `local_confirm_log` */

/*Table structure for table `local_trade_log` */

DROP TABLE IF EXISTS `local_trade_log`;

CREATE TABLE `local_trade_log` (
  `tx_no` bigint(20) NOT NULL,
  `create_time` datetime DEFAULT NULL,
  PRIMARY KEY (`tx_no`) USING BTREE
) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_bin ROW_FORMAT=DYNAMIC;
DROP TABLE IF EXISTS `local_try_log`;

CREATE TABLE `local_try_log` (
  `tx_no` varchar(64) NOT NULL COMMENT '事務id',
  `create_time` datetime DEFAULT NULL,
  PRIMARY KEY (`tx_no`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

/*Data for the table `local_try_log` */

/*Table structure for table `undo_log` */

DROP TABLE IF EXISTS `undo_log`;

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 DEFAULT CHARSET=utf8;

3.3.4.啟動TC（事務協調器）

（1）下載seata服務器
下載地址：seata服務器
（2）解壓并啟動
winodws ：【seata服務端解壓路徑】/bin/seata-server.bat -p 8888 -m file
mac/linux : 【seata服務端解壓路徑】nohup sh seata-server.sh -p 8888 -h 127.0.0.1 -m file &> seata.log &
注：其中8888為服務埠號；file為啟動模式，這里指seata服務將采用檔案的方式存盤資訊，
在這里插入圖片描述
如上圖出現“Server started，，，“的字樣則表示啟動成功，

3.3.5 discover-server

discover-server是服務注冊中心，測驗工程將自己注冊至discover-server，

3.3.6 創建dtx-seata-demo

dtx-seata-demo是seata的測驗工程，根據業務需求需要創建兩個dex-seata-demo工程，
（1）父工程maven依賴說明
在dtx父工程中指定了SpringBoot和SpringCloud版本
在這里插入圖片描述
在dtx-seata-demo父工程中指定了spring-cloud-alibaba-dependencies的版本，

（3）配置seata
在src/main/resource中，新增registry.conf、file.conf檔案，內容可拷貝seata-server-0.7.1中的組態檔子，在registry.conf中registry.type使用file:

在file.conf中更改service.vgroup_mapping.[springcloud服務名]-fescar-service-group = “default”，并修改 service.default.grouplist =[seata服務端地址]
在這里插入圖片描述
關于vgroup_mapping的配置:
vgroup_mapping.事務分組服務名=Seata Server集群名稱(默認名稱為default) default.grouplist = Seata Server集群地址
在 org.springframework.cloud:spring-cloud-starter-alibaba-seata 的 org.springframework.cloud.alibaba.seata.GlobalTransactionAutoConfiguration 類中，默認會使用 ${spring.application.name}-fescar-service-group 作為事務分組服務名注冊到 Seata Server上，如果和 file.conf 中的配置不一致，會提示 no available server to connect 錯誤
也可以通過配置 spring.cloud.alibaba.seata.tx-service-group 修改后綴，但是必須和 file.conf 中的配置保持一致，
(4)創建代理資料源
新增DatabaseConfiguration.java，Seata的RM通過DataSourceProxy才能在業務代碼的事務提交時，通過這個切入點，與TC進行通信互動、記錄undo_log等，

@Configuration
public class DatabaseConfiguration { 
	@Bean
	@ConfigurationProperties(prefix = "spring.datasource.ds0") 
	public 	DruidDataSource ds0() {
	DruidDataSource druidDataSource = new DruidDataSource(); 
	return 		druidDataSource;
}
	@Primary
	@Bean
	public DataSource dataSource(DruidDataSource ds0) {
	DataSourceProxy pds0 = new DataSourceProxy(ds0);
	return pds0; 
	}
}

3.3.7 Seata執行流程

1、正常提交流程
在這里插入圖片描述
2、回滾流程
回滾流程省略前的RM注冊程序，

要點說明：
1、每個RM使用DataSourceProxy連接資料庫，其目的是使用ConnectionProxy，使用資料源和資料連接代理的目的就是第一階段將undo_log和業務資料放在一個本地事務提交，這樣就保存了只要有業務操作就一定有undo_log.
2、在第一階段undo_log中存放了資料修改前和修改后的值，為事務回滾作好準備，所以第一階段完成就已經將分支事務提交，也就釋放了鎖資源，
3、TM開啟全域事務開始，將XID全域事務id放在事務上下午中，通過feign呼叫也將XID傳入下游分支事務，每個分支事務將自己的Branch ID分支事務ID與XID關聯，
4、第二階段全域事務提交，TC會通知各個分支參與者提交分支事務，在第一階段就已經提交了分支事務，這里各個參與者只需要洗掉undo_log即可，并且可以異步執行，第二階段很快可以完成，
5、第二階段全域事務回滾，TC會通知各個分支參與者回滾分支事務，通過XID和Branch ID找到相應的回滾日志，通過回滾日志生成反向的SQL并執行，以完成分支事務回滾到之前的狀態，如果回滾失敗則會重試回滾操作，

3.3.8 dtx-seata-demo-bank1

dtx-seata-demo-bank1實作如下功能：
1、張三賬戶減少金額，開啟全域事務，
2、遠程呼叫bank2向李四轉賬，
（1）DAO

@Mapper
@Component
public interface AccountInfoDao {

	//更新賬戶金額
@Update("update account_info set account_balance = account_balance + #{amount} where account_no = #{accountNo}")
int updateAccountBalance(@Param("accountNo") String accountNo, @Param("amount") Double amount);

}

(2) FeignClient
遠程呼叫bank2的客戶端

 @FeignClient(value = "seata‐demo‐bank2",fallback = Bank2ClientFallback.class) public interface Bank2Client {
@GetMapping("/bank2/transfer")
String transfer(@RequestParam("amount") Double amount); 
}
@Component
public class Bank2ClientFallback implements Bank2Client{
@Override
public String transfer(Double amount) {
return "fallback"; }
}

（3）Service

@Service
public class AccountInfoServiceImpl implements AccountInfoService {
private Logger logger = LoggerFactory.getLogger(AccountInfoServiceImpl.class);
@Autowired
AccountInfoDao accountInfoDao;
@Autowired
Bank2Client bank2Client;
//張三轉賬
@Override
@GlobalTransactional
@Transactional
public void updateAccountBalance(String accountNo, Double amount) {
	logger.info("******** Bank1 Service Begin ... xid: {}" , RootContext.getXID()); //張三扣減金額
	accountInfoDao.updateAccountBalance(accountNo,amount*‐1);
	//向李四轉賬
	String remoteRst = bank2Client.transfer(amount); //遠程呼叫失敗
	if(remoteRst.equals("fallback")){
	throw new RuntimeException("bank1 下游服務例外"); }
	//人為制造錯誤 if(amount==3){
	throw new RuntimeException("bank1 make exception 3"); }
	} 
}

將@GlobalTransactional注解標注在全域事務發起的Service實作方法上，開啟全域事務：
GlobalTransactionalInterceptor會攔截@GlobalTransactional注解的方法，生成全域事務ID（XID），XID會在整個分布式事務中傳遞，
在遠程呼叫時，spring-cloud-alibaba-seata會攔截Feign呼叫將XID傳遞到下游服務，
（6）Controller

@RestController
public class Bank1Controller {
@Autowired
AccountInfoService accountInfoService;
//轉賬
@GetMapping("/transfer")
public String transfer(Double amount){
accountInfoService.updateAccountBalance("1",amount);
return "bank1"+amount; }
}

3.3.9 dtx-seata-demo-bank2

dtx-seata-demo-bank2實作如下功能：
1、李四賬戶增加金額，
dtx-seata-demo-bank2在本賬戶事務中作為分支事務不使用@GlobalTransactional，
（1）DAO

 @Mapper
@Component
public interface AccountInfoDao {
//向李四轉賬
@Update("UPDATE account_info SET account_balance = account_balance + #{amount} WHERE account_no = #{accountNo}")
int updateAccountBalance(@Param("accountNo") String accountNo, @Param("amount") Double amount);
}

（2）Service

@Service
public class AccountInfoServiceImpl implements AccountInfoService {
private Logger logger = LoggerFactory.getLogger(AccountInfoServiceImpl.class);
@Autowired
AccountInfoDao accountInfoDao;
@Override 
@Transactional
public void updateAccountBalance(String accountNo, Double amount) { logger.info("******** Bank2 Service Begin ... xid: {}" , RootContext.getXID()); //李四增加金額
accountInfoDao.updateAccountBalance(accountNo,amount);
//制造例外
if(amount==2){
throw new RuntimeException("bank1 make exception 2"); }
} 
}

（3）Controller

 @RestController
public class Bank2Controller {
@Autowired
AccountInfoService accountInfoService;
@GetMapping("/transfer")
public String transfer(Double amount){
accountInfoService.updateAccountBalance("2",amount);
return "bank2"+amount; 
}
}

3.3.10 測驗場景

張三向李四轉賬成功，
李四事務失敗，張三事務回滾成功，
張三事務失敗，李四事務回滾成功，
分支事務超時測驗，

3.4. 小結

傳統2PC（基于資料庫XA協議）和Seata實作2PC的兩種2PC方案，由于Seata的零入侵并且解決了傳統2PC長期鎖資源的問題，所以推薦采用Seata實作2PC，
Seata實作2PC要點：
1、全域事務開始使用GlobalTransactional標識，
2、每個本地事務方案仍然使用@Transactional標識，
3、每個資料都需要創建undo_log表，此表是Seata保證本地事務一致性的關鍵，

轉載請註明出處，本文鏈接：https://www.uj5u.com/ruanti/37768.html

標籤：架構設計

上一篇：Centos7安裝redis5.0.7

下一篇：設計模式之美—工廠方法模式