【Seata】seata的部署和集成

深藏阁楼爱情的钟 2024-03-02 10:25 61阅读 0赞

## 一、部署Seata的tc-server ##

### 1.下载 ###

首先我们要下载seata-server包，地址在[http][][://seata.io/zh-cn/blog/download][http][.][http][html][http]

当然，课前资料也准备好了：

![3b73d29c0d274d378b210be83b43d8ed.png][]

### 2.解压 ###

在非中文目录解压缩这个zip包，其目录结构如下：

### ![f1f81f0fabf543789cfeb23b9be3c666.png][] ###

### 3.修改配置 ###

修改conf目录下的registry.conf文件：

![98f025174f414e7d92893a84494ee591.png][]

内容如下：

registry {
      # tc服务的注册中心类，这里选择nacos，也可以是eureka、zookeeper等
      type = "nacos"
    
      nacos {
        # seata tc 服务注册到 nacos的服务名称，可以自定义
        application = "seata-tc-server"
        serverAddr = "127.0.0.1:8848"
        group = "DEFAULT_GROUP"
        namespace = ""
        cluster = "SH"
        username = "nacos"
        password = "nacos"
      }
    }
    
    config {
      # 读取tc服务端的配置文件的方式，这里是从nacos配置中心读取，这样如果tc是集群，可以共享配置
      type = "nacos"
      # 配置nacos地址等信息
      nacos {
        serverAddr = "127.0.0.1:8848"
        namespace = ""
        group = "SEATA_GROUP"
        username = "nacos"
        password = "nacos"
        dataId = "seataServer.properties"
      }
    }

### 4.在nacos添加配置 ###

特别注意，为了让tc服务的集群可以共享配置，我们选择了nacos作为统一配置中心。因此服务端配置文件seataServer.properties文件需要在nacos中配好。

格式如下：

![b019e8af6c7b4718b933599e7b083803.png][]

配置内容如下：

# 数据存储方式，db代表数据库
    store.mode=db
    store.db.datasource=druid
    store.db.dbType=mysql
    store.db.driverClassName=com.mysql.jdbc.Driver
    store.db.url=jdbc:mysql://127.0.0.1:3306/seata?useUnicode=true&rewriteBatchedStatements=true
    store.db.user=root
    store.db.password=123
    store.db.minConn=5
    store.db.maxConn=30
    store.db.globalTable=global_table
    store.db.branchTable=branch_table
    store.db.queryLimit=100
    store.db.lockTable=lock_table
    store.db.maxWait=5000
    # 事务、日志等配置
    server.recovery.committingRetryPeriod=1000
    server.recovery.asynCommittingRetryPeriod=1000
    server.recovery.rollbackingRetryPeriod=1000
    server.recovery.timeoutRetryPeriod=1000
    server.maxCommitRetryTimeout=-1
    server.maxRollbackRetryTimeout=-1
    server.rollbackRetryTimeoutUnlockEnable=false
    server.undo.logSaveDays=7
    server.undo.logDeletePeriod=86400000
    
    # 客户端与服务端传输方式
    transport.serialization=seata
    transport.compressor=none
    # 关闭metrics功能，提高性能
    metrics.enabled=false
    metrics.registryType=compact
    metrics.exporterList=prometheus
    metrics.exporterPrometheusPort=9898

==其中的数据库地址、用户名、密码都需要修改成你自己的数据库信息。==

### 5.创建数据库表 ###

特别注意：tc服务在管理分布式事务时，需要记录事务相关数据到数据库中，你需要提前创建好这些表。

新建一个名为seata的数据库，运行课前资料提供的sql文件：

![528c796e4201424e9a7cca758735f55f.png][]

这些表主要记录全局事务、分支事务、全局锁信息：

SET NAMES utf8mb4;
    SET FOREIGN_KEY_CHECKS = 0;
    
    -- ----------------------------
    -- 分支事务表
    -- ----------------------------
    DROP TABLE IF EXISTS `branch_table`;
    CREATE TABLE `branch_table`  (
      `branch_id` bigint(20) NOT NULL,
      `xid` varchar(128) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL,
      `transaction_id` bigint(20) NULL DEFAULT NULL,
      `resource_group_id` varchar(32) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
      `resource_id` varchar(256) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
      `branch_type` varchar(8) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
      `status` tinyint(4) NULL DEFAULT NULL,
      `client_id` varchar(64) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
      `application_data` varchar(2000) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
      `gmt_create` datetime(6) NULL DEFAULT NULL,
      `gmt_modified` datetime(6) NULL DEFAULT NULL,
      PRIMARY KEY (`branch_id`) USING BTREE,
      INDEX `idx_xid`(`xid`) USING BTREE
    ) ENGINE = InnoDB CHARACTER SET = utf8 COLLATE = utf8_general_ci ROW_FORMAT = Compact;
    
    -- ----------------------------
    -- 全局事务表
    -- ----------------------------
    DROP TABLE IF EXISTS `global_table`;
    CREATE TABLE `global_table`  (
      `xid` varchar(128) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL,
      `transaction_id` bigint(20) NULL DEFAULT NULL,
      `status` tinyint(4) NOT NULL,
      `application_id` varchar(32) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
      `transaction_service_group` varchar(32) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
      `transaction_name` varchar(128) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
      `timeout` int(11) NULL DEFAULT NULL,
      `begin_time` bigint(20) NULL DEFAULT NULL,
      `application_data` varchar(2000) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
      `gmt_create` datetime NULL DEFAULT NULL,
      `gmt_modified` datetime NULL DEFAULT NULL,
      PRIMARY KEY (`xid`) USING BTREE,
      INDEX `idx_gmt_modified_status`(`gmt_modified`, `status`) USING BTREE,
      INDEX `idx_transaction_id`(`transaction_id`) USING BTREE
    ) ENGINE = InnoDB CHARACTER SET = utf8 COLLATE = utf8_general_ci ROW_FORMAT = Compact;
    
    SET FOREIGN_KEY_CHECKS = 1;

### 6.启动TC服务 ###

进入bin目录，运行其中的seata-server.bat即可：

![5ad638e423e6491cb8b157a11bef5232.png][]

启动成功后，seata-server应该已经注册到nacos注册中心了。

打开浏览器，访问nacos地址：[http://localhost:8848][http_localhost_8848]，然后进入服务列表页面，可以看到seata-tc-server的信息：

![f61131d01c044b08a804334016b01a7b.png][]

## 二、微服务集成seata ##

### 1.引入依赖 ###

首先，我们需要在微服务中引入seata依赖：

<dependency>
        <groupId>com.alibaba.cloud</groupId>
        <artifactId>spring-cloud-starter-alibaba-seata</artifactId>
        <exclusions>
            
            <exclusion>
                <artifactId>seata-spring-boot-starter</artifactId>
                <groupId>io.seata</groupId>
            </exclusion>
        </exclusions>
    </dependency>
    
    <dependency>
        <groupId>io.seata</groupId>
        <artifactId>seata-spring-boot-starter</artifactId>
        <version>${seata.version}</version>
    </dependency>

### 2.修改配置文件 ###

需要修改application.yml文件，添加一些配置：

seata:
      registry: # TC服务注册中心的配置，微服务根据这些信息去注册中心获取tc服务地址
        # 参考tc服务自己的registry.conf中的配置
        type: nacos
        nacos: # tc
          server-addr: 127.0.0.1:8848
          namespace: ""
          group: DEFAULT_GROUP
          application: seata-tc-server # tc服务在nacos中的服务名称
          cluster: SH
      tx-service-group: seata-demo # 事务组，根据这个获取tc服务的cluster名称
      service:
        vgroup-mapping: # 事务组与TC服务cluster的映射关系
          seata-demo: SH

## 三、TC服务的高可用和异地容灾 ##

### 1.模拟异地容灾的TC集群 ###

计划启动两台seata的tc服务节点：

<table> 
 <thead> 
  <tr> 
   <th>节点名称</th> 
   <th>ip地址</th> 
   <th>端口号</th> 
   <th>集群名称</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>seata</td> 
   <td>127.0.0.1</td> 
   <td>8091</td> 
   <td>SH</td> 
  </tr> 
  <tr> 
   <td>seata2</td> 
   <td>127.0.0.1</td> 
   <td>8092</td> 
   <td>HZ</td> 
  </tr> 
 </tbody> 
</table>

之前我们已经启动了一台seata服务，端口是8091，集群名为SH。

现在，将seata目录复制一份，起名为seata2

修改seata2/conf/registry.conf内容如下：

registry {
      # tc服务的注册中心类，这里选择nacos，也可以是eureka、zookeeper等
      type = "nacos"
    
      nacos {
        # seata tc 服务注册到 nacos的服务名称，可以自定义
        application = "seata-tc-server"
        serverAddr = "127.0.0.1:8848"
        group = "DEFAULT_GROUP"
        namespace = ""
        cluster = "HZ"
        username = "nacos"
        password = "nacos"
      }
    }
    
    config {
      # 读取tc服务端的配置文件的方式，这里是从nacos配置中心读取，这样如果tc是集群，可以共享配置
      type = "nacos"
      # 配置nacos地址等信息
      nacos {
        serverAddr = "127.0.0.1:8848"
        namespace = ""
        group = "SEATA_GROUP"
        username = "nacos"
        password = "nacos"
        dataId = "seataServer.properties"
      }
    }

进入seata2/bin目录，然后运行命令：

seata-server.bat -p 8092

打开nacos控制台，查看服务列表：

![042f1f481069454a9f23b82f91ccac0e.png][]点进详情查看：

![c169fb0c854d4400929b368d8bd4dadf.png][]

### 2.将事务组映射配置到nacos ###

接下来，我们需要将tx-service-group与cluster的映射关系都配置到nacos配置中心。

新建一个配置：

![aa2025238b4243a780c957da49b49050.png][]配置的内容如下：

# 事务组映射关系
    service.vgroupMapping.seata-demo=SH
    
    service.enableDegrade=false
    service.disableGlobalTransaction=false
    # 与TC服务的通信配置
    transport.type=TCP
    transport.server=NIO
    transport.heartbeat=true
    transport.enableClientBatchSendRequest=false
    transport.threadFactory.bossThreadPrefix=NettyBoss
    transport.threadFactory.workerThreadPrefix=NettyServerNIOWorker
    transport.threadFactory.serverExecutorThreadPrefix=NettyServerBizHandler
    transport.threadFactory.shareBossWorker=false
    transport.threadFactory.clientSelectorThreadPrefix=NettyClientSelector
    transport.threadFactory.clientSelectorThreadSize=1
    transport.threadFactory.clientWorkerThreadPrefix=NettyClientWorkerThread
    transport.threadFactory.bossThreadSize=1
    transport.threadFactory.workerThreadSize=default
    transport.shutdown.wait=3
    # RM配置
    client.rm.asyncCommitBufferLimit=10000
    client.rm.lock.retryInterval=10
    client.rm.lock.retryTimes=30
    client.rm.lock.retryPolicyBranchRollbackOnConflict=true
    client.rm.reportRetryCount=5
    client.rm.tableMetaCheckEnable=false
    client.rm.tableMetaCheckerInterval=60000
    client.rm.sqlParserType=druid
    client.rm.reportSuccessEnable=false
    client.rm.sagaBranchRegisterEnable=false
    # TM配置
    client.tm.commitRetryCount=5
    client.tm.rollbackRetryCount=5
    client.tm.defaultGlobalTransactionTimeout=60000
    client.tm.degradeCheck=false
    client.tm.degradeCheckAllowTimes=10
    client.tm.degradeCheckPeriod=2000
    
    # undo日志配置
    client.undo.dataValidation=true
    client.undo.logSerialization=jackson
    client.undo.onlyCareUpdateColumns=true
    client.undo.logTable=undo_log
    client.undo.compress.enable=true
    client.undo.compress.type=zip
    client.undo.compress.threshold=64k
    client.log.exceptionRate=100

### 3.微服务读取nacos配置 ###

接下来，需要修改每一个微服务的application.yml文件，让微服务读取nacos中的client.properties文件：

seata:
      config:
        type: nacos
        nacos:
          server-addr: 127.0.0.1:8848
          username: nacos
          password: nacos
          group: SEATA_GROUP
          data-id: client.properties

重启微服务，现在微服务到底是连接tc的SH集群，还是tc的HZ集群，都统一由nacos的client.properties来决定了。

[http]: http://seata.io/zh-cn/blog/download.html
[3b73d29c0d274d378b210be83b43d8ed.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/02/5044a9d578a24c9f8b8101757b7da095.png
[f1f81f0fabf543789cfeb23b9be3c666.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/02/e0437c2f68ef4aa99c0e70d33d48fc97.png
[98f025174f414e7d92893a84494ee591.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/02/9832ce13a7804413b099a80dea4795a9.png
[b019e8af6c7b4718b933599e7b083803.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/02/4833b6c394044783b25ff9ece4733e1a.png
[528c796e4201424e9a7cca758735f55f.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/02/1bec042ba02e4585a57fd7071f4c5fd6.png
[5ad638e423e6491cb8b157a11bef5232.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/02/2379a5a2a3574e8d969501322d705115.png
[http_localhost_8848]: http://localhost:8848
[f61131d01c044b08a804334016b01a7b.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/02/ea88189132d34cbbad81cb26c1a7fc80.png
[042f1f481069454a9f23b82f91ccac0e.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/02/e7c71403df8e4ed68468904084ad0f14.png
[c169fb0c854d4400929b368d8bd4dadf.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/02/a16451582a9f4907bea1635f56afc310.png
[aa2025238b4243a780c957da49b49050.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/02/dfd6d5e9005c44c4a129035e55fc5c1e.png