服务端搭建

Docker-compose编排服务

注意: 1.5.1不支持mysql8 从1.5.2开始支持mysql8

version: '3'  seata-server:    image: seataio/seata-server:1.5.2    container_name: seata-server    ports:      - "7091:7091"      - "8091:8091"    environment:      - TZ=Asia/Shanghai      - SEATA_IP=IP地址(注意 这里要填可以访问的ip)      - SEATA_PORT=8091    volumes:    # 配置文件目录映射      - /docker/seata/config/application.yml:/seata-server/resources/application.yml

application.yml 配置文件

server:  port: 7091spring:  application:    name: seata-serverlogging:  config: classpath:logback-spring.xml  file:    path: ./logs/seata#  extend:#    logstash-appender:#      destination: 127.0.0.1:4560#    kafka-appender:#      bootstrap-servers: 127.0.0.1:9092#      topic: logback_to_logstashconsole:  user:    username: seata    passWord: seataseata:  config:    # support: Nacos 、 consul 、 apollo 、 zk  、 etcd3    type: nacos    nacos:      # nacos ip地址      server-addr: 127.0.0.1:8848      group: DEFAULT_GROUP      namespace:       username:      password:      ##if use MSE Nacos with auth, mutex with username/password attribute      #access-key: ""      #secret-key: ""      # 读取nacos上的配置文件      data-id: seata-server.properties  reGIStry:    # support: nacos 、 eureka 、 Redis 、 zk  、 consul 、 etcd3 、 sofa    type: nacos    nacos:      application: seata-server      # nacos ip地址      server-addr: 127.0.0.1:8848      group: DEFAULT_GROUP      namespace:       cluster: default      username:      password:      ##if use MSE Nacos with auth, mutex with username/password attribute      #access-key: ""      #secret-key: ""  security:    secreTKEy: SeataSecretKey0c382ef121d778043159209298fd40bf3850a017    tokenValidityInMilliseconds: 1800000    ignore:      urls: /,/***.js,/***.map,/***.png,/**/*.ico,/console-fe/public/**,/api/v1/auth/login

seata-server.properties 配置文件

再nacos创建 seata-server.properties 配置文件
修改其中的 Mysql 连接地址

service.vgroupMapping.default-tx-group=defaultservice.enableDegrade=falseservice.disableGlobalTransaction=false#Transaction storage configuration, only for the server. The file, DB, and redis configuration values are optional.store.mode=dbstore.lock.mode=dbstore.session.mode=db#Used for password encryptionstore.publicKey=#These configurations are required if the `store mode` is `db`. If `store.mode,store.lock.mode,store.session.mode` are not equal to `db`, you can remove the configuration block.store.db.datasource=druidstore.db.dbType=mysqlstore.db.driverClassName=com.mysql.cj.jdbc.Driverstore.db.url=jdbc:mysql://127.0.0.1:3306/seata?useUnicode=true&rewriteBatchedStatements=truestore.db.user=rootstore.db.password=rootstore.db.minConn=5store.db.maxConn=30store.db.globalTable=global_tablestore.db.branchTable=branch_tablestore.db.distributedLockTable=distributed_lockstore.db.queryLimit=100store.db.lockTable=lock_tablestore.db.maxWait=5000#Transaction rule configuration, only for the serverserver.recovery.committingRetryPeriod=1000server.recovery.asynCommittingRetryPeriod=1000server.recovery.rollbackingRetryPeriod=1000server.recovery.timeoutRetryPeriod=1000server.maxCommitRetryTimeout=-1server.maxRollbackRetryTimeout=-1server.rollbackRetryTimeoutUnlockEnable=falseserver.distributedLockExpireTime=10000server.xaerNotaRetryTimeout=60000server.session.branchAsyncQueueSize=5000server.session.enableBranchAsyncRemove=false#Transaction rule configuration, only for the clientclient.rm.asyncCommitBufferLimit=10000client.rm.lock.retryInterval=10client.rm.lock.retryTimes=30client.rm.lock.retryPolicyBranchRollbackOnConflict=trueclient.rm.reportRetryCount=5client.rm.tableMetaCheckEnable=trueclient.rm.tableMetaCheckerInterval=60000client.rm.sqlParserType=druidclient.rm.reportSuccessEnable=falseclient.rm.sagaBranchRegisterEnable=falseclient.rm.sagaJSONParser=fastjsonclient.rm.tccActionInterceptorOrder=-2147482648client.tm.commitRetryCount=5client.tm.rollbackRetryCount=5client.tm.defaultGlobalTransactionTimeout=60000client.tm.degradeCheck=falseclient.tm.degradeCheckAllowTimes=10client.tm.degradeCheckPeriod=2000client.tm.interceptorOrder=-2147482648client.undo.dataValidation=trueclient.undo.logSerialization=jacksonclient.undo.onlyCareUpdateColumns=trueserver.undo.logSaveDays=7server.undo.logDeletePeriod=86400000client.undo.logTable=undo_loGClient.undo.compress.enable=trueclient.undo.compress.type=zipclient.undo.compress.threshold=64k#For TCC transaction modetcc.fence.logTableName=tcc_fence_logtcc.fence.cleanPeriod=1h#Log rule configuration, for client and serverlog.exceptionRate=100#Metrics configuration, only for the servermetrics.enabled=falsemetrics.registryType=compactmetrics.exporterList=prometheusmetrics.exporterPrometheusPort=9898#For details about configuration items, see https://seata.io/zh-cn/docs/user/configurations.html#Transport configuration, for client and servertransport.type=tcptransport.server=NIOtransport.heartbeat=truetransport.enableTmClientBatchSendRequest=falsetransport.enableRmClientBatchSendRequest=truetransport.enableTcServerBatchSendResponse=falsetransport.rpcRmRequestTimeout=30000transport.rpcTmRequestTimeout=30000transport.rpcTcRequestTimeout=30000transport.threadFactory.bossThreadPrefix=NettyBosstransport.threadFactory.workerThreadPrefix=NettyServerNIOWorkertransport.threadFactory.serverExecutorThreadPrefix=NettyServerBizHandlertransport.threadFactory.shareBossWorker=falsetransport.threadFactory.clientSelectorThreadPrefix=NettyClientSelectortransport.threadFactory.clientSelectorThreadSize=1transport.threadFactory.clientWorkerThreadPrefix=NettyClientWorkerThreadtransport.threadFactory.bossThreadSize=1transport.threadFactory.workerThreadSize=defaulttransport.shutdown.wait=3transport.serialization=seatatransport.compressor=none

