[知识总结] 【Seata】1.4.2使用教程和注意事项

作者：CC下载站日期：2021-07-18 05:23:00 浏览：71 分类：编程开发

本博客截取自分布式新生电子报道系统

Seata搭建

我使用的版本是1.4.2的，还是比较麻烦的，需要下载源码包seata-1.4.2.zip和服务端包seata-server-1.4.2。
仅服务端的前期工作一共要做5件事：
- 为seata建数据库，导sql
- 修改两个配置文件file.conf和registry.conf
- 在源码包中修改config.txt，并导入nacos配置中心（建议单独给seata建立命名空间）
- 给需要进行全局事务控制的数据库导入undo_log表
- 双击seata-server.bat启动

为seata建数据库，导sql

这里我依旧在本机上的mysql中建立一个数据库名为seata，导入的sql文件在源码包下的script\server\db\mysql.sql
导入完成后这里建议更改seata数据库中的global_table表的transaction_service_group字段长度改为64，以免全局事务开启时报错提示长度问题
修改两个配置文件file.conf和registry.conf

更改服务端包下/conf/file.conf，主要修改：

mode = "db"
db {
  datasource = "druid"
  dbType = "mysql"
  ## mysql 8.0
  driverClassName = "com.mysql.cj.jdbc.Driver"
  url = "jdbc:mysql://localhost:3306/seata?useUnicode=true&characterEncoding=UTF-8&useJDBCCompliantTimezoneShift=true&useLegacyDatetimeCode=false&serverTimezone=UTC&useSSL=false&allowPublicKeyRetrieval=true&rewriteBatchedStatements=true"
  user = "root"
  password = "12345"
  minConn = 5
  maxConn = 100
  globalTable = "global_table"
  branchTable = "branch_table"
  lockTable = "lock_table"
  queryLimit = 100
  maxWait = 5000
}

更改服务端包下/conf/registry.conf，主要修改：

registry {
  type = "nacos"

  nacos {
  application = "seata-server"
  serverAddr = "127.0.0.1:8848"
  group = "SEATA_GROUP"
  namespace = "21e2fe2e-3d5e-449b-9ff2-a87a9345742e"
  cluster = "default"
  username = "nacos"
  password = "nacos"
}
}
config {
type = "nacos"

nacos {
  serverAddr = "127.0.0.1:8848"
  namespace = "21e2fe2e-3d5e-449b-9ff2-a87a9345742e"
  group = "SEATA_GROUP"
  username = "nacos"
  password = "nacos"
  dataId = "seataServer.properties"
}

其中21e2fe2e-3d5e-449b-9ff2-a87a9345742e是我单独在nacos中建立的命名空间，用于之后导入seata配置（配置内容比较多，多达9页，默认全部导入public命名空间）
在源码包中修改config.txt，并导入nacos配置中心

修改源码包中的/script/config-center/config.txt：

store.mode=db
store.db.datasource=druid
store.db.dbType=mysql
store.db.driverClassName=com.mysql.cj.jdbc.Driver
store.db.url=jdbc:mysql://localhost:3306/seata?useUnicode=true&characterEncoding=UTF-8&useJDBCCompliantTimezoneShift=true&useLegacyDatetimeCode=false&serverTimezone=UTC&useSSL=false&allowPublicKeyRetrieval=true&rewriteBatchedStatements=true
store.db.user=root
store.db.password=12345

其余尽量不要修改，大家额外需要关注的一个参数是service.vgroupMapping.my_test_tx_group=default，其中my_test_tx_group即为分布式事务中的TC集群名称，可以是自定义的，比如my_dev_tx_group等等，也可以多加几个不同的：
```
service.vgroupMapping.seata-storage-service-group=default
service.vgroupMapping.seata-account-service-group=default
service.vgroupMapping.seata-order-service-group=default
```
这些都会导入到nacos配置中心，我们在那里也可以修改，但要保证项目中的yml里的tx-service-group:后面的值需要和nacos里面的TC集群名保持一致，例如nacos里有 service.vgroupMapping.my_test_tx_group，这里就需要填写tx-service-group: my_test_tx_group。
可以多个服务都用不同的TC集群名，也都可以使用同一个，具体的解释官网是这么说的：
事务分组说明。
1.事务分组是什么？
事务分组是seata的资源逻辑，类似于服务实例。在file.conf中的my_test_tx_group就是一个事务分组。
2.通过事务分组如何找到后端集群？
首先程序中配置了事务分组（GlobalTransactionScanner 构造方法的txServiceGroup参数），程序会通过用户配置的配置中心去寻找service.vgroupMapping
.事务分组配置项，取得配置项的值就是TC集群的名称。拿到集群名称程序通过一定的前后缀+集群名称去构造服务名，各配置中心的服务名实现不同。拿到服务名去相应的注册中心去拉取相应服务名的服务列表，获得后端真实的TC服务列表。
3.为什么这么设计，不直接取服务名？
这里多了一层获取事务分组到映射集群的配置。这样设计后，事务分组可以作为资源的逻辑隔离单位，当发生故障时可以快速failover。

修改完之后打开GitBash，打开到目录script\config-center\nacos下，运行

sh nacos-config.sh -h localhost -p 8848 -g SEATA_GROUP -t 21e2fe2e-3d5e-449b-9ff2-a87a9345742e -u nacos -w nacos

其中-t后是命名空间，如果你使用默认的public就去掉该参数
给需要进行全局事务控制的数据库导入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) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL,
`context` varchar(128) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL,
`rollback_info` longblob NOT NULL,
`log_status` int NOT NULL,
`log_created` datetime(0) NOT NULL,
`log_modified` datetime(0) NOT NULL,
`ext` varchar(100) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
PRIMARY KEY (`id`) USING BTREE,
UNIQUE INDEX `ux_undo_log`(`xid`, `branch_id`) USING BTREE
) ENGINE = InnoDB CHARACTER SET = utf8 COLLATE = utf8_general_ci ROW_FORMAT = Dynamic;SET FOREIGN_KEY_CHECKS = 1;

