09--seata搭建 AT模式及 springcloudAlibaba集成seata

缺乏、安全感 2022-12-23 15:22 174阅读 0赞

[seata官方文档][seata]

1.  下载seata镜像

docker pull seataio/seata-server

1.  创建宿主机映射目录及文件

mkdir /mnt/seata/config
    mkdir registry
    vim registry.conf

1.  registry.conf 配置（使用nacos做为配置，并将seata注册至nacos）

registry {
      type = "nacos"
    
      nacos {   
        application = "serverAddr"
        serverAddr = "nacos-ip"
        group = "DEFAULT_GROUP"
        namespace = ""
        cluster = "default"
        username = "nacos"
        password = "123456"
      }
    }
    
    
    config {
      type = "nacos"
      nacos {
        serverAddr = "nacos-ip"
        group = "SEATA_GROUP"
        namespace = ""
        username = "nacos"
        password = "123456"
      }
    }

springcloudAlibaba 集成seata后，默认的seata服务名称是serverAddr 分组是 DEFAULT\_GROUP。没找到在哪里可以修改的地方。（找到修改后，会更新此文档）。所以我先把application 起名为serverAddr group 为 DEFAULT\_GROUP

1.  将配置上传至nacos

### config.txt nacos 配置 ###

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
    service.vgroupMapping.producer-tx-group=default
    service.vgroupMapping.consumer-tx-group=default
    service.enableDegrade=false
    service.disableGlobalTransaction=false
    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.sqlParserType=druid
    client.rm.reportSuccessEnable=false
    client.rm.sagaBranchRegisterEnable=false
    client.tm.commitRetryCount=5
    client.tm.rollbackRetryCount=5
    client.tm.defaultGlobalTransactionTimeout=60000
    client.tm.degradeCheck=false
    client.tm.degradeCheckAllowTimes=10
    client.tm.degradeCheckPeriod=2000
    store.mode=db
    store.db.datasource=druid
    store.db.dbType=mysql
    store.db.driverClassName=com.mysql.jdbc.Driver
    store.db.url=jdbc:mysql://123.206.19.217:3306/seata?useUnicode=true
    store.db.user=root
    store.db.password=lzq199528
    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
    client.undo.dataValidation=true
    client.undo.logSerialization=jackson
    client.undo.onlyCareUpdateColumns=true
    server.undo.logSaveDays=7
    server.undo.logDeletePeriod=86400000
    client.undo.logTable=undo_log
    client.log.exceptionRate=100
    transport.serialization=seata
    transport.compressor=none
    metrics.enabled=false
    metrics.registryType=compact
    metrics.exporterList=prometheus
    metrics.exporterPrometheusPort=9898

##### [配置文档][Link 1] #####

1. service.vgroupMapping.producer-tx-group=default中的producer-tx-group 和 producer-example 服务中 bootstrap.yml 中的 spring:cloud:alibaba:seata:producer-tx-group 对应
        消费服务也一样
        
        2. seata数据库  
            store.db.url=jdbc:mysql://123.206.19.217:3306/seata?useUnicode=true
            store.db.user=root
            store.db.password=lzq199528

#### 使用脚本上传至nacos ####

sh nacos-config.sh -h 52.83.239.30 -p 8848 -g SEATA_GROUP -u nacos -w 123456

#### nacos-config.sh ####

