SpringCloud Greenwich集成Seata1.2.0详解说明

左手的ㄟ右手 2023-03-02 10:05 32阅读 0赞

Seata

Seata 是一款开源的分布式事务解决方案，致力于提供高性能和简单易用的分布式事务服务。Seata 将为用户提供了 AT、TCC、SAGA 和 XA 事务模式，为用户打造一站式的分布式解决方案。

官网&下载地址：http://seata.io/zh-cn/

配置说明：（TC端配置）

1.下载运行包，下载地址：https://github.com/seata/seata/releases

Seata分TC、TM和RM三个角色，TC（Server端）为单独服务端部署，TM和RM（Client端）由业务系统集成。

2.修改seata-server-1.2.0\\seata\\conf\\file.conf

主要修改：事务日志存储模式为db，连接数据库

service {
    
    #transaction service group mapping
    
    vgroupMapping.gridcloud_tx_group = "default"
    
    #only support when registry.type=file, please don't set multiple addresses
    
    default.grouplist = "192.168.0.100:8091"
    
    #degrade, current not support
    
    enableDegrade = false
    
    #disable seata
    
    disableGlobalTransaction = false
    
    }
    
    ## transaction log store, only used in seata-server
    
    store {
    
    ## store mode: file、db
    
    mode = "db"
    
    
    
    ## file store property
    
    file {
    
    ## store location dir
    
    dir = "sessionStore"
    
    # branch session size , if exceeded first try compress lockkey, still exceeded throws exceptions
    
    maxBranchSessionSize = 16384
    
    # globe session size , if exceeded throws exceptions
    
    maxGlobalSessionSize = 512
    
    # file buffer size , if exceeded allocate new buffer
    
    fileWriteBufferCacheSize = 16384
    
    # when recover batch read size
    
    sessionReloadReadSize = 100
    
    # async, sync
    
    flushDiskMode = async
    
    }
    
    
    
    ## database store property
    
    db {
    
    ## the implement of javax.sql.DataSource, such as DruidDataSource(druid)/BasicDataSource(dbcp) etc.
    
    datasource = "druid"
    
    ## mysql/oracle/postgresql/h2/oceanbase etc.
    
    dbType = "mysql"
    
    driverClassName = "com.mysql.jdbc.Driver"
    
    url = "jdbc:mysql://192.168.0.100:3306/seata"
    
    user = "root"
    
    password = "root"
    
    minConn = 5
    
    maxConn = 30
    
    globalTable = "global_table"
    
    branchTable = "branch_table"
    
    lockTable = "lock_table"
    
    queryLimit = 100
    
    maxWait = 5000
    
    }
    
    }

3.在mysql中新建库，并配置预装表

注意库要和上面url配置保持一致，默认为：seata

注意Seata1.0以后server包中没有sql表了，具体如下：

db\_store.sql

