我的项目源码： https://gitee.com/benwang6/se...

一、订单业务案例

1.1 创立 Empty Project：seata-at

先新建文件夹 seata-samples，前面测试的 Seata AT 和 Seata TCC 模式都放在该目录下。

接着创立 seata-at 我的项目：

抉择 Empty Project：

填写我的项目名 seata-at 和寄存目录，寄存在你新建的 seata-samples 目录下：

1.2 数据库初始化工具

订单案例波及四个数据库：

为了后续测试不便咱们编写一个工具，用来重置所有数据库表，能够不便地把数据重置到初始状态。

1.3 新建Module：db-init

新建 Module，抉择 Spring Initializr

填写 Group 和 Artifact，其余选项默认即可：

增加 JDBC 和 MySQL Driver 依赖：

实现后，pom.xml 文件如下：

<?xml version="1.0" encoding="UTF-8"?><project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">    <modelVersion>4.0.0</modelVersion>    <parent>        <groupId>org.springframework.boot</groupId>        <artifactId>spring-boot-starter-parent</artifactId>        <version>2.3.2.RELEASE</version>        <relativePath/> <!-- lookup parent from repository -->    </parent>    <groupId>cn.tedu</groupId>    <artifactId>db-init</artifactId>    <version>0.0.1-SNAPSHOT</version>    <name>db-init</name>    <description>Demo project for Spring Boot</description>    <properties>        <java.version>1.8</java.version>    </properties>    <dependencies>        <dependency>            <groupId>org.springframework.boot</groupId>            <artifactId>spring-boot-starter-jdbc</artifactId>        </dependency>        <dependency>            <groupId>mysql</groupId>            <artifactId>mysql-connector-java</artifactId>            <scope>runtime</scope>        </dependency>        <dependency>            <groupId>org.springframework.boot</groupId>            <artifactId>spring-boot-starter-test</artifactId>            <scope>test</scope>            <exclusions>                <exclusion>                    <groupId>org.junit.vintage</groupId>                    <artifactId>junit-vintage-engine</artifactId>                </exclusion>            </exclusions>        </dependency>    </dependencies>    <build>        <plugins>            <plugin>                <groupId>org.springframework.boot</groupId>                <artifactId>spring-boot-maven-plugin</artifactId>            </plugin>        </plugins>    </build></project>

1.4 application.yml 配置

我的项目的 application.properties 文件改名成 application.yml，而后增加 mysql 连贯配置：

spring:  datasource:    driver-class-name: com.mysql.cj.jdbc.Driver    url: jdbc:mysql://localhost/?useUnicode=true&characterEncoding=UTF-8&serverTimezone=GMT%2B8    username: root    password: root

留神：在连贯地址中没有指定库名，是因为咱们要先后连贯四个数据库，前面执行的 sql 脚本文件中会执行 use 来进行数据库切换。

1.5 增加 sql 脚本文件

案例中的 sql 脚本来自不同的我的项目：

seata 库
seata 库是 Seata Server （TC，全局事务协调器）应用的数据库，建表语句来自这里：https://github.com/seata/seat...

order、storage和account库中的 undo_log 表
undo_log 表是各分支事务用来记录回滚日志的表，建表语句来自这里：https://github.com/seata/seat...

order、storage和account表
这个案例我的项目是 Seata 官网案例，我少做了一些改变。案例用的建表语句来自这里：https://github.com/seata/seat...，在各项目标 resources 目录中的 sql 文件。

order库中的 segment 表
EasyIdGenerator 是一个非常简单易用的全局惟一id发号器，他反对数据库自增id形式和雪花算法，因为雪花算法须要用到zookeeper服务器，为了简便起见，咱们应用数据库自增id的形式。segment 表就来自这个开源我的项目，我的项目地址：https://github.com/lookingats...

上面，在 resources 目录下，先新建一个 sql 文件夹，四个 sql 脚本文件放在 sql 文件夹下：

seata-server.sql

drop database if exists `seata`;CREATE DATABASE `seata` CHARSET utf8;use `seata`;-- -------------------------------- The script used when storeMode is 'db' ---------------------------------- the table to store GlobalSession dataCREATE TABLE IF NOT EXISTS `global_table`(`xid`                       VARCHAR(128) NOT NULL,`transaction_id`            BIGINT,`status`                    TINYINT      NOT NULL,`application_id`            VARCHAR(32),`transaction_service_group` VARCHAR(32),`transaction_name`          VARCHAR(128),`timeout`                   INT,`begin_time`                BIGINT,`application_data`          VARCHAR(2000),`gmt_create`                DATETIME,`gmt_modified`              DATETIME,PRIMARY KEY (`xid`),KEY `idx_gmt_modified_status` (`gmt_modified`, `status`),KEY `idx_transaction_id` (`transaction_id`)) ENGINE = InnoDBDEFAULT CHARSET = utf8;-- the table to store BranchSession dataCREATE TABLE IF NOT EXISTS `branch_table`(`branch_id`         BIGINT       NOT NULL,`xid`               VARCHAR(128) NOT NULL,`transaction_id`    BIGINT,`resource_group_id` VARCHAR(32),`resource_id`       VARCHAR(256),`branch_type`       VARCHAR(8),`status`            TINYINT,`client_id`         VARCHAR(64),`application_data`  VARCHAR(2000),`gmt_create`        DATETIME(6),`gmt_modified`      DATETIME(6),PRIMARY KEY (`branch_id`),KEY `idx_xid` (`xid`)) ENGINE = InnoDBDEFAULT CHARSET = utf8;-- the table to store lock dataCREATE TABLE IF NOT EXISTS `lock_table`(`row_key`        VARCHAR(128) NOT NULL,`xid`            VARCHAR(96),`transaction_id` BIGINT,`branch_id`      BIGINT       NOT NULL,`resource_id`    VARCHAR(256),`table_name`     VARCHAR(32),`pk`             VARCHAR(36),`gmt_create`     DATETIME,`gmt_modified`   DATETIME,PRIMARY KEY (`row_key`),KEY `idx_branch_id` (`branch_id`)) ENGINE = InnoDBDEFAULT CHARSET = utf8;