#!/usr/bin/env bash
    # Copyright 1999-2019 Seata.io Group.
    #
    # Licensed under the Apache License, Version 2.0 (the "License");
    # you may not use this file except in compliance with the License.
    # You may obtain a copy of the License at、
    #
    #      http://www.apache.org/licenses/LICENSE-2.0
    #
    # Unless required by applicable law or agreed to in writing, software
    # distributed under the License is distributed on an "AS IS" BASIS,
    # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
    # See the License for the specific language governing permissions and
    # limitations under the License.
    
    while getopts ":h:p:g:t:u:w:" opt
    do
      case $opt in
      h)
        host=$OPTARG
        ;;
      p)
        port=$OPTARG
        ;;
      g)
        group=$OPTARG
        ;;
      t)
        tenant=$OPTARG
        ;;
      u)
        username=$OPTARG
        ;;
      w)
        password=$OPTARG
        ;;
      ?)
        echo " USAGE OPTION: $0 [-h host] [-p port] [-g group] [-t tenant] [-u username] [-w password] "
        exit 1
        ;;
      esac
    done
    
    if [[ -z ${host} ]]; then
        host=localhost
    fi
    if [[ -z ${port} ]]; then
        port=8848
    fi
    if [[ -z ${group} ]]; then
        group="SEATA_GROUP"
    fi
    if [[ -z ${tenant} ]]; then
        tenant=""
    fi
    if [[ -z ${username} ]]; then
        username=""
    fi
    if [[ -z ${password} ]]; then
        password=""
    fi
    
    nacosAddr=$host:$port
    contentType="content-type:application/json;charset=UTF-8"
    
    echo "set nacosAddr=$nacosAddr"
    echo "set group=$group"
    
    failCount=0
    tempLog=$(mktemp -u)
    function addConfig() {
      curl -X POST -H "${contentType}" "http://$nacosAddr/nacos/v1/cs/configs?dataId=$1&group=$group&content=$2&tenant=$tenant&username=$username&password=$password" >"${tempLog}" 2>/dev/null
      if [[ -z $(cat "${tempLog}") ]]; then
        echo " Please check the cluster status. "
        exit 1
      fi
      if [[ $(cat "${tempLog}") =~ "true" ]]; then
        echo "Set $1=$2 successfully "
      else
        echo "Set $1=$2 failure "
        (( failCount++ ))
      fi
    }
    
    count=0
    for line in $(cat $(dirname "$PWD")/config.txt | sed s/[[:space:]]//g); do
      (( count++ ))
    	key=${line%%=*}
        value=${line#*=}
    	addConfig "${key}" "${value}"
    done
    
    echo "========================================================================="
    echo " Complete initialization parameters,  total-count:$count ,  failure-count:$failCount "
    echo "========================================================================="
    
    if [[ ${failCount} -eq 0 ]]; then
    	echo " Init nacos config finished, please start seata-server. "
    else
    	echo " init nacos config fail. "
    fi

#### seata 表 ####

/* Navicat MySQL Data Transfer Source Server : mysql Source Server Version : 50729 Source Host : 123.206.19.217:3306 Source Database : seata Target Server Type : MYSQL Target Server Version : 50729 File Encoding : 65001 Date: 2020-11-04 17:42:36 */
    
    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) NOT NULL,
      `transaction_id` bigint(20) DEFAULT NULL,
      `resource_group_id` varchar(32) DEFAULT NULL,
      `resource_id` varchar(256) DEFAULT NULL,
      `branch_type` varchar(8) DEFAULT NULL,
      `status` tinyint(4) DEFAULT NULL,
      `client_id` varchar(64) DEFAULT NULL,
      `application_data` varchar(2000) DEFAULT NULL,
      `gmt_create` datetime(6) DEFAULT NULL,
      `gmt_modified` datetime(6) DEFAULT NULL,
      PRIMARY KEY (`branch_id`),
      KEY `idx_xid` (`xid`)
    ) ENGINE=InnoDB DEFAULT CHARSET=utf8;
    
    -- ----------------------------
    -- Table structure for global_table
    -- ----------------------------
    DROP TABLE IF EXISTS `global_table`;
    CREATE TABLE `global_table` (
      `xid` varchar(128) NOT NULL,
      `transaction_id` bigint(20) DEFAULT NULL,
      `status` tinyint(4) NOT NULL,
      `application_id` varchar(32) DEFAULT NULL,
      `transaction_service_group` varchar(32) DEFAULT NULL,
      `transaction_name` varchar(128) DEFAULT NULL,
      `timeout` int(11) DEFAULT NULL,
      `begin_time` bigint(20) DEFAULT NULL,
      `application_data` varchar(2000) DEFAULT NULL,
      `gmt_create` datetime DEFAULT NULL,
      `gmt_modified` datetime DEFAULT NULL,
      PRIMARY KEY (`xid`),
      KEY `idx_gmt_modified_status` (`gmt_modified`,`status`),
      KEY `idx_transaction_id` (`transaction_id`)
    ) ENGINE=InnoDB DEFAULT CHARSET=utf8;
    
    -- ----------------------------
    -- Table structure for lock_table
    -- ----------------------------
    DROP TABLE IF EXISTS `lock_table`;
    CREATE TABLE `lock_table` (
      `row_key` varchar(128) NOT NULL,
      `xid` varchar(96) DEFAULT NULL,
      `transaction_id` bigint(20) DEFAULT NULL,
      `branch_id` bigint(20) NOT NULL,
      `resource_id` varchar(256) DEFAULT NULL,
      `table_name` varchar(32) DEFAULT NULL,
      `pk` varchar(36) DEFAULT NULL,
      `gmt_create` datetime DEFAULT NULL,
      `gmt_modified` datetime DEFAULT NULL,
      PRIMARY KEY (`row_key`),
      KEY `idx_branch_id` (`branch_id`)
    ) ENGINE=InnoDB DEFAULT CHARSET=utf8;

### 1. docker 启动 seata服务 ###

docker run --name seata-server  --restart=always -p 8091:8091 -e SEATA_IP=宿主机ip -e SEATA_PORT=8091 -e STORE_MODE=db -e SEATA_CONFIG_NAME=file:/root/seata-config/registry -v /mnt/seata/config:/root/seata-config -d seataio/seata-server