/*
    
    Navicat MySQL Data Transfer
    
    Source Server : localhost
    Source Server Type : MySQL
    Source Server Version : 50611
    Source Host : localhost:3306
    Source Schema : seata
    
    
    
    Target Server Type : MySQL
    Target Server Version : 50611
    
    File Encoding : 65001
    
    Date: 24/07/2020 11:32:13
    */
    
    SET NAMES utf8mb4;
    SET FOREIGN_KEY_CHECKS = 0;
    
    -- ----------------------------
    
    -- Table structure for branch_table
    
    -- ----------------------------
    
    DROP TABLE IF EXISTS `branch_table`;
    
    CREATE TABLE `branch_table` (
    `branch_id` bigint(20) NOT NULL,
    `xid` varchar(128) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL,
    `transaction_id` bigint(20) NULL DEFAULT NULL,
    `resource_group_id` varchar(32) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL,
    `resource_id` varchar(256) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL,
    `lock_key` varchar(128) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL,
    `branch_type` varchar(8) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL,
    `status` tinyint(4) NULL DEFAULT NULL,
    `client_id` varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL,
    `application_data` varchar(2000) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL,
    `gmt_create` datetime(0) NULL DEFAULT NULL,
    `gmt_modified` datetime(0) NULL DEFAULT NULL,
    PRIMARY KEY (`branch_id`) USING BTREE,
    INDEX `idx_xid`(`xid`) USING BTREE
    ) ENGINE = InnoDB CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci ROW_FORMAT = Compact;
    
    
    
    -- ----------------------------
    
    -- Table structure for global_table
    
    -- ----------------------------
    
    DROP TABLE IF EXISTS `global_table`;
    
    CREATE TABLE `global_table` (
    `xid` varchar(128) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL,
    `transaction_id` bigint(20) NULL DEFAULT NULL,
    `status` tinyint(4) NOT NULL,
    `application_id` varchar(32) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL,
    `transaction_service_group` varchar(32) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL,
    `transaction_name` varchar(128) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL,
    `timeout` int(11) NULL DEFAULT NULL,
    `begin_time` bigint(20) NULL DEFAULT NULL,
    `application_data` varchar(2000) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL,
    `gmt_create` datetime(0) NULL DEFAULT NULL,
    `gmt_modified` datetime(0) 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 = utf8mb4 COLLATE = utf8mb4_general_ci ROW_FORMAT = Compact;
    
    
    
    -- ----------------------------
    
    -- Table structure for lock_table
    
    -- ----------------------------
    
    DROP TABLE IF EXISTS `lock_table`;
    
    CREATE TABLE `lock_table` (
    `row_key` varchar(128) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL,
    `xid` varchar(96) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL,
    `transaction_id` mediumtext CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL,
    `branch_id` mediumtext CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL,
    `resource_id` varchar(256) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL,
    `table_name` varchar(32) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL,
    `pk` varchar(36) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL,
    `gmt_create` datetime(0) NULL DEFAULT NULL,
    `gmt_modified` datetime(0) NULL DEFAULT NULL,
    PRIMARY KEY (`row_key`) USING BTREE
    ) ENGINE = InnoDB CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci ROW_FORMAT = Compact;
    
    
    SET FOREIGN_KEY_CHECKS = 1;

4.修改注册配置信息，seata-server-1.2.0\\seata\\conf\\registry.conf

registry {
    
    # file 、nacos 、eureka、redis、zk、consul、etcd3、sofa
    type = "nacos"
    
    nacos {
    application = "seata-server"
    serverAddr = "192.168.0.100:8848"
    namespace = ""
    cluster = "default"
    username = ""
    password = ""
    }
    
    eureka {
    serviceUrl = "http://localhost:8761/eureka"
    application = "default"
    weight = "1"
    }
    
    redis {
    serverAddr = "localhost:6379"
    db = 0
    password = ""
    cluster = "default"
    timeout = 0
    }
    
    zk {
    cluster = "default"
    serverAddr = "127.0.0.1:2181"
    sessionTimeout = 6000
    connectTimeout = 2000
    username = ""
    password = ""
    }
    
    consul {
    cluster = "default"
    serverAddr = "127.0.0.1:8500"
    }
    
    etcd3 {
    cluster = "default"
    serverAddr = "http://localhost:2379"
    }
    
    sofa {
    serverAddr = "127.0.0.1:9603"
    application = "default"
    region = "DEFAULT_ZONE"
    datacenter = "DefaultDataCenter"
    cluster = "default"
    group = "SEATA_GROUP"
    addressWaitTime = "3000"
    }
    
    file {
    name = "file.conf"
    }
    
    }
    
    config {
    
    # file、nacos 、apollo、zk、consul、etcd3
    type = "file"
    
    nacos {
    serverAddr = "192.168.0.100:8848"
    namespace = ""
    group = "SEATA_GROUP"
    username = ""
    password = ""
    }
    
    consul {
    serverAddr = "127.0.0.1:8500"
    }
    
    apollo {
    appId = "seata-server"
    apolloMeta = "http://192.168.1.204:8801"
    namespace = "application"
    }
    
    zk {
    serverAddr = "127.0.0.1:2181"
    sessionTimeout = 6000
    connectTimeout = 2000
    username = ""
    password = ""
    }
    
    etcd3 {
    serverAddr = "http://localhost:2379"
    }
    
    file {
    name = "file.conf"
    }
    
    }

这里配置注册中心为nacos，以及修改nacos连接地址信息

5.server配置完成。上传配置好的文件到centos，并启动

启动脚本在如下路径

seata-server-1.2.0\\seata\\bin

启动完成后，会自动注册到nacos.

3.并在每个rm库中建立回滚日志表

CREATE TABLE `undo_log` (
    `id` bigint(20) NOT NULL AUTO_INCREMENT,
    `branch_id` bigint(20) NOT NULL,
    `xid` varchar(100) NOT NULL,
    `context` varchar(128) NOT NULL,
    `rollback_info` longblob NOT NULL,
    `log_status` int(11) NOT NULL,
    `log_created` datetime NOT NULL,
    `log_modified` datetime NOT NULL,
    `ext` varchar(100) DEFAULT NULL,
    PRIMARY KEY (`id`),
    UNIQUE KEY `ux_undo_log` (`xid`,`branch_id`)
    ) ENGINE=InnoDB DEFAULT CHARSET=utf8;

4.新建工程和配置工程

每个rm application.yml 都需要如下配置

seata:
    application-id: ${spring.application.name}
    tx-service-group: gridcloud_tx_group
    
    # 服务配置项
    service:
    
    # 虚拟组和分组的映射 1.0.0以上将vgroup-mapping 改为 vgroupMapping,
    vgroupMapping:
    
    # 此处Key对应 tx-service-group 的 Value, 此处 value 默认 default
    gridcloud_tx_group: default
    
    # 分组和 Seata 服务的映射 默认端口8091
    grouplist:
    default: 192.168.0.100:8091

工程根pom文件内容

<dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-dependencies</artifactId>
        <version>2.1.4.RELEASE</version>
        <type>pom</type>
        <scope>import</scope>
    </dependency>
    
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-dependencies</artifactId>
        <version>Greenwich.RELEASE</version>
        <type>pom</type>
        <scope>import</scope>
    </dependency>
    
    <dependency>
        <groupId>com.alibaba.cloud</groupId>
        <artifactId>spring-cloud-alibaba-dependencies</artifactId>
        <version>2.1.2.RELEASE</version>
        <type>pom</type>
        <scope>import</scope>
    </dependency>
    
    
    rm pom 文件内容
    
    <dependency>
        <groupId>com.alibaba.cloud</groupId>
        <artifactId>spring-cloud-starter-alibaba-seata</artifactId>
        <exclusions>
            <exclusion>
                <groupId>io.seata</groupId>
                <artifactId>seata-all</artifactId>
            </exclusion>
            <exclusion>
                <groupId>io.seata</groupId>
                <artifactId>seata-spring-boot-starter</artifactId>
            </exclusion>
        </exclusions>
    </dependency>
    <dependency>
        <groupId>io.seata</groupId>
        <artifactId>seata-spring-boot-starter</artifactId>
        <version>1.2.0</version>
    </dependency>