order.sql

drop database if exists `seata_order`;CREATE DATABASE `seata_order` charset utf8;use `seata_order`;CREATE TABLE `order` (  `id` bigint(11) NOT NULL,  `user_id` bigint(11) 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 '金额',  PRIMARY KEY (`id`)) ENGINE=InnoDB AUTO_INCREMENT=7 DEFAULT CHARSET=utf8;ALTER TABLE `order` ADD COLUMN `status` int(1) DEFAULT NULL COMMENT '订单状态：0：创立中；1：已完结' AFTER `money` ;-- for AT mode you must to init this sql for you business database. the seata server not need it.CREATE TABLE IF NOT EXISTS `undo_log`(    `branch_id`     BIGINT(20)   NOT NULL COMMENT 'branch transaction id',    `xid`           VARCHAR(100) NOT NULL COMMENT 'global transaction id',    `context`       VARCHAR(128) NOT NULL COMMENT 'undo_log context,such as serialization',    `rollback_info` LONGBLOB     NOT NULL COMMENT 'rollback info',    `log_status`    INT(11)      NOT NULL COMMENT '0:normal status,1:defense status',    `log_created`   DATETIME(6)  NOT NULL COMMENT 'create datetime',    `log_modified`  DATETIME(6)  NOT NULL COMMENT 'modify datetime',    UNIQUE KEY `ux_undo_log` (`xid`, `branch_id`)) ENGINE = InnoDB  AUTO_INCREMENT = 1  DEFAULT CHARSET = utf8 COMMENT ='AT transaction mode undo table';CREATE TABLE IF NOT EXISTS segment(    id            BIGINT UNSIGNED AUTO_INCREMENT PRIMARY KEY COMMENT '自增主键',    VERSION       BIGINT      DEFAULT 0  NOT NULL COMMENT '版本号',    business_type VARCHAR(63) DEFAULT '' NOT NULL COMMENT '业务类型，惟一',    max_id        BIGINT      DEFAULT 0  NOT NULL COMMENT '以后最大id',    step          INT         DEFAULT 0  NULL COMMENT '步长',    increment     INT         DEFAULT 1  NOT NULL COMMENT '每次id增量',    remainder     INT         DEFAULT 0  NOT NULL COMMENT '余数',    created_at    BIGINT UNSIGNED        NOT NULL COMMENT '创立工夫',    updated_at    BIGINT UNSIGNED        NOT NULL COMMENT '更新工夫',    CONSTRAINT uniq_business_type UNIQUE (business_type)) CHARSET = utf8mb4  ENGINE INNODB COMMENT '号段表';INSERT INTO segment(VERSION, business_type, max_id, step, increment, remainder, created_at, updated_at)VALUES (1, 'order_business', 1000, 1000, 1, 0, NOW(), NOW());

storage.sql

drop database  if exists `seata_storage`;CREATE DATABASE `seata_storage` charset utf8;use `seata_storage`;CREATE TABLE `storage` (  `id` 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 '残余库存',  `frozen` int(11) DEFAULT '0' COMMENT 'TCC事务锁定的库存',  PRIMARY KEY (`id`)) ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8;INSERT INTO `seata_storage`.`storage` (`id`, `product_id`, `total`, `used`, `residue`) VALUES ('1', '1', '100', '0', '100');-- for AT mode you must to init this sql for you business database. the seata server not need it.CREATE TABLE IF NOT EXISTS `undo_log`(    `branch_id`     BIGINT(20)   NOT NULL COMMENT 'branch transaction id',    `xid`           VARCHAR(100) NOT NULL COMMENT 'global transaction id',    `context`       VARCHAR(128) NOT NULL COMMENT 'undo_log context,such as serialization',    `rollback_info` LONGBLOB     NOT NULL COMMENT 'rollback info',    `log_status`    INT(11)      NOT NULL COMMENT '0:normal status,1:defense status',    `log_created`   DATETIME(6)  NOT NULL COMMENT 'create datetime',    `log_modified`  DATETIME(6)  NOT NULL COMMENT 'modify datetime',    UNIQUE KEY `ux_undo_log` (`xid`, `branch_id`)) ENGINE = InnoDB  AUTO_INCREMENT = 1  DEFAULT CHARSET = utf8 COMMENT ='AT transaction mode undo table';

account.sql