初始化数据库

-- -------------------------------- The script used when storeMode is 'db' ---------------------------------- the table to store GlobalSession dataCREATE TABLE IF NOT EXISTS `global_table`(    `xid`                       VARCHAR(128) NOT NULL,    `transaction_id`            BIGINT,    `status`                    TINYINT      NOT NULL,    `application_id`            VARCHAR(32),    `transaction_service_group` VARCHAR(32),    `transaction_name`          VARCHAR(128),    `timeout`                   INT,    `begin_time`                BIGINT,    `application_data`          VARCHAR(2000),    `gmt_create`                DATETIME,    `gmt_modified`              DATETIME,    PRIMARY KEY (`xid`),    KEY `idx_status_gmt_modified` (`status` , `gmt_modified`),    KEY `idx_transaction_id` (`transaction_id`)) ENGINE = InnoDB  DEFAULT CHARSET = utf8mb4;-- the table to store BranchSession dataCREATE TABLE IF NOT EXISTS `branch_table`(    `branch_id`         BIGINT       NOT NULL,    `xid`               VARCHAR(128) NOT NULL,    `transaction_id`    BIGINT,    `resource_group_id` VARCHAR(32),    `resource_id`       VARCHAR(256),    `branch_type`       VARCHAR(8),    `status`            TINYINT,    `client_id`         VARCHAR(64),    `application_data`  VARCHAR(2000),    `gmt_create`        DATETIME(6),    `gmt_modified`      DATETIME(6),    PRIMARY KEY (`branch_id`),    KEY `idx_xid` (`xid`)) ENGINE = InnoDB  DEFAULT CHARSET = utf8mb4;-- the table to store lock dataCREATE TABLE IF NOT EXISTS `lock_table`(    `row_key`        VARCHAR(128) NOT NULL,    `xid`            VARCHAR(128),    `transaction_id` BIGINT,    `branch_id`      BIGINT       NOT NULL,    `resource_id`    VARCHAR(256),    `table_name`     VARCHAR(32),    `pk`             VARCHAR(36),    `status`         TINYINT      NOT NULL DEFAULT '0' COMMENT '0:locked ,1:rollbacking',    `gmt_create`     DATETIME,    `gmt_modified`   DATETIME,    PRIMARY KEY (`row_key`),    KEY `idx_status` (`status`),    KEY `idx_branch_id` (`branch_id`),    KEY `idx_xid_and_branch_id` (`xid` , `branch_id`)) ENGINE = InnoDB  DEFAULT CHARSET = utf8mb4;CREATE TABLE IF NOT EXISTS `distributed_lock`(    `lock_key`       CHAR(20) NOT NULL,    `lock_value`     VARCHAR(20) NOT NULL,    `expire`         BIGINT,    primary key (`lock_key`)) ENGINE = InnoDB  DEFAULT CHARSET = utf8mb4;INSERT INTO `distributed_lock` (lock_key, lock_value, expire) VALUES ('AsyncCommitting', ' ', 0);INSERT INTO `distributed_lock` (lock_key, lock_value, expire) VALUES ('RetryCommitting', ' ', 0);INSERT INTO `distributed_lock` (lock_key, lock_value, expire) VALUES ('RetryRollbacking', ' ', 0);INSERT INTO `distributed_lock` (lock_key, lock_value, expire) VALUES ('TxTimeoutCheck', ' ', 0);

