源码地址：GitHub·点这里 || GitEE·点这里

一、Seata简介

1、Seata组件

Seata是一款开源的分布式事务解决方案，致力于提供高性能和简略易用的分布式事务服务。Seata将为用户提供了AT、TCC、SAGA、XA事务模式，为用户打造一站式的分布式解决方案。

2、反对模式

AT 模式

• 基于反对本地 ACID 事务的关系型数据库。
• Java利用，通过 JDBC 拜访数据库。

一阶段：业务数据和回滚日志记录在同一个本地事务中提交，开释本地锁和连贯资源。

二阶段：提交异步化，十分疾速地实现。回滚通过一阶段的回滚日志进行反向弥补。

TCC模式

一个分布式的全局事务，整体是两阶段提交的模型，全局事务是由若干分支事务组成的，分支事务要满足两阶段提交的模型要求，即须要每个分支事务都具备本人的：

一阶段 prepare 行为

二阶段 commit 或 rollback 行为

Saga模式

Saga模式是SEATA提供的长事务解决方案，在Saga模式中，业务流程中每个参与者都提交本地事务，当呈现某一个参与者失败则弥补后面曾经胜利的参与者，一阶段正向服务和二阶段弥补服务都由业务开发实现。

XA模式

XA是一个分布式事务协定，对业务无侵入的分布式事务解决方案，XA提交协定须要事务参与者的数据库反对，XA事务具备强一致性，在两阶段提交的整个过程中，始终会持有资源的锁，性能不现实的毛病很显著。

二、服务端部署

1、下载组件包

1.2版本：seata-server-1.2.0.zip

解压目录

• bin：寄存服务端运行启动脚本;
• lib：寄存服务端依赖的资源jar包；
• conf：配置文件目录。

2、批改配置

file.conf配置

mode:db 即应用数据库存储事务信息，这里还能够抉择file存储形式。

file模式为单机模式，全局事务会话信息内存中读写并长久化本地文件root.data，性能较高;

db模式为高可用模式，全局事务会话信息通过db共享，相应性能差些;

redis模式Seata-Server 1.3及以上版本反对,性能较高,存在事务信息失落危险,请提前配置适合以后场景的redis长久化配置.

store {  ## store mode: file、db  mode = "db"  db {    datasource = "druid"    dbType = "mysql"    driverClassName = "com.mysql.jdbc.Driver"    url = "jdbc:mysql://127.0.0.1:3306/seata_server"    user = "root"    password = "123456"    minConn = 5    maxConn = 30    globalTable = "global_table"    branchTable = "branch_table"    lockTable = "lock_table"    queryLimit = 100    maxWait = 5000  }}

registry.conf配置

这里抉择eureka作为注册核心，seata-server也要作为一个服务增加到注册核心，不应用配置核心所以config配置默认即可。

registry {  # file 、nacos 、eureka、redis、zk、consul、etcd3、sofa  type = "eureka"  eureka {    serviceUrl = "http://localhost:8761/eureka"    application = "default"    weight = "1"  }}

3、事务管理表

须要在seata-server即上述配置的MySQL库中建设3张事务管理表：

• 全局事务：global_table
• 分支事务：branch_table
• 全局锁：lock_table
• 事务回滚：undo_log
• SQL脚本：mysql-script目录

4、启动命令

Linux环境：sh seata-server.sh

三、业务服务搭建

1、代码构造

• seata-eureka：注册核心
• seata-order：订单服务
• seata-account：账户服务
• seata-inventor：库存服务
• seata-client：客户端服务
• account-feign：账户Feign接口
• inventory-feign：库存Feign接口
• order-feign：订单Feign接口

申请链路：客户端->订单->账户+库存，测试整个流程的分布式事务问题。

2、数据库构造

• seata_server：seata组件服务端依赖库
• seata_account：模仿账户数据库
• seata_inventor：模仿库存数据库
• seata_order：模仿订单数据库

各个库脚本地位：mysql-script/data-biz.sql

3、启动服务

顺次启动：注册核心，库存服务，账户服务，订单服务，客户端服务；

Eureka服务列表如下：

四、Seata用法详解

1、Seata根底配置

几个根底服务的配置形式一样。

conf配置

file.conf重点关注上面内容，事务组的名称，须要在yml文件中应用。

my_test_tx_group = "default"

registry.conf：是注册核心的抉择。

2、数据库配置

留神这里的事务组名称配置。

spring:  # 事务组的名称  cloud:    alibaba:      seata:        tx-service-group: my_test_tx_group  # 数据源配置  datasource:    type: com.alibaba.druid.pool.DruidDataSource    druid:      driverClassName: com.mysql.jdbc.Driver      url: jdbc:mysql://127.0.0.1:3306/seata_account      username: root      password: 123456

将数据库整体由Seata进行代理治理，外围API：DataSourceProxy。

@Configurationpublic class SeataAccountConfig {    @Value("${spring.application.name}")    private String applicationName;    @Bean    public GlobalTransactionScanner globalTransactionScanner() {        return new GlobalTransactionScanner(applicationName, "test-tx-group");    }    @Bean    @ConfigurationProperties(prefix = "spring.datasource.druid")    public DruidDataSource druidDataSource() {        return new DruidDataSource() ;    }    @Primary    @Bean("dataSource")    public DataSourceProxy dataSourceProxy(DataSource druidDataSource) {        return new DataSourceProxy(druidDataSource);    }    @Bean    public SqlSessionFactory sqlSessionFactory(DataSourceProxy dataSourceProxy)throws Exception{        SqlSessionFactoryBean sqlSessionFactoryBean = new SqlSessionFactoryBean();        sqlSessionFactoryBean.setDataSource(dataSourceProxy);        sqlSessionFactoryBean.setMapperLocations(new PathMatchingResourcePatternResolver()                .getResources("classpath*:/mapper/*.xml"));        sqlSessionFactoryBean.setTransactionFactory(new SpringManagedTransactionFactory());        return sqlSessionFactoryBean.getObject();    }}

3、业务代码

外围注解：GlobalTransactional，治理整体的分布式事务。

@Servicepublic class OrderServiceImpl implements OrderService {    private final Logger LOGGER = LoggerFactory.getLogger(OrderServiceImpl.class);    @Resource    private OrderMapper orderMapper ;    @Resource    private AccountFeign accountFeign ;    @Resource    private InventoryFeign inventoryFeign ;    @GlobalTransactional    @Override    public Integer createOrder(String orderNo) {        LOGGER.info("Order 生成中 "+orderNo);        // 本服务下订单库        Integer insertFlag = orderMapper.insert(orderNo) ;        // 基于feign接口解决账户和库存        accountFeign.updateAccount(10L) ;        inventoryFeign.updateInventory(10) ;        return insertFlag ;    }}

测试流程：在任意服务下抛出异样，察看整体的事务状态，察看是否有整体的事务管制成果。

五、源代码地址

GitHub地址：知了一笑https://github.com/cicadasmile/spring-cloud-baseGitEE地址：知了一笑https://gitee.com/cicadasmile/spring-cloud-base

举荐浏览：架构设计系列