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

博主：皆非
发布时间：2021 年 07 月 18 日
2571 次浏览
暂无评论
7661字数
分类：知识总结

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

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

这里我依旧在本机上的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就去掉该参数

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;

当然需要先启动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();
//    }
}

为什么最后那个SqlSessionFactory我给注掉了，因为我使用MyBatis Plus的注解形式开发，不用xml，所以注掉了。而且不注的话会报ibatis的绑定错误。
（当然以上问题有些人不会遇到，暂时我还不知道原因）

最后修改：2021 年 07 月 22 日

发表评论取消回复
使用cookie技术保留您的个人信息以便您下次快速评论，继续评论表示您已同意该条款

评论 *

私密评论

名称 *

🎲

邮箱 *

地址

zuxjvblwjw
你的文章内容非常用心，让人感动。http://www.lgkt...
nttsjitreq
你的才华横溢，让人敬佩。http://www.sdhtsd.com
zlmareqpbb
你的文章内容非常专业，让人佩服。http://www.feic...
mmazzmlkkn
你的才华让人惊叹，你是我的榜样。http://www.shxi...
racponyxjj
你的文章内容非常卖力，让人点赞。http://www.hntd...

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

皆非 • 2021 年 07 月 18 日

<blockquote>
<p>本博客截取自<span class="external-link"><a class="no-external-link" href="https://www.makeyourchoice.cn/archives/266/" target="_blank"><i data-feather="external-link"></i>分布式新生电子报道系统</a></span></p>
</blockquote>
<h2>Seata搭建</h2>
<ul>
<li>我使用的版本是1.4.2的，还是比较麻烦的，需要下载源码包<code>seata-1.4.2.zip</code>和服务端包<code>seata-server-1.4.2</code>。</li>
<li>仅服务端的前期工作一共要做5件事：<ul>
<li>为seata建数据库，导sql</li>
<li>修改两个配置文件file.conf和registry.conf</li>
<li>在源码包中修改config.txt，并导入nacos配置中心（建议单独给seata建立命名空间）</li>
<li>给需要进行全局事务控制的数据库导入undo_log表</li>
<li>双击seata-server.bat启动</li>
</ul>
</li>
</ul>
<p><div class="tip inlineBlock share">

为seata建数据库，导sql
</div></p>
<ul>
<li>
<p>这里我依旧在本机上的mysql中建立一个数据库名为seata，导入的sql文件在源码包下的<code>script\server\db\mysql.sql</code></p>
</li>
<li>
<p>导入完成后这里建议更改seata数据库中的global_table表的transaction_service_group字段长度改为64，以免全局事务开启时报错提示长度问题<br />
<div class="tip inlineBlock share">

修改两个配置文件file.conf和registry.conf
</div></p>
</li>
<li>
<p>更改服务端包下<code>/conf/file.conf</code>，主要修改：</p>
<pre><code class="language-shell">mode = "db"
db {
  datasource = "druid"
  dbType = "mysql"
  ## mysql 8.0
  driverClassName = "com.mysql.cj.jdbc.Driver"
  url = "jdbc:mysql://localhost:3306/seata?useUnicode=true&amp;characterEncoding=UTF-8&amp;useJDBCCompliantTimezoneShift=true&amp;useLegacyDatetimeCode=false&amp;serverTimezone=UTC&amp;useSSL=false&amp;allowPublicKeyRetrieval=true&amp;rewriteBatchedStatements=true"
  user = "root"
  password = "12345"
  minConn = 5
  maxConn = 100
  globalTable = "global_table"
  branchTable = "branch_table"
  lockTable = "lock_table"
  queryLimit = 100
  maxWait = 5000
}</code></pre>
</li>
<li>
<p>更改服务端包下<code>/conf/registry.conf</code>，主要修改：</p>
<pre><code class="language-shell">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"
}</code></pre>
</li>
<li>
<p>其中<code>21e2fe2e-3d5e-449b-9ff2-a87a9345742e</code>是我单独在nacos中建立的命名空间，用于之后导入seata配置（配置内容比较多，多达9页，默认全部导入public命名空间）<br />
<div class="tip inlineBlock share">

在源码包中修改config.txt，并导入nacos配置中心
</div></p>
</li>
<li>
<p>修改源码包中的<code>/script/config-center/config.txt</code>：</p>
<pre><code class="language-shell">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&amp;characterEncoding=UTF-8&amp;useJDBCCompliantTimezoneShift=true&amp;useLegacyDatetimeCode=false&amp;serverTimezone=UTC&amp;useSSL=false&amp;allowPublicKeyRetrieval=true&amp;rewriteBatchedStatements=true
store.db.user=root
store.db.password=12345</code></pre>
</li>
<li>
<p>其余尽量不要修改，大家额外需要关注的一个参数是<code>service.vgroupMapping.my_test_tx_group=default</code>，其中my_test_tx_group即为分布式事务中的<span class="external-link"><a class="no-external-link" href="https://www.makeyourchoice.cn/archives/266/" target="_blank"><i data-feather="external-link"></i>TC集群名称</a></span>，可以是自定义的，比如my_dev_tx_group等等，也可以多加几个不同的：</p>
<pre><code class="language-shell">service.vgroupMapping.seata-storage-service-group=default
service.vgroupMapping.seata-account-service-group=default
service.vgroupMapping.seata-order-service-group=default</code></pre>
</li>
<li>
<p>这些都会导入到nacos配置中心，我们在那里也可以修改，但要保证项目中的yml里的<code>tx-service-group:</code>后面的值需要和nacos里面的TC集群名保持一致，例如nacos里有 <code>service.vgroupMapping.my_test_tx_group</code>，这里就需要填写<code>tx-service-group: my_test_tx_group</code>。</p>
</li>
<li>
<p>可以多个服务都用不同的TC集群名，也都可以使用同一个，具体的解释官网是这么说的：<br />
<div class="tip inlineBlock info">