## 客户端 ##

### 消费者 和 生产者服务 集成 mybatis 和 seata ###

#### 引入maven包 ####

<dependency>
                <groupId>io.seata</groupId>
                <artifactId>seata-all</artifactId>
                <version>1.4.0</version>
            </dependency>
    
            <dependency>
                <groupId>com.alibaba.cloud</groupId>
                <artifactId>spring-cloud-starter-alibaba-seata</artifactId>
                <exclusions>
                    <exclusion>
                        <groupId>io.seata</groupId>
                        <artifactId>seata-all</artifactId>
                    </exclusion>
                </exclusions>
            </dependency>

#### 生产和消费服务registry.conf文件 配置。文件创建在 resources 下。使用nacos配置，并像nacos中的serverAddr服务注册 ####

registry {
      type = "nacos"
      nacos {
        application = "serverAddr"
        serverAddr = "nacos-ip"
        namespace = ""
        cluster = "default"
        username = "nacos"
        password = "123456"
      }
    }
    
    config {
      type = "nacos"
      nacos {
        serverAddr = "nacos-ip"
        group = "SEATA_GROUP"
        namespace = ""
        username = "nacos"
        password = "123456"
      }
    }

#### yml文件配置 生产者 ####

spring:
      cloud:
        alibaba:
          seata:
            tx-service-group: producer-tx-group

#### yml文件配置 消费者 ####

spring:
      cloud:
        alibaba:
          seata:
            tx-service-group: consumer-tx-group

#### 生产者和消费者数据库分别增加undo\_log表 ####

DROP TABLE IF EXISTS `undo_log`;
    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 AUTO_INCREMENT=4 DEFAULT CHARSET=utf8;

#### 生产服务和消费服务分别配置数据源代理 ####

package com.cloud.alibaba.config;
    
    import com.alibaba.druid.pool.DruidDataSource;
    import io.seata.rm.datasource.DataSourceProxy;
    import org.apache.commons.lang3.StringUtils;
    import org.mybatis.spring.SqlSessionFactoryBean;
    import org.mybatis.spring.boot.autoconfigure.MybatisProperties;
    import org.springframework.boot.context.properties.ConfigurationProperties;
    import org.springframework.boot.context.properties.EnableConfigurationProperties;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.core.io.Resource;
    import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
    import org.springframework.core.io.support.ResourcePatternResolver;
    
    import javax.sql.DataSource;
    import java.io.IOException;
    
    /** * DataSourceConfiguration * @author admin */
    @Configuration
    @EnableConfigurationProperties({ MybatisProperties.class})
    public class DataSourceConfiguration { 
    
    
        @Bean
        @ConfigurationProperties(prefix = "spring.datasource")
        public DataSource dataSource() { 
            return new DruidDataSource();
        }
    
        @Bean
        public DataSourceProxy dataSourceProxy(DataSource dataSource) { 
            return new DataSourceProxy(dataSource);
        }
    
        @Bean
        public SqlSessionFactoryBean sqlSessionFactoryBean(DataSourceProxy dataSourceProxy,
                                                           MybatisProperties mybatisProperties) { 
            SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
            bean.setDataSource(dataSourceProxy);
    
            ResourcePatternResolver resolver = new PathMatchingResourcePatternResolver();
            try { 
                Resource[] mapperLocaltions = resolver.getResources(mybatisProperties.getMapperLocations()[0]);
                bean.setMapperLocations(mapperLocaltions);
    
                if (StringUtils.isNotBlank(mybatisProperties.getConfigLocation())) { 
                    Resource[] resources = resolver.getResources(mybatisProperties.getConfigLocation());
                    bean.setConfigLocation(resources[0]);
                }
            } catch (IOException e) { 
                e.printStackTrace();
            }
            return bean;
        }
    }

#### 消费者 业务方法上增加 @GlobalTransactional(rollbackFor = Exception.class) 注解 ####

#### [源码地址][Link 2] ####

#### 问题： ####

1.  声明事务为全局事务后，本地@Transactional声明的事务会失效。
2.  假设全局事务修改了a表的id为1的数据，本地事务提交后，全局事务提交前。本地事务b查询id为1的数据，数据已修改，数据隔离性会存在问题。但全局事务有可能不提交并造成事务回滚。
3.  seata的写隔离 是基于事务都是全局事务的基础上。如果一个时本地事务一个时全局事务。本地事务不需要获取全局锁就可以提交，存在隔离问题。

[seata]: https://seata.io/zh-cn/docs/overview/what-is-seata.html
[Link 1]: https://seata.io/zh-cn/docs/user/configurations.html
[Link 2]: https://gitee.com/lzq199528/spring-cloud-alibaba