SpringBoot整合Seata

上一篇 <<<Seata-核心源码分析
下一篇 >>>Seata与Lcn的区别

---

1.事务协调者(TC)启动

A、创建数据库，并执行sql: db_store.sql
B、修改 registry.conf和file.conf配置
Registry.conf支持：file 、nacos 、eureka、redis、zk、consul、etcd3、sofa
file.conf：修改db信息
C、seata-server.sh启动脚本

2.发起方TM和参与方RM整合

在关联的数据库里执行db_undo_log.sql后在执行下面操作

2.1 引入jar包依赖

<dependency>
        <groupId>com.alibaba.cloud</groupId>
        <artifactId>spring-cloud-alibaba-seata</artifactId>
        <version>2.1.1.RELEASE</version>
    </dependency>

2.2 配置修改

spring:
  cloud:
    nacos:
      discovery:
        server-addr: 10.211.55.16:8848
        #feign客户端的命名必须使用中划线，不能使用下划线
    refresh:
      enabled: false
      #seata配置
    alibaba:
      seata:
        tx-service-group: my_test_tx_group
  application:
    name: seata-user-service
  datasource:
    url: jdbc:mysql://localhost:3306/jarye?useUnicode=true&characterEncoding=UTF-8
    username: root
    password: 123456
    driver-class-name: com.mysql.jdbc.Driver

拷贝registry.conf和file.conf到配置文件地方
其中tx-service-group的配置要和file.conf里的vgroup_mapping名称一致

service { 
  vgroup_mapping.my_test_tx_group = "default" 
  default.grouplist = "127.0.0.1:8091"
}

2.3 剔除默认数据源

//自定义配置
@Configuration
public class DataSourceProxyConfig {

    @Bean
    @ConfigurationProperties(prefix = "spring.datasource")
    public DataSource dataSource() {
        return new DruidDataSource();
    }

    @Bean
    public DataSourceProxy dataSourceProxy(DataSource dataSource) {
        return new DataSourceProxy(dataSource);
    }

    @Bean
    public SqlSessionFactory sqlSessionFactoryBean(DataSourceProxy dataSourceProxy) throws Exception {
        SqlSessionFactoryBean sqlSessionFactoryBean = new SqlSessionFactoryBean();
        sqlSessionFactoryBean.setDataSource(dataSourceProxy);
        sqlSessionFactoryBean.setTransactionFactory(new SpringManagedTransactionFactory());
        return sqlSessionFactoryBean.getObject();
    }
}

启动的地方剔除默认的数据源加载
@SpringBootApplication(exclude = DataSourceAutoConfiguration.class)
@MapperScan("com.jgspx.mapper")
public class SeataUserApp {
    public static void main(String[] args) {
        SpringApplication.run(SeataUserApp.class);
    }
}

2.4 注解使用

只要在发起方增加注解，参与方不用任何注解

@GlobalTransactional
@GetMapping("/orderToMember")
public String orderToMember(Long userId) {
    orderMapper.insertUser(userId+"");
    String result = userServiceFeign.getUser(userId);
    return "我是订单服务，调用会员服务接口返回结果:" + result;
}

2.5 通过日志来验证

当出现异常或超时，日志信息：
Branch Rollbacked result: PhaseTwo_Rollbacked
当执行成功，日志信息：
Branch commit result: PhaseTwo_Committed

---

推荐阅读：
<<<分布式事务产生的背景
<<<解决分布式事务的核心思路
<<<柔性事务和刚性事务(ACID)
<<<CAP理论简单概况
<<<Base理论核心思想
<<<一致性协议--XA接口
<<<一致性协议--Jta规范
<<<一致性协议--2PC提交协议
<<<一致性协议--3PC提交协议
<<<2PC与3PC协议的提交区别
<<<主流的分布式事务解决框架
<<<LCN-框架介绍
<<<LCN-实现原理剖析
<<<LCN-事务协调者(TM)安装启动
<<<SpringBoot整合LCN
<<<LCN-核心源码分析
<<<LCN-集群模式介绍
<<<Seata-框架介绍
<<<Seata原理实现/执行流程/生命周期
<<<Seata-TM执行时突然宕机了会造成什么问题
<<<Seata-核心源码分析
<<<Seata与Lcn的区别