事务分组说明。<br />
1.事务分组是什么？<br />
事务分组是seata的资源逻辑，类似于服务实例。在file.conf中的my_test_tx_group就是一个事务分组。<br />
2.通过事务分组如何找到后端集群？<br />
首先程序中配置了事务分组（GlobalTransactionScanner 构造方法的txServiceGroup参数），程序会通过用户配置的配置中心去寻找service.vgroupMapping<br />
.事务分组配置项，取得配置项的值就是TC集群的名称。拿到集群名称程序通过一定的前后缀+集群名称去构造服务名，各配置中心的服务名实现不同。拿到服务名去相应的注册中心去拉取相应服务名的服务列表，获得后端真实的TC服务列表。<br />
3.为什么这么设计，不直接取服务名？<br />
这里多了一层获取事务分组到映射集群的配置。这样设计后，事务分组可以作为资源的逻辑隔离单位，当发生故障时可以快速failover。
</div></p>
</li>
<li>
<p>修改完之后打开GitBash，打开到目录<code>script\config-center\nacos</code>下，运行</p>
<pre><code class="language-shell">sh nacos-config.sh -h localhost -p 8848 -g SEATA_GROUP -t 21e2fe2e-3d5e-449b-9ff2-a87a9345742e -u nacos -w nacos</code></pre>
</li>
<li>
<p>其中-t后是命名空间，如果你使用默认的public就去掉该参数<br />
<div class="tip inlineBlock share">

给需要进行全局事务控制的数据库导入undo_log表
</div></p>
<pre><code class="language-sql">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;</code></pre>
</li>
</ul>
<p><div class="tip inlineBlock share">

双击seata-server.bat启动
</div></p>
<ul>
<li>当然需要先启动nacos。</li>
</ul>
<h2>结果</h2>
<pre><code class="language-java">@Service
@Slf4j
@RequiredArgsConstructor
public class StudentPraiseServiceImpl extends ServiceImpl&lt;StudentPraiseMapper, StudentPraise&gt; 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);
        .......
    }
}</code></pre>
<ul>
<li>由于这个方法牵扯到其他服务对数据库的写操作，所以这里在方法上加上seata的<code>@GlobalTransactional</code>，这样全局的事务就控制住了，真滴方便（但是底层实现确实相当麻烦）。</li>
</ul>
<h2>附录</h2>
<p><div class="tip inlineBlock warning">

问题1：引入seata的项目启动报错，提示数据源方面的问题
</div></p>
<ul>
<li>
<p>我的数据源使用druid，数据库是mysql。</p>
</li>
<li>
<p>其实这个问题当时我遇到的时候也是挺蒙的，排查了好久，发现是数据源代理的问题，当我在yml中把seata下的enable-auto-data-source-proxy: 改为了false，服务可以正常启动了，但是测试的时候发现事务控制不住，加了<code>@GlobalTransactional</code>，而且seata控制台也输出rollback successfully了吗，但是事务确实没回滚。</p>
</li>
<li>
<p>之后从github官网的例子上看到需要加上配置类：</p>
<pre><code class="language-java">@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();
//    }
}</code></pre>
</li>
<li>
<p>为什么最后那个SqlSessionFactory我给注掉了，因为我使用MyBatis Plus的注解形式开发，不用xml，所以注掉了。而且不注的话会报ibatis的绑定错误。</p>
</li>
<li>
<p>（当然以上问题有些人不会遇到，暂时我还不知道原因）</p>
</li>
</ul>

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

Seata搭建

结果

附录

发表评论取消回复
使用cookie技术保留您的个人信息以便您下次快速评论，继续评论表示您已同意该条款

美化优化个人网站历程

搭建【分布式新生电子报到系统】过程

从事SQL血缘解析一年后，谈谈我对它的理解

【2021数位板】高漫M7开箱+使用测评——新手入门的上乘之作

2021考研感想——考研失败不是遗憾，没有考研才是遗憾！

有关微软收购Bethesda

第十二届蓝桥杯——Java软件开发（国赛）总结（20210605）

2021年03月日总结

Dubbo + Zookeeper学习

【幽灵行者】在 GTX1050ti 和 i5 7300hq下的表现

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

Seata搭建

结果

附录

发表评论 取消回复 使用cookie技术保留您的个人信息以便您下次快速评论，继续评论表示您已同意该条款

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

发表评论取消回复
使用cookie技术保留您的个人信息以便您下次快速评论，继续评论表示您已同意该条款