drop database  if exists `seata_account`;CREATE DATABASE `seata_account` charset utf8;use `seata_account`;CREATE TABLE `account` (  `id` bigint(11) NOT NULL AUTO_INCREMENT COMMENT 'id',  `user_id` bigint(11) UNIQUE DEFAULT NULL COMMENT '用户id',  `total` decimal(10,0) DEFAULT NULL COMMENT '总额度',  `used` decimal(10,0) DEFAULT NULL COMMENT '已用余额',  `residue` decimal(10,0) DEFAULT '0' COMMENT '残余可用额度',  `frozen` decimal(10,0) DEFAULT '0' COMMENT 'TCC事务锁定的金额',  PRIMARY KEY (`id`)) ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8;INSERT INTO `seata_account`.`account` (`id`, `user_id`, `total`, `used`, `residue`) VALUES ('1', '1', '1000', '0', '1000');-- for AT mode you must to init this sql for you business database. the seata server not need it.CREATE TABLE IF NOT EXISTS `undo_log`(    `branch_id`     BIGINT(20)   NOT NULL COMMENT 'branch transaction id',    `xid`           VARCHAR(100) NOT NULL COMMENT 'global transaction id',    `context`       VARCHAR(128) NOT NULL COMMENT 'undo_log context,such as serialization',    `rollback_info` LONGBLOB     NOT NULL COMMENT 'rollback info',    `log_status`    INT(11)      NOT NULL COMMENT '0:normal status,1:defense status',    `log_created`   DATETIME(6)  NOT NULL COMMENT 'create datetime',    `log_modified`  DATETIME(6)  NOT NULL COMMENT 'modify datetime',    UNIQUE KEY `ux_undo_log` (`xid`, `branch_id`)) ENGINE = InnoDB  AUTO_INCREMENT = 1  DEFAULT CHARSET = utf8 COMMENT ='AT transaction mode undo table';

1.6 主程序中增加代码，执行sql脚本

Spring 中提供了一个 jdbc 脚本执行器，应用这个工具能够十分不便的运行一个 sql 脚本文件，上面是这个办法：

ScriptUtils.executeSqlScript()

只须要传入它须要的参数即可。

上面代码运行 sql 目录中的四个脚本程序，每次运行都会删除四个数据库再从新创立，并初始化数据。

package cn.tedu.dbinit;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.boot.SpringApplication;import org.springframework.boot.autoconfigure.SpringBootApplication;import org.springframework.core.io.ClassPathResource;import org.springframework.core.io.support.EncodedResource;import org.springframework.jdbc.datasource.init.ScriptUtils;import javax.annotation.PostConstruct;import javax.sql.DataSource;import java.sql.SQLException;@SpringBootApplicationpublic class DbInitApplication {    @Autowired    private DataSource dataSource;    public static void main(String[] args) {        SpringApplication.run(DbInitApplication.class, args);    }    @PostConstruct    public void init() throws SQLException {        exec(dataSource, "sql/account.sql");        exec(dataSource, "sql/storage.sql");        exec(dataSource, "sql/order.sql");        exec(dataSource, "sql/seata-server.sql");    }    private void exec(DataSource accountDatasource, String script) throws SQLException {        ClassPathResource rc = new ClassPathResource(script, DbInitApplication.class.getClassLoader());        EncodedResource er = new EncodedResource(rc, "utf-8");        ScriptUtils.executeSqlScript(accountDatasource.getConnection(), er);    }}

二、eureka注册核心

2.1 新建 Module：eureka-server

新建 Module：

设置 Group 和 Artifact，其余默认：

抉择 eureka server 依赖：

设置我的项目名 eureka-server，寄存门路放在 seata-at 目录下：

2.2 application.yml 配置

spring:  application:    name: eureka-serverserver:  port: 8761eureka:  server:    enable-self-preservation: false  instance:    hostname: eureka1  client:    register-with-eureka: false    fetch-registry: false

2.3 主程序增加 @EnableEurekaServer 注解

package cn.tedu.eurekaserver;import org.springframework.boot.SpringApplication;import org.springframework.boot.autoconfigure.SpringBootApplication;import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;@EnableEurekaServer@SpringBootApplicationpublic class EurekaServerApplication {    public static void main(String[] args) {        SpringApplication.run(EurekaServerApplication.class, args);    }}

3. 父我的项目

为了对 order、storage和account微服务项目依赖进行对立治理，这里创立一个 pom 类型的 maven 我的项目，作为父我的项目。

3.1 新建 Maven 我的项目：order-parent

新建 Module，抉择 Maven 我的项目：

填写设置，将 order-parent 我的项目寄存在 seata-at 我的项目目录下：

3.2 批改 pom.xml

看到 seata 依赖局部被正文掉了，前面增加 seata 事务时再启用。

