36、SpringCloudAlibaba实战：分布式事务：Seata框架代码的完善-15800字匠心巨作

本文详细讲解如何使用Seata解决微服务架构下的分布式事务问题。通过一个完整的订单系统示例，涵盖数据库设计、四个微服务（storage, account, order, business）的代码实现、Ribbon集成、Restful接口暴露，并演示了分布式事务异常场景及Seata的解决方案。

代码的完善

- 1.数据库表导入
2.模型对象和 Mapper 对象生成
3.storage-service 代码的完善
- 3.1 接口设计
3.2 实现该接口
3.3 使用 Restful 暴露此接口
3.4 添加配置文件
3.5 添加启动类
3.6 启动项目测试
4.account-service 代码的完善
- 4.1 接口设计
4.2 实现该接口
4.3 使用 Restful 暴露此接口
4.4 添加配置文件
4.5 添加启动类
4.6 启动项目测试
5.order-service 代码的完善
- 5.1 接口设计
5.2 实现该接口
5.3 远程调用 account-service 的实现
5.4 Ribbon 集成
5.5 使用 Restful 暴露此接口
5.6 添加配置文件
5.7 添加启动类
5.8 启动项目测试
6.business-service 代码的完善
- 6.1 接口设计
6.2 实现该接口
6.3 远程调用 storage-service 的实现
6.4 远程调用 order-service 的实现
6.5 集成 Ribbon
6.6 添加配置文件
6.7 添加启动类
6.8 暴露下单接口
6.9 启动项目测试
7.总体的调用流程如下
8.正常下单测试
9.分布式事务的演示
- 9.1 在 accout-service 服务扣减余额触发异常
9.2 重启 accout-service
9.3 还原数据库里面的数据
9.4 重新下单测试
10.使用 Seata 解决分布式问题
- 10.1 改造 accout-service 里面的 AccountServiceImpl
10.2 改造 BusinessServiceImpl
10.3 重启测试

1.数据库表导入

在测试分布式事务之前，我们需要先设计数据库，以及准备测试数据。
新建数据库，命名为：seata
创建表（导入 Sql）

/*
Navicat MySQL Data Transfer

Source Server         : Mysql
Source Server Version : 80019
Source Host           : localhost:3306
Source Database       : seata

Target Server Type    : MYSQL
Target Server Version : 80019
File Encoding         : 65001

Date: 2020-05-21 16:22:26
*/

SET FOREIGN_KEY_CHECKS=0;

-- ----------------------------
-- Table structure for account_tbl
-- ----------------------------
DROP TABLE IF EXISTS account_tbl;
CREATE TABLE account_tbl (
  id int NOT NULL AUTO_INCREMENT,
  user_id varchar(255) DEFAULT NULL,
  money int DEFAULT '0',
  PRIMARY KEY (id)
) ENGINE=InnoDB AUTO_INCREMENT=3 DEFAULT CHARSET=utf8;

-- ----------------------------
-- Records of account_tbl
-- ----------------------------
INSERT INTO account_tbl VALUES ('1', 'DQCGM_USER_1', '10000');
INSERT INTO account_tbl VALUES ('2', 'DQCGM_USER_2', '10000');

-- ----------------------------
-- Table structure for order_tbl
-- ----------------------------
DROP TABLE IF EXISTS order_tbl;
CREATE TABLE order_tbl (
  id int NOT NULL AUTO_INCREMENT,
  user_id varchar(255) DEFAULT NULL,
  commodity_code varchar(255) DEFAULT NULL,
  count int DEFAULT '0',
  money int DEFAULT '0',
  PRIMARY KEY (id)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

-- ----------------------------
-- Records of order_tbl
-- ----------------------------

-- ----------------------------
-- Table structure for storage_tbl
-- ----------------------------
DROP TABLE IF EXISTS storage_tbl;
CREATE TABLE storage_tbl (
  id int NOT NULL AUTO_INCREMENT,
  commodity_code varchar(255) DEFAULT NULL,
  count int DEFAULT '0',
  PRIMARY KEY (id),
  UNIQUE KEY commodity_code (commodity_code)
) ENGINE=InnoDB AUTO_INCREMENT=3 DEFAULT CHARSET=utf8;

-- ----------------------------
-- Records of storage_tbl
-- ----------------------------
INSERT INTO storage_tbl VALUES ('1', 'HUAWEI_0001', '10');
INSERT INTO storage_tbl VALUES ('2', 'XIAOMI_002', '10');

-- ----------------------------
-- Table structure for undo_log
-- ----------------------------
DROP TABLE IF EXISTS undo_log;
CREATE TABLE undo_log (
  id bigint NOT NULL AUTO_INCREMENT,
  branch_id bigint NOT NULL,
  xid varchar(100) NOT NULL,
  context varchar(128) NOT NULL,
  rollback_info longblob NOT NULL,
  log_status int 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;

-- ----------------------------
-- Records of undo_log
-- ----------------------