【Seata】1.4.2使用教程和注意事项

2021-07-18T17:23:00
本博客截取自分布式新生电子报道系统

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启动

[scode type="share"]为seata建数据库,导sql[/scode]

  • 这里我依旧在本机上的mysql中建立一个数据库名为seata,导入的sql文件在源码包下的script\server\db\mysql.sql
  • 导入完成后这里建议更改seata数据库中的global_table表的transaction_service_group字段长度改为64,以免全局事务开启时报错提示长度问题
    [scode type="share"]修改两个配置文件file.conf和registry.conf[/scode]
  • 更改服务端包下/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命名空间)
    [scode type="share"]在源码包中修改config.txt,并导入nacos配置中心[/scode]
  • 修改源码包中的/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集群名,也都可以使用同一个,具体的解释官网是这么说的:
    [scode type="blue"]事务分组说明。
    1.事务分组是什么?
    事务分组是seata的资源逻辑,类似于服务实例。在file.conf中的my_test_tx_group就是一个事务分组。
    2.通过事务分组如何找到后端集群?
    首先程序中配置了事务分组(GlobalTransactionScanner 构造方法的txServiceGroup参数),程序会通过用户配置的配置中心去寻找service.vgroupMapping
    .事务分组配置项,取得配置项的值就是TC集群的名称。拿到集群名称程序通过一定的前后缀+集群名称去构造服务名,各配置中心的服务名实现不同。拿到服务名去相应的注册中心去拉取相应服务名的服务列表,获得后端真实的TC服务列表。
    3.为什么这么设计,不直接取服务名?
    这里多了一层获取事务分组到映射集群的配置。这样设计后,事务分组可以作为资源的逻辑隔离单位,当发生故障时可以快速failover。[/scode]
  • 修改完之后打开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就去掉该参数
    [scode type="share"]给需要进行全局事务控制的数据库导入undo_log表[/scode]

    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;

[scode type="share"]双击seata-server.bat启动[/scode]

  • 当然需要先启动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,这样全局的事务就控制住了,真滴方便(但是底层实现确实相当麻烦)。

附录

[scode type="yellow"]问题1:引入seata的项目启动报错,提示数据源方面的问题[/scode]

  • 我的数据源使用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();
    //    }
    }
  • 为什么最后那个SqlSessionFactory我给注掉了,因为我使用MyBatis Plus的注解形式开发,不用xml,所以注掉了。而且不注的话会报ibatis的绑定错误。
  • (当然以上问题有些人不会遇到,暂时我还不知道原因)
当前页面是本站的「Baidu MIP」版。发表评论请点击:完整版 »