<?xml version="1.0" encoding="UTF-8"?><project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">    <modelVersion>4.0.0</modelVersion>    <parent>        <groupId>org.springframework.boot</groupId>        <artifactId>spring-boot-starter-parent</artifactId>        <version>2.3.2.RELEASE</version>        <relativePath/> <!-- lookup parent from repository -->    </parent>    <groupId>cn.tedu</groupId>    <artifactId>order-parent</artifactId>    <version>1.0-SNAPSHOT</version>    <packaging>pom</packaging>    <name>order-parent</name>    <properties>        <mybatis-plus.version>3.3.2</mybatis-plus.version>        <druid-spring-boot-starter.version>1.1.23</druid-spring-boot-starter.version>        <seata.version>1.3.0</seata.version>        <spring-cloud-alibaba-seata.version>2.0.0.RELEASE</spring-cloud-alibaba-seata.version>        <spring-cloud.version>Hoxton.SR6</spring-cloud.version>    </properties>    <dependencies>        <dependency>            <groupId>org.springframework.boot</groupId>            <artifactId>spring-boot-starter</artifactId>        </dependency>        <dependency>            <groupId>org.springframework.boot</groupId>            <artifactId>spring-boot-starter-web</artifactId>        </dependency>        <dependency>            <groupId>org.springframework.cloud</groupId>            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>        </dependency>        <dependency>            <groupId>org.springframework.cloud</groupId>            <artifactId>spring-cloud-starter-openfeign</artifactId>        </dependency>        <dependency>            <groupId>com.baomidou</groupId>            <artifactId>mybatis-plus-boot-starter</artifactId>            <version>${mybatis-plus.version}</version>        </dependency>        <dependency>            <groupId>mysql</groupId>            <artifactId>mysql-connector-java</artifactId>        </dependency>        <dependency>            <groupId>com.alibaba</groupId>            <artifactId>druid-spring-boot-starter</artifactId>            <version>${druid-spring-boot-starter.version}</version>        </dependency>        <!--<dependency>-->        <!--  <groupId>com.alibaba.cloud</groupId>-->        <!--  <artifactId>spring-cloud-alibaba-seata</artifactId>-->        <!--  <version>${spring-cloud-alibaba-seata.version}</version>-->        <!--  <exclusions>-->        <!--    <exclusion>-->        <!--      <artifactId>seata-all</artifactId>-->        <!--      <groupId>io.seata</groupId>-->        <!--    </exclusion>-->        <!--  </exclusions>-->        <!--</dependency>-->        <!--<dependency>-->        <!--  <groupId>io.seata</groupId>-->        <!--  <artifactId>seata-all</artifactId>-->        <!--  <version>${seata.version}</version>-->        <!--</dependency>-->        <dependency>            <groupId>org.projectlombok</groupId>            <artifactId>lombok</artifactId>        </dependency>        <dependency>            <groupId>org.springframework.boot</groupId>            <artifactId>spring-boot-starter-test</artifactId>            <scope>test</scope>            <exclusions>                <exclusion>                    <groupId>org.junit.vintage</groupId>                    <artifactId>junit-vintage-engine</artifactId>                </exclusion>            </exclusions>        </dependency>    </dependencies>    <dependencyManagement>        <dependencies>            <dependency>                <groupId>org.springframework.cloud</groupId>                <artifactId>spring-cloud-dependencies</artifactId>                <version>${spring-cloud.version}</version>                <type>pom</type>                <scope>import</scope>            </dependency>        </dependencies>    </dependencyManagement>    <build>        <plugins>            <plugin>                <groupId>org.springframework.boot</groupId>                <artifactId>spring-boot-maven-plugin</artifactId>            </plugin>        </plugins>    </build></project>

4. account账户我的项目

在这个微服务项目中实现扣减账户金额的性能。

新建 Module：account
新建Module：

设置 Group 和 Artifact，其它选项默认：

不抉择任何依赖，间接点下一步，这个我的项目要继承 order-parent 我的项目：

设置 Module 名称和存储目录：

批改 pom.xml
批改 pom.xml，设置继承父我的项目 order-parent：

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

     xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd"><parent>    <artifactId>order-parent</artifactId>    <groupId>cn.tedu</groupId>    <version>1.0-SNAPSHOT</version></parent><modelVersion>4.0.0</modelVersion><groupId>cn.tedu</groupId><artifactId>account</artifactId><version>0.0.1-SNAPSHOT</version><name>account</name><description>Demo project for Spring Boot</description>

</project>
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16

application.yml 配置
spring:
application:

name: account

datasource:

driver-class-name: com.mysql.cj.jdbc.Driverurl: jdbc:mysql://localhost/seata_account?useUnicode=true&characterEncoding=UTF-8&serverTimezone=GMT%2B8username: rootpassword: root

server:
port: 8081

eureka:
client:

service-url:  defaultZone: http://localhost:8761/eureka

instance:

prefer-ip-address: true

mybatis-plus:
type-aliases-package: cn.tedu.account.entity
mapper-locations:

- classpath:mapper/*Mapper.xml

configuration:

map-underscore-to-camel-case: true

logging:
level:

cn.tedu.account.mapper: DEBUG

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29

Mapper配置
先在 resources 目录下新建文件夹 mapper，而后创立文件 AccountMapper.xml：

<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
<mapper namespace="cn.tedu.account.mapper.AccountMapper" >

<resultMap id="BaseResultMap" type="cn.tedu.account.entity.Account" >    <id column="id" property="id" jdbcType="BIGINT" />    <result column="user_id" property="userId" jdbcType="BIGINT" />    <result column="total" property="total" jdbcType="DECIMAL" />    <result column="used" property="used" jdbcType="DECIMAL" />    <result column="residue" property="residue" jdbcType="DECIMAL"/>    <result column="frozen" property="frozen" jdbcType="DECIMAL"/></resultMap><update id="decrease">UPDATE account SET residue = residue - #{money},used = used + #{money} where user_id = #{userId};

</update>
</mapper>
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15

主程序增加 Mybatis 扫描注解
增加注解 @MapperScan("cn.tedu.account.mapper") ：

package cn.tedu.account;

import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@MapperScan("cn.tedu.account.mapper")
@SpringBootApplication
public class AccountApplication {

public static void main(String[] args) {    SpringApplication.run(AccountApplication.class, args);}

}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15

创立 Account 实体类
package cn.tedu.account.entity;

import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;

import java.math.BigDecimal;

@Data
@NoArgsConstructor
@AllArgsConstructor
public class Account {

private Long id;private Long userId;private BigDecimal total;private BigDecimal used;private BigDecimal residue;private BigDecimal frozen;

}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

创立 AccountMapper 类
这里继承 Mybatis-Plus 提供的通用 Mapper 父类

package cn.tedu.account.mapper;

import cn.tedu.account.entity.Account;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;

import java.math.BigDecimal;

public interface AccountMapper extends BaseMapper<Account> {

void decrease(Long userId, BigDecimal money);

}
1
2
3
4
5
6
7
8
9
10

增加 AccountService 接口和它的实现类
decrease() 办法实现扣减账户金额的性能

package cn.tedu.account.service;

import java.math.BigDecimal;

public interface AccountService {

void decrease(Long userId, BigDecimal money);

}
1
2
3
4
5
6
7
package cn.tedu.account.service;

import cn.tedu.account.mapper.AccountMapper;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.math.BigDecimal;
@Service
public class AccountServiceImpl implements AccountService {

@Autowiredprivate AccountMapper accountMapper;@Overridepublic void decrease(Long userId, BigDecimal money) {    accountMapper.decrease(userId,money);}

}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17

增加 AccountController 类提供客户端拜访接口
package cn.tedu.account.controller;

import cn.tedu.account.service.AccountService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

import java.math.BigDecimal;

@RestController
@Slf4j
public class AccountController {

@Autowiredprivate AccountService accountService;@GetMapping("/decrease")public String decrease(Long userId, BigDecimal money) {    accountService.decrease(userId,money);    return "用户账户扣减金额胜利";}

}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

启动 account 我的项目进行测试
查看 eureka 注册信息
拜访 http://localhost:8761/ 查看账户服务在 eureka 中的注册信息：

拜访账户服务执行账户扣减金额
拜访 http://localhost:8081/decrease?userId=1&money=100

查看控制台 Mybatis 执行的 sql 日志

查看数据库表，确认金额曾经被减掉

storage库存我的项目
storage 库存微服务项目，用来实现缩小库存的性能。

新建 Module：storage
新建Module：

设置 Group 和 Artifact，其它选项默认：

不抉择任何依赖，间接点下一步，这个我的项目要继承 order-parent 我的项目：

设置 Module 名称和存储目录：

批改 pom.xml
批改 pom.xml，设置继承父我的项目 order-parent：

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

     xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd"><parent>    <artifactId>order-parent</artifactId>    <groupId>cn.tedu</groupId>    <version>1.0-SNAPSHOT</version></parent><modelVersion>4.0.0</modelVersion><groupId>cn.tedu</groupId><artifactId>storage</artifactId><version>0.0.1-SNAPSHOT</version><name>storage</name><description>Demo project for Spring Boot</description>

</project>
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17

application.yml 配置
spring:
application:

name: storage

datasource:

driver-class-name: com.mysql.cj.jdbc.Driverurl: jdbc:mysql://localhost/seata_storage?useUnicode=true&characterEncoding=UTF-8&serverTimezone=GMT%2B8username: rootpassword: root

server:
port: 8082

eureka:
client:

service-url:  defaultZone: http://localhost:8761/eureka

instance:

prefer-ip-address: true

mybatis-plus:
type-aliases-package: cn.tedu.storage.entity
mapper-locations:

- classpath:/mapper/*Mapper.xml

configuration:

map-underscore-to-camel-case: true

logging:
level:

cn.tedu.storage.mapper: DEBUG

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29

Mapper配置
先在 resources 目录下新建文件夹 mapper，而后创立文件 StorageMapper.xml：

<resultMap id="BaseResultMap" type="cn.tedu.storage.entity.Storage" >    <id column="id" property="id" jdbcType="BIGINT" />    <result column="product_id" property="productId" jdbcType="BIGINT" />    <result column="total" property="total" jdbcType="INTEGER" />    <result column="used" property="used" jdbcType="INTEGER" />    <result column="residue" property="residue" jdbcType="INTEGER" /></resultMap><update id="decrease">  UPDATE storage SET used = used + #{count},residue = residue - #{count} WHERE product_id = #{productId}</update>

</mapper>
1
2
3
4
5
6
7
8
9
10
11
12
13
14

主程序增加 Mybatis 扫描注解
增加注解 @MapperScan("cn.tedu.storage.mapper") ：

package cn.tedu.storage;

import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@MapperScan("cn.tedu.storage.mapper")
@SpringBootApplication
public class StorageApplication {

public static void main(String[] args) {    SpringApplication.run(StorageApplication.class, args);}

}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15

创立 storage 实体类
package cn.tedu.storage.entity;

import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;

@Data
@NoArgsConstructor
@AllArgsConstructor
public class Storage {

private Long id;private Long productId;private Integer total;private Integer used;private Integer residue;private Integer frozen;

}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17

创立 StorageMapper 类
这里继承 Mybatis-Plus 提供的通用 Mapper 父类

package cn.tedu.storage.mapper;

import cn.tedu.storage.entity.Storage;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;

public interface StorageMapper extends BaseMapper<Storage> {

void decrease(Long productId, Integer count);

}
1
2
3
4
5
6
7
8

增加 StorageService 接口和它的实现类
decrease() 办法实现缩小商品库存性能。

package cn.tedu.storage.service;

public interface StorageService {

void decrease(Long productId, Integer count) throws Exception;

}
1
2
3
4
5
package cn.tedu.storage.service;

import cn.tedu.storage.mapper.StorageMapper;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

@Service
public class StorageServiceImpl implements StorageService {

@Autowiredprivate StorageMapper storageMapper;@Overridepublic void decrease(Long productId, Integer count) throws Exception {    storageMapper.decrease(productId,count);}

}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16

增加 StorageController 类提供客户端拜访接口
package cn.tedu.storage.controller;

import cn.tedu.storage.service.StorageService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class StorageController {

@Autowiredprivate StorageService storageService;@GetMapping("/decrease")public String decrease(Long productId, Integer count) throws Exception {    storageService.decrease(productId,count);    return "缩小商品库存胜利";}

}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

启动 storage 我的项目进行测试
查看 eureka 注册信息
拜访 http://localhost:8761/ 查看库存服务在 eureka 中的注册信息：

拜访库存服务，执行缩小库存操作
拜访 http://localhost:8082/decrease?productId=1&count=1

查看控制台 Mybatis 执行的 sql 日志

查看数据库表，确认金额曾经被减掉

order订单我的项目
order 订单我的项目保留订单，并调用 storage 和 account 缩小库存和扣减金额。

新建 Module：order
新建Module：

设置 Group 和 Artifact，其它选项默认：

不抉择任何依赖，间接点下一步，这个我的项目要继承 order-parent 我的项目：

设置 Module 名称和存储目录：

批改 pom.xml
批改 pom.xml，设置继承父我的项目 order-parent：

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

     xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd"><parent>    <artifactId>order-parent</artifactId>    <groupId>cn.tedu</groupId>    <version>1.0-SNAPSHOT</version></parent><modelVersion>4.0.0</modelVersion><groupId>cn.tedu</groupId><artifactId>order</artifactId><version>0.0.1-SNAPSHOT</version><name>order</name><description>Demo project for Spring Boot</description>

</project>
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17

application.yml 配置
spring:
application:

name: order

datasource:

driver-class-name: com.mysql.cj.jdbc.Driverurl: jdbc:mysql://localhost/seata_order?useUnicode=true&characterEncoding=UTF-8&serverTimezone=GMT%2B8username: rootpassword: root

server:
port: 8083

eureka:
client:

service-url:  defaultZone: http://localhost:8761/eureka

instance:

prefer-ip-address: true

mybatis-plus:
type-aliases-package: cn.tedu.sdorder.entity
mapper-locations:

- classpath:/mapper/*Mapper.xml

configuration:

map-underscore-to-camel-case: true

logging:
level:

cn.tedu.order.mapper: DEBUG

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30

Mapper配置
先在 resources 目录下新建文件夹 mapper，而后创立文件 OrderMapper.xml：

<resultMap id="BaseResultMap" type="cn.tedu.order.entity.Order" >    <id column="id" property="id" jdbcType="BIGINT" />    <result column="user_id" property="userId" jdbcType="BIGINT" />    <result column="product_id" property="productId" jdbcType="BIGINT" />    <result column="count" property="count" jdbcType="INTEGER" />    <result column="money" property="money" jdbcType="DECIMAL" />    <result column="status" property="status" jdbcType="INTEGER" /></resultMap><insert id="create">    INSERT INTO `order` (`id`,`user_id`,`product_id`,`count`,`money`,`status`)    VALUES(#{id}, #{userId}, #{productId}, #{count}, #{money},1);</insert>

</mapper>
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17

主程序增加 Mybatis 扫描注解
增加注解 @MapperScan("cn.tedu.order.mapper") ：

package cn.tedu.order;

import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@MapperScan("cn.tedu.order.mapper")
@SpringBootApplication
public class OrderApplication {

public static void main(String[] args) {    SpringApplication.run(OrderApplication.class, args);}

}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15

创立 order 实体类
package cn.tedu.order.entity;

import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;

import java.math.BigDecimal;

@Data
@NoArgsConstructor
@AllArgsConstructor
public class Order {

private Long id;private Long userId;private Long productId;private Integer count;private BigDecimal money;private Integer status;

}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

创立 OrderMapper 类
这里继承 Mybatis-Plus 提供的通用 Mapper 父类

package cn.tedu.order.mapper;

import cn.tedu.order.entity.Order;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;

public interface OrderMapper extends BaseMapper {

void create(Order order);

}
1
2
3
4
5
6
7
8
9

增加 OrderService 接口和它的实现类
create() 办法实现保留订单的性能。

package cn.tedu.order.service;

import cn.tedu.order.entity.Order;

public interface OrderService {

void create(Order order);

}
1
2
3
4
5
6
7
这里增加了三个 // TODO 正文，会在前面两节中实现。

package cn.tedu.order.service;

import cn.tedu.order.entity.Order;
import cn.tedu.order.mapper.OrderMapper;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.Random;

@Service
public class OrderServiceImpl implements OrderService {

@Autowiredprivate OrderMapper orderMapper;@Overridepublic void create(Order order) {    // TODO: 从全局惟一id发号器取得id，这里临时随机产生一个 orderId    Long orderId = Long.valueOf(new Random().nextInt(Integer.MAX_VALUE));    order.setId(orderId);    orderMapper.create(order);    // TODO: 调用storage，批改库存    // TODO: 调用account，批改账户余额}

}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28

增加 OrderController 类提供客户端拜访接口
package cn.tedu.order.controller;

import cn.tedu.order.entity.Order;
import cn.tedu.order.service.OrderService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
@Slf4j
public class OrderController {

@AutowiredOrderService orderService;/*用户用这个门路进行拜访：http://localhost:8083/create?userId=1&productId=1&count=10&money=100 */@GetMapping("/create")public String create(Order order) {    log.info("创立订单");    orderService.create(order);    return "创立订单胜利";}

}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26

