SpringCloud Alibaba Seata---處理分布式事務

本文轉載自查看原文 2020-03-30 18:55 3887 微服務

　　前言：不斷學習就是程序員的宿命

一、Seata概述

1、背景

　　單體應用被拆分成微服務應用，原來的三個模塊被拆分成三個獨立的應用，分別使用不同的數據源，業務操作需要調用三個服務來完成。此時每個服務內部的數據一致性由本地事務來保證，但是全局的數據一致性問題沒法保證。

　　Seata是一款開源的分布式事務解決方案，致力於在微服務架構下提供高性能和簡單易用的分布式事務服務。

　　官網：http://seata.io/zh-cn/

2、一個典型的分布式事務過程（1+3）-分布式事務處理過程的一個ID+三組件模型：

　　　　(1)Transaction ID XID：全局唯一的事務ID

　　　　(2)三組概念：

　　　　　　①Transaction Coordinator（TC事務協調器）：維護全局和分支事務狀態，驅動全局事務提交或回滾

　　　　　　②Transaction Manager（TM事務管理器）：控制全局事務的邊界，負責開啟一個全局事務，並最終發起全局提交或全局回滾的決議

　　　　　　③Resource Manager（RM資源管理器）：控制分支事務,負責分支注冊、狀態匯報,並接受事務協調的指令,驅動分支(本地)事務的提交和回滾

3、Seata處理過程

①TM向TC申請開啟一個全局事務，全局事務創建成功並生成一個全局唯一的XID；

②XID在微服務調用鏈路的上下文傳播

③RM向TC注冊分支事務，將其納入XID對應全局事務的管轄

④TM向TC發起針對XID的全局提交或回滾決議；

⑤TC調度XID下管轄的全部分支事務完成提交或回滾事務

二、Seata分布式交易解決方案

案例需求：下訂單-->扣庫存--->減賬戶余額---->修改訂單狀態

環境准備：3個數據庫（訂單庫、庫存庫、賬戶庫）、3個微服務（訂單、庫存、賬戶服務）

當用戶下單時，會在訂單服務中創建一個訂單，然后通過遠程調用庫存服務來扣減下單商品的庫存。再通過遠程調用賬戶服務來扣減賬戶余額，最后在訂單服務中修改訂單狀態為已完成。該操作跨越三個數據庫，有兩次遠程調用，很明顯會有分布式事務問題。

三、Seata-Server安裝

　　下載地址：https://github.com/seata/seata/releases

1、修改file.conf

　　主要修改：自定義事務組名稱+事務日志存儲模式為db+數據連接信息（ps：記得備份file.conf）

1.1 service模塊

1.2store模塊

2、數據庫初始化

　　新建數據庫seata，執行初始表sql位置：/seata/conf/db_store.sql

3、修改registry.conf

4、分別啟動Nacos、seata-server

四、數據庫初始化

①seata_order：存儲訂單數據庫；

②seata_storage：存儲庫存數據；

③seata_account：存儲賬戶信息數據庫；

---seata biz
create database seata_order;
USE seata_order;
CREATE TABLE `t_order`  (
  `int` bigint(11) NOT NULL AUTO_INCREMENT,
  `user_id` bigint(20) DEFAULT NULL COMMENT '用戶id',
  `product_id` bigint(11) DEFAULT NULL COMMENT '產品id',
  `count` int(11) DEFAULT NULL COMMENT '數量',
  `money` decimal(11, 0) DEFAULT NULL COMMENT '金額',
  `status` int(1) DEFAULT NULL COMMENT '訂單狀態:  0:創建中 1:已完結',
  PRIMARY KEY (`int`) USING BTREE
) ENGINE = InnoDB CHARACTER SET = utf8 COLLATE = utf8_general_ci COMMENT = '訂單表' ROW_FORMAT = Dynamic;

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;

create database seata_storage;
USE seata_storage;
DROP TABLE IF EXISTS `t_storage`;
CREATE TABLE `t_storage`  (
  `int` bigint(11) NOT NULL AUTO_INCREMENT,
  `product_id` bigint(11) DEFAULT NULL COMMENT '產品id',
  `total` int(11) DEFAULT NULL COMMENT '總庫存',
  `used` int(11) DEFAULT NULL COMMENT '已用庫存',
  `residue` int(11) DEFAULT NULL COMMENT '剩余庫存',
  PRIMARY KEY (`int`) USING BTREE
) ENGINE = InnoDB CHARACTER SET = utf8 COLLATE = utf8_general_ci COMMENT = '庫存' ROW_FORMAT = Dynamic;
INSERT INTO `t_storage` VALUES (1, 1, 100, 0, 100);

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;

CREATE database seata_account;
USE seata_account;
DROP TABLE IF EXISTS `t_account`;
CREATE TABLE `t_account`  (
  `id` bigint(11) NOT NULL COMMENT 'id',
  `user_id` bigint(11) DEFAULT NULL COMMENT '用戶id',
  `total` decimal(10, 0) DEFAULT NULL COMMENT '總額度',
  `used` decimal(10, 0) DEFAULT NULL COMMENT '已用余額',
  `residue` decimal(10, 0) DEFAULT NULL COMMENT '剩余可用額度',
  PRIMARY KEY (`id`) USING BTREE
) ENGINE = InnoDB CHARACTER SET = utf8 COLLATE = utf8_general_ci COMMENT = '賬戶表' ROW_FORMAT = Dynamic;

INSERT INTO `t_account` VALUES (1, 1, 1000, 0, 1000);

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;