启动 seata 服务端

访问 7091 端口 进入seata 控制台


查看 nacos 服务注册列表

客户端搭建

pom依赖

由于 SpringCloud Alibaba seata 使用的客户端为 1.4.2
故排除依赖 手动引入 1.5.X

<dependencyManagement>        <dependencies>            <dependency>                <groupId>com.alibaba.cloudgroupId>                <artifactId>spring-cloud-alibaba-dependenciesartifactId>                <version>${spring-cloud-alibaba.version}version>                <type>pomtype>                <scope>importscope>            dependency>        dependencies>dependencyManagement>

        <dependency>            <groupId>com.alibaba.cloudgroupId>            <artifactId>spring-cloud-starter-alibaba-nacos-discoveryartifactId>            <exclusions>                <exclusion>                    <groupId>com.alibaba.nacosgroupId>                    <artifactId>nacos-clientartifactId>                exclusion>            exclusions>        dependency>        <dependency>            <groupId>com.alibaba.cloudgroupId>            <artifactId>spring-cloud-starter-alibaba-nacos-configartifactId>        dependency>        <dependency>            <groupId>com.alibaba.nacosgroupId>            <artifactId>nacos-clientartifactId>            <version>2.0.2version>        dependency>        <dependency>            <groupId>com.alibaba.cloudgroupId>            <artifactId>spring-cloud-starter-alibaba-seataartifactId>            <exclusions>                <exclusion>                    <groupId>io.seatagroupId>                    <artifactId>seata-spring-boot-starterartifactId>                exclusion>            exclusions>        dependency><dependency>    <groupId>io.seatagroupId>    <artifactId>seata-spring-boot-starterartifactId>    <version>1.5.2version>dependency>

客户端 application.yml 配置 nacos 连接

# Springspring:  application:    # 应用名称    name: seata-client-demo--- # nacos 配置spring:  cloud:    nacos:      # nacos 服务地址      server-addr: 127.0.0.1:8848      discovery:        # 注册组 要与 seata 相同        group: DEFAULT_GROUP      config:        # 配置组 要与 seata 相同        group: DEFAULT_GROUP  config:    import:      - optional:nacos:seata-client-demo.yml

seata-client-demo.yml 配置文件

在 nacos 创建 seata-client-demo.yml 配置文件 用于编写客户端 seata 配置

# seata配置seata:  enabled: true  application-id: seata-cilent-deme  # Seata 事务组编号，此处需于 seata 相同  tx-service-group: default-tx-group  config:    type: nacos    nacos:      # nacos ip地址      server-addr: 127.0.0.1:8848      group: DEFAULT_GROUP      data-id: seata-server.properties # 读取 nacos seata 配置  registry:    type: nacos    nacos:      application: seata-server # seata 服务名      # nacos ip地址      server-addr: 127.0.0.1:8848      group: DEFAULT_GROUP

数据库配置

在客户端连接的业务数据库 增加 undo_log 表

-- for AT mode you must to init this sql for you business database. the seata server not need it.CREATE TABLE IF NOT EXISTS `undo_log`(    `branch_id`     BIGINT(20)   NOT NULL COMMENT 'branch transaction id',    `xid`           VARCHAR(100) NOT NULL COMMENT 'global transaction id',    `context`       VARCHAR(128) NOT NULL COMMENT 'undo_log context,such as serialization',    `rollback_info` LONGBLOB     NOT NULL COMMENT 'rollback info',    `log_status`    INT(11)      NOT NULL COMMENT '0:nORMal status,1:defense status',    `log_created`   DATETIME(6)  NOT NULL COMMENT 'create datetime',    `log_modified`  DATETIME(6)  NOT NULL COMMENT 'modify datetime',    UNIQUE KEY `ux_undo_log` (`xid`, `branch_id`)) ENGINE = InnoDB    AUTO_INCREMENT = 1    DEFAULT CHARSET = utf8mb4 COMMENT ='AT transaction mode undo table';

代码编写

最初调用方为 事务发起者 需标记 seata 注解

@GlobalTransactional(rollbackFor = Exception.class)

来源地址：https://blog.csdn.net/weixin_40461281/article/details/125077852