启动 order 我的项目进行测试
查看 eureka 注册信息
拜访 http://localhost:8761/ 查看订单服务在 eureka 中的注册信：

拜访订单服务，执行订单保留
拜访 http://localhost:8083/create?userId=1&productId=1&count=10&money=100

查看控制台 Mybatis 执行的 sql 日志

查看数据库表，确认订单保留胜利

全局惟一id发号器
分布式系统中，产生惟一流水号的服务零碎俗称发号器。

有很多发号器开源我的项目，这里应用 EasyIdGenerator，具体我的项目信息请拜访：https://github.com/lookingats...

我的项目应用非常简单，将我的项目下载下来稍作配置即可。

下载我的项目
拜访 https://github.com/lookingats... ，下载发号器我的项目。

解压到 seata-at 工程目录下
解压，和后面的我的项目放到同一个工程目录。

把目录改名为 easy-id-generator ：

导入 Module
在Maven工具窗口中点击增加按钮，抉择发号器我的项目的 pom.xml 文件导入该我的项目：

留神：如果右侧没有Maven工具标签，请按两下shift键，而后查找 “add maven projects” 就能够找到这个工具。

配置

pom.xml
发号器向 eureka 进行注册，以便其它服务发现它。

在pom.xml 中增加 Spring Cloud Eureka Client 依赖：

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

     xmlns="http://maven.apache.org/POM/4.0.0"     xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><parent>    <groupId>org.springframework.boot</groupId>    <artifactId>spring-boot-starter-parent</artifactId>    <version>2.1.2.RELEASE</version>    <relativePath/></parent><groupId>com.easy.id</groupId><artifactId>easy-id-generator</artifactId><version>1.0-SNAPSHOT</version><properties>    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>    <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>    <maven.compiler.target>1.8</maven.compiler.target>    <maven.compiler.source>1.8</maven.compiler.source>    <junit.version>4.12</junit.version>    <mysql.connector.version>8.0.16</mysql.connector.version>    <com.alibaba.fastjson.version>1.2.62</com.alibaba.fastjson.version>    <lombok.version>1.18.8</lombok.version>    <curator.version>2.6.0</curator.version></properties><dependencies>    <dependency>        <groupId>org.projectlombok</groupId>        <artifactId>lombok</artifactId>        <version>${lombok.version}</version>        <scope>provided</scope>    </dependency>    <dependency>        <groupId>org.springframework.boot</groupId>        <artifactId>spring-boot-starter-web</artifactId>    </dependency>    <dependency>        <groupId>com.zaxxer</groupId>        <artifactId>HikariCP</artifactId>    </dependency>    <dependency>        <groupId>mysql</groupId>        <artifactId>mysql-connector-java</artifactId>        <version>${mysql.connector.version}</version>    </dependency>    <dependency>        <groupId>com.alibaba</groupId>        <artifactId>fastjson</artifactId>        <version>${com.alibaba.fastjson.version}</version>    </dependency>    <dependency>        <groupId>org.apache.curator</groupId>        <artifactId>curator-recipes</artifactId>        <version>${curator.version}</version>    </dependency>    <dependency>        <groupId>org.springframework.cloud</groupId>        <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>    </dependency></dependencies><dependencyManagement>    <dependencies>        <dependency>            <groupId>org.springframework.cloud</groupId>            <artifactId>spring-cloud-dependencies</artifactId>            <version>Greenwich.SR6</version>            <type>pom</type>            <scope>import</scope>        </dependency>    </dependencies></dependencyManagement>