双击seata-server.bat启动

当然需要先启动nacos。

结果

@Service
@Slf4j
@RequiredArgsConstructor
public class StudentPraiseServiceImpl extends ServiceImpl<StudentPraiseMapper, StudentPraise> implements IStudentPraiseService {

    private final StudentPraiseMapper studentPraiseMapper;

    //erc-student模块的服务
    private final IStudentsService studentsService;

    //erc-openid模块的服务
    private final IOpenIdService openIdService;

    @Override
    @GlobalTransactional
    public Boolean clickWish( String cartId, String openId ) {
        log.info("【学生身份证为：】" + cartId + "【当前用户的openid为】" + openId);
        Integer openIdCount = openIdService.selectCount(openId);
        .......
    }
}

由于这个方法牵扯到其他服务对数据库的写操作，所以这里在方法上加上seata的@GlobalTransactional，这样全局的事务就控制住了，真滴方便（但是底层实现确实相当麻烦）。

附录

问题1：引入seata的项目启动报错，提示数据源方面的问题

我的数据源使用druid，数据库是mysql。
其实这个问题当时我遇到的时候也是挺蒙的，排查了好久，发现是数据源代理的问题，当我在yml中把seata下的enable-auto-data-source-proxy: 改为了false，服务可以正常启动了，但是测试的时候发现事务控制不住，加了@GlobalTransactional，而且seata控制台也输出rollback successfully了吗，但是事务确实没回滚。

之后从github官网的例子上看到需要加上配置类：

@Configuration
public class SeataDataSourceAutoConfig {
  @Autowired
  private DataSourceProperties dataSourceProperties;

  @Bean
  @Primary
  public DruidDataSource druidDataSource(){
      DruidDataSource druidDataSource = new DruidDataSource();
      druidDataSource.setUrl(dataSourceProperties.getUrl());
      druidDataSource.setUsername(dataSourceProperties.getUsername());
      druidDataSource.setPassword(dataSourceProperties.getPassword());
      druidDataSource.setDriverClassName(dataSourceProperties.getDriverClassName());
      druidDataSource.setInitialSize(0);
      druidDataSource.setMaxActive(180);
      druidDataSource.setMaxWait(60000);
      druidDataSource.setMinIdle(0);
      druidDataSource.setValidationQuery("Select 1 from DUAL");
      druidDataSource.setTestOnBorrow(false);
      druidDataSource.setTestOnReturn(false);
      druidDataSource.setTestWhileIdle(true);
      druidDataSource.setTimeBetweenEvictionRunsMillis(60000);
      druidDataSource.setMinEvictableIdleTimeMillis(25200000);
      druidDataSource.setRemoveAbandoned(true);
      druidDataSource.setRemoveAbandonedTimeout(1800);
      druidDataSource.setLogAbandoned(true);
      return druidDataSource;
  }
  /**
   * init mybatis sqlSessionFactory
   * @Param: dataSourceProxy  datasource proxy
   * @Return: DataSourceProxy  datasource proxy
   */
//    @Bean
//    public SqlSessionFactory sqlSessionFactory(DataSource dataSource) throws Exception {
//        SqlSessionFactoryBean factoryBean = new SqlSessionFactoryBean();
//        factoryBean.setDataSource(dataSource);
//        factoryBean.setMapperLocations(new PathMatchingResourcePatternResolver()
//                .getResources("classpath*:/mapper/*.xml"));
//        return factoryBean.getObject();
//    }
}