</project>
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74

application.yml
配置应用数据库来生成自增id
向eureka进行注册
server:
port: 9090

easy-id-generator:
snowflake:

enable: falsezk:  connection-string: 127.0.0.1:2181,127.0.0.1:2182,127.0.0.1:2183load-worker-id-from-file-when-zk-down: true  # 当zk不可拜访时，从本地文件中读取之前备份的workerId

segment:

enable: truedb-list: seata_orderfetch-segment-retry-times: 3 # 从数据库获取号段失败重试次数

spring:
application:

name: easy-id-generator

eureka:
client:

service-url:  defaultZone: http://localhost:8761/eureka

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

seata_order.properties 数据库配置
在 resources 目录下新建配置文件 seata_order.properties，配置 seata_order 数据库的连贯信息。

jdbcUrl=jdbc:mysql://localhost:3306/seata_order?autoReconnect=true&useUnicode=true&characterEncoding=UTF-8
driverClassName=com.mysql.cj.jdbc.Driver
dataSource.user=root
dataSource.password=root
dataSource.cachePrepStmts=true
dataSource.prepStmtCacheSize=250
dataSource.prepStmtCacheSqlLimit=2048
1
2
3
4
5
6
7

数据表
在 db-init 我的项目的 order.sql 中曾经创立了数据表，并插入了一个名为 order_business 的自增id条目。

我的项目的 schema.sql 中为示例数据表。

启动我的项目并拜访测试
查看 eureka 中的注册信息

拜访测试
依据 SegmentEasyIdController 类的设置，拜访上面地址获取自增id：
http://localhost:9090/segment/ids/next_id?businessType=order_business

order订单增加Feign，调用库存和账户服务
调用发号器取得全局惟一id
调用库存服务缩小商品库存
调用账户服务扣减用户金额

application.yml
ribbon 默认超时工夫是1秒，为了不便分布式事务测试，把超时时长改为 10 秒：

spring:
application:

name: order

datasource:

driver-class-name: com.mysql.cj.jdbc.Driverurl: jdbc:mysql://localhost/seata_order?useUnicode=true&characterEncoding=UTF-8&serverTimezone=GMT%2B8username: rootpassword: root

server:
port: 8083

eureka:
client:

service-url:  defaultZone: http://localhost:8761/eureka

instance:

prefer-ip-address: true

mybatis-plus:
type-aliases-package: cn.tedu.sdorder.entity
mapper-locations:

- classpath:/mapper/*Mapper.xml

configuration:

map-underscore-to-camel-case: true

logging:
level:

cn.tedu.order.mapper: DEBUG

ribbon:
ReadTimeout: 10000
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33

主程序增加注解启用 Feign
增加 @EnableFeignClients 注解：

package cn.tedu.order;

import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.openfeign.EnableFeignClients;

@EnableFeignClients
@MapperScan("cn.tedu.order.mapper")
@SpringBootApplication
public class OrderApplication {

public static void main(String[] args) {    SpringApplication.run(OrderApplication.class, args);}

}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17

增加Feign申明式客户端接口
发号器的客户端接口：

package cn.tedu.order.feign;

import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestParam;

@FeignClient(name = "EASY-ID-GENERATOR")
public interface EasyIdGeneratorClient {

@GetMapping("/segment/ids/next_id")Long nextId(@RequestParam String businessType);

}
1
2
3
4
5
6
7
8
9
10
11
库存服务的客户端接口：

package cn.tedu.order.feign;

import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestParam;

@FeignClient(name = "storage")
public interface StorageClient {

@GetMapping("/decrease")String decrease(@RequestParam Long productId, @RequestParam Integer count);

}
1
2
3
4
5
6
7
8
9
10
11
账户服务的客户端接口：

package cn.tedu.order.feign;

import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestParam;

import java.math.BigDecimal;

@FeignClient(name = "account")
public interface AccountClient {

@GetMapping("/decrease")String decrease(@RequestParam Long userId, @RequestParam BigDecimal money);

}
1
2
3
4
5
6
7
8
9
10
11
12
13

在业务代码中通过Feign客户端调用近程服务
package cn.tedu.order.service;

import cn.tedu.order.entity.Order;
import cn.tedu.order.feign.AccountClient;
import cn.tedu.order.feign.EasyIdGeneratorClient;
import cn.tedu.order.feign.StorageClient;
import cn.tedu.order.mapper.OrderMapper;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.Random;

@Service
public class OrderServiceImpl implements OrderService {

@Autowiredprivate OrderMapper orderMapper;@AutowiredEasyIdGeneratorClient easyIdGeneratorClient;@Autowiredprivate AccountClient accountClient;@Autowiredprivate StorageClient storageClient;@Overridepublic void create(Order order) {    // 从全局惟一id发号器取得id    Long orderId = easyIdGeneratorClient.nextId("order_business");    order.setId(orderId);    orderMapper.create(order);    // 批改库存    storageClient.decrease(order.getProductId(), order.getCount());    // 批改账户余额    accountClient.decrease(order.getUserId(), order.getMoney());}

}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38

启动我的项目，拜访测试
拜访订单我的项目进行测试：

http://localhost:8083/create?userId=1&productId=1&count=10&money=100

查看 order、storage和account的控制台查看日志
查看三个数据库中的数据变动

将我的项目托管到 git 仓库

seata-samples 设置老本地 git 仓库
目前我的项目的目录构造：

seata-samples        |- seata-at             |- ...

seata-at 工程对 AT 事务进行测试。前面咱们还要测试 TCC 事务，会创立 seata-tcc 工程：

seata-samples        |- seata-at             |- ...        |- seata-tcc             |- ...

咱们能够把 seata 测试的这两个我的项目一起托管到同一个 git 仓库，便于管理，所以间接把 seata-samples 目录设置为本地仓库。

抉择创立本地仓库：

抉择 seata-samples 文件夹创立为本地库：

按 ctrl + k 提交，抉择提交全副文件，填写提交阐明后进行提交：

推送到近程 git 仓库
接下来先在 github 或 gitee 创立一个近程仓库，例如能够命名为 seata-samples。

再按 ctrl+shift+k 先设置近程仓库门路：

点击 push 向近程仓库推送：

我的项目源码： https://gitee.com/benwang6/se...