1.1 file.conf#

file.conf 改指定参数

1
store {
2
  ## store mode: file、db、redis
3
  mode = "db"
4
  ## database store property
5
  db {
6
    ## the implement of javax.sql.DataSource, such as DruidDataSource(druid)/BasicDataSource(dbcp)/HikariDataSource(hikari) etc.
7
    datasource = "druid"
8
    ## mysql/oracle/postgresql/h2/oceanbase etc.
9
    dbType = "mysql"
10
    driverClassName = "com.mysql.jdbc.Driver"
11
    url = "jdbc:mysql://127.0.0.1:3306/seata"
12
    user = "root"
13
    password = "easyParkMysql2021"
14
    minConn = 5
15
    maxConn = 30
16
    globalTable = "global_table"
17
    branchTable = "branch_table"
18
    lockTable = "lock_table"
19
    queryLimit = 100
20
    maxWait = 5000
21
  }
22
}

1.2 registry.conf#

registry.conf 改指定参数

1
registry {
2
  # file 、nacos 、eureka、redis、zk、consul、etcd3、sofa
3
  type = "nacos"
4

5
  nacos {
6
    application = "seata-server"
7
    serverAddr = "127.0.0.1:8848"
8
    group = "SEATA_GROUP"
9
    namespace = ""
10
    cluster = "default"
11
    username = "nacos"
12
    password = "essyParkNacos2021"
13
  }
14
}
15

16
config {
17
  # file、nacos 、apollo、zk、consul、etcd3
18
  type = "nacos"
19

20
  nacos {
21
    serverAddr = "127.0.0.1:8848"
22
    namespace = ""
23
    group = "SEATA_GROUP"
24
    username = "nacos"
25
    password = "essyParkNacos2021"
26
  }
27
}

2.1、config.txt#

config.txt 改指定参数

1
transport.type=TCP
2
transport.server=NIO
3
transport.heartbeat=true
4
transport.enableClientBatchSendRequest=false
5
transport.threadFactory.bossThreadPrefix=NettyBoss
6
transport.threadFactory.workerThreadPrefix=NettyServerNIOWorker
7
transport.threadFactory.serverExecutorThreadPrefix=NettyServerBizHandler
8
transport.threadFactory.shareBossWorker=false
9
transport.threadFactory.clientSelectorThreadPrefix=NettyClientSelector
10
transport.threadFactory.clientSelectorThreadSize=1
11
transport.threadFactory.clientWorkerThreadPrefix=NettyClientWorkerThread
12
transport.threadFactory.bossThreadSize=1
13
transport.threadFactory.workerThreadSize=default
14
transport.shutdown.wait=3
15

16
# 原来是service.vgroupMapping.my_test_tx_group，我改成service.vgroupMapping.hello_group (这句话修改完删掉)
17
service.vgroupMapping.hello_group=default
18
service.default.grouplist=127.0.0.1:8091
19
service.enableDegrade=false
20
service.disableGlobalTransaction=false
21
client.rm.asyncCommitBufferLimit=10000
22
client.rm.lock.retryInterval=10
23
client.rm.lock.retryTimes=30
24
client.rm.lock.retryPolicyBranchRollbackOnConflict=true
25
client.rm.reportRetryCount=5
26
client.rm.tableMetaCheckEnable=false
27
client.rm.sqlParserType=druid
28
client.rm.reportSuccessEnable=false
29
client.rm.sagaBranchRegisterEnable=false
30
client.tm.commitRetryCount=5
31
client.tm.rollbackRetryCount=5
32
client.tm.defaultGlobalTransactionTimeout=60000
33
client.tm.degradeCheck=false
34
client.tm.degradeCheckAllowTimes=10
35
client.tm.degradeCheckPeriod=2000
36

37
# store.mode=file改成 store.mode=db (这句话修改完删掉)
38
store.mode=db
39
store.file.dir=file_store/data
40
store.file.maxBranchSessionSize=16384
41
store.file.maxGlobalSessionSize=512
42
store.file.fileWriteBufferCacheSize=16384
43
store.file.flushDiskMode=async
44
store.file.sessionReloadReadSize=100
45

46
# db配置指向seata数据库 (这句话修改完删掉)
47
store.db.datasource=druid
48
store.db.dbType=mysql
49
store.db.driverClassName=com.mysql.jdbc.Driver
50
store.db.url=jdbc:mysql://127.0.0.1:3306/seata?useUnicode=true
51
store.db.user=root
52
store.db.password=12345678
53
store.db.minConn=5
54
store.db.maxConn=30
55
store.db.globalTable=global_table
56
store.db.branchTable=branch_table
57
store.db.queryLimit=100
58
store.db.lockTable=lock_table
59
store.db.maxWait=5000
60
store.redis.host=127.0.0.1
61
store.redis.port=6379
62
store.redis.maxConn=10
63
store.redis.minConn=1
64
store.redis.database=0
65
store.redis.password=null
66
store.redis.queryLimit=100
67
server.recovery.committingRetryPeriod=1000
68
server.recovery.asynCommittingRetryPeriod=1000
69
server.recovery.rollbackingRetryPeriod=1000
70
server.recovery.timeoutRetryPeriod=1000
71
server.maxCommitRetryTimeout=-1
72
server.maxRollbackRetryTimeout=-1
73
server.rollbackRetryTimeoutUnlockEnable=false
74
client.undo.dataValidation=true
75
client.undo.logSerialization=jackson
76
client.undo.onlyCareUpdateColumns=true
77
server.undo.logSaveDays=7
78
server.undo.logDeletePeriod=86400000
79
client.undo.logTable=undo_log
80
client.log.exceptionRate=100
81
transport.serialization=seata
82
transport.compressor=none
83
metrics.enabled=false
84
metrics.registryType=compact
85
metrics.exporterList=prometheus
86
metrics.exporterPrometheusPort=9898

2.2、nacos-conf.sh#

nacos-conf.sh 不需要改

放在conf 目录下

1
#!/usr/bin/env bash
2
# Copyright 1999-2019 Seata.io Group.
3
#
4
# Licensed under the Apache License, Version 2.0 (the "License");
5
# you may not use this file except in compliance with the License.
6
# You may obtain a copy of the License at、
7
#
8
#      http://www.apache.org/licenses/LICENSE-2.0
9
#
10
# Unless required by applicable law or agreed to in writing, software
11
# distributed under the License is distributed on an "AS IS" BASIS,
12
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13
# See the License for the specific language governing permissions and
14
# limitations under the License.
15

16
while getopts ":h:p:g:t:u:w:" opt
17
do
18
  case $opt in
19
  h)
20
    host=$OPTARG
21
    ;;
22
  p)
23
    port=$OPTARG
24
    ;;
25
  g)
26
    group=$OPTARG
27
    ;;
28
  t)
29
    tenant=$OPTARG
30
    ;;
31
  u)
32
    username=$OPTARG
33
    ;;
34
  w)
35
    password=$OPTARG
36
    ;;
37
  ?)
38
    echo " USAGE OPTION: $0 [-h host] [-p port] [-g group] [-t tenant] [-u username] [-w password] "
39
    exit 1
40
    ;;
41
  esac
42
done
43

44
urlencode() {
45
  for ((i=0; i < ${#1}; i++))
46
  do
47
    char="${1:$i:1}"
48
    case $char in
49
    [a-zA-Z0-9.~_-]) printf $char ;;
50
    *) printf '%%%02X' "'$char" ;;
51
    esac
52
  done
53
}
54

55
if [[ -z ${host} ]]; then
56
    host=localhost
57
fi
58
if [[ -z ${port} ]]; then
59
    port=8848
60
fi
61
if [[ -z ${group} ]]; then
62
    group="SEATA_GROUP"
63
fi
64
if [[ -z ${tenant} ]]; then
65
    tenant=""
66
fi
67
if [[ -z ${username} ]]; then
68
    username=""
69
fi
70
if [[ -z ${password} ]]; then
71
    password=""
72
fi
73

74
nacosAddr=$host:$port
75
contentType="content-type:application/json;charset=UTF-8"
76

77
echo "set nacosAddr=$nacosAddr"
78
echo "set group=$group"
79

80
failCount=0
81
tempLog=$(mktemp -u)
82
function addConfig() {
83
  curl -X POST -H "${contentType}" "http://$nacosAddr/nacos/v1/cs/configs?dataId=$(urlencode $1)&group=$group&content=$(urlencode $2)&tenant=$tenant&username=$username&password=$password" >"${tempLog}" 2>/dev/null
84
  if [[ -z $(cat "${tempLog}") ]]; then
85
    echo " Please check the cluster status. "
86
    exit 1
87
  fi
88
  if [[ $(cat "${tempLog}") =~ "true" ]]; then
89
    echo "Set $1=$2 successfully "
90
  else
91
    echo "Set $1=$2 failure "
92
    (( failCount++ ))
93
  fi
94
}
95

96
count=0
97
for line in $(cat $(dirname "$PWD")/config.txt | sed s/[[:space:]]//g); do
98
  (( count++ ))
99
  key=${line%%=*}
100
    value=${line#*=}
101
  addConfig "${key}" "${value}"
102
done
103

104
echo "**=****=****=****=****=****=****=****=****=****=****=****=****=****=**==="
105
echo " Complete initialization parameters,  total-count:$count ,  failure-count:$failCount "
106
echo "**=****=****=****=****=****=****=****=****=****=****=****=****=****=**==="
107

108
if [[ ${failCount} -eq 0 ]]; then
109
  echo " Init nacos config finished, please start seata-server. "
110
else
111
  echo " init nacos config fail. "
112
fi

4.1、seata 库#

1
-- -------------------------------- The script used when storeMode is 'db' --------------------------------
2
-- the table to store GlobalSession data
3
CREATE TABLE IF NOT EXISTS `global_table`
4
(
5
    `xid`                       VARCHAR(128) NOT NULL,
6
    `transaction_id`            BIGINT,
7
    `status`                    TINYINT      NOT NULL,
8
    `application_id`            VARCHAR(32),
9
    `transaction_service_group` VARCHAR(32),
10
    `transaction_name`          VARCHAR(128),
11
    `timeout`                   INT,
12
    `begin_time`                BIGINT,
13
    `application_data`          VARCHAR(2000),
14
    `gmt_create`                DATETIME,
15
    `gmt_modified`              DATETIME,
16
    PRIMARY KEY (`xid`),
17
    KEY `idx_gmt_modified_status` (`gmt_modified`, `status`),
18
    KEY `idx_transaction_id` (`transaction_id`)
19
) ENGINE = InnoDB
20
  DEFAULT CHARSET = utf8;
21

22
-- the table to store BranchSession data
23
CREATE TABLE IF NOT EXISTS `branch_table`
24
(
25
    `branch_id`         BIGINT       NOT NULL,
26
    `xid`               VARCHAR(128) NOT NULL,
27
    `transaction_id`    BIGINT,
28
    `resource_group_id` VARCHAR(32),
29
    `resource_id`       VARCHAR(256),
30
    `branch_type`       VARCHAR(8),
31
    `status`            TINYINT,
32
    `client_id`         VARCHAR(64),
33
    `application_data`  VARCHAR(2000),
34
    `gmt_create`        DATETIME(6),
35
    `gmt_modified`      DATETIME(6),
36
    PRIMARY KEY (`branch_id`),
37
    KEY `idx_xid` (`xid`)
38
) ENGINE = InnoDB
39
  DEFAULT CHARSET = utf8;
40

41
-- the table to store lock data
42
CREATE TABLE IF NOT EXISTS `lock_table`
43
(
44
    `row_key`        VARCHAR(128) NOT NULL,
45
    `xid`            VARCHAR(96),
46
    `transaction_id` BIGINT,
47
    `branch_id`      BIGINT       NOT NULL,
48
    `resource_id`    VARCHAR(256),
49
    `table_name`     VARCHAR(32),
50
    `pk`             VARCHAR(36),
51
    `gmt_create`     DATETIME,
52
    `gmt_modified`   DATETIME,
53
    PRIMARY KEY (`row_key`),
54
    KEY `idx_branch_id` (`branch_id`)
55
) ENGINE = InnoDB
56
  DEFAULT CHARSET = utf8;

4.2 业务数据库#

在我们的业务数据库中执行 undo_log 这张表：

1
CREATE TABLE `undo_log`
2
(
3
    `id` BIGINT(20) NOT NULL AUTO_INCREMENT,
4
    `branch_id` BIGINT(20) NOT NULL,
5
    `xid` VARCHAR(100) NOT NULL,
6
    `context` VARCHAR(128) NOT NULL,
7
    `rollback_info` LONGBLOB NOT NULL,
8
    `log_status` INT(11) NOT NULL,
9
    `log_created` DATETIME NOT NULL,
10
    `log_modified` DATETIME NOT NULL,
11
    `ext` VARCHAR(100) DEFAULT NULL,
12
    PRIMARY KEY (`id`),
13
    UNIQUE KEY `ux_undo_log` (`xid`, `branch_id`)
14
) ENGINE = INNODB
15
AUTO_INCREMENT = 1
16
DEFAULT CHARSET = utf8;

5.1编写启动脚本#

做好了以上准备，我们便可以启动 seata 了，直接在 bin 目录下 cmd 执行 bat 脚本即可，启动结束便可在 nacos 中看到 seata 服务：

新建start.sh，并存放在seata根目录下

1
nohup  ./bin/seata-server.sh -p 8091 -h 8.135.57.242 -m file  >nohup.out 2>1 &

5.2启动#

1
sh start.sh

user服务#

调用并开始全局事务

1
    @Autowired
2
    private ThirdFeignClient thirdFeignClient;
3

4
  @GlobalTransactional(name = "testSeata",rollbackFor = Exception.class)
5
    @GetMapping("/testSeata")
6
    public void test(){
7

8
        log.info("开始保存");
9
        thirdFeignClient.test();
10

11
        log.info("手工抛出异常");
12
        throw new EpException(ServiceCodeEnum.BAD_REQUEST);
13
    }

third服务#

提供服务

1
    @GetMapping(value = "/test")
2
    public void test(){
3
        savePictureValidationCode("我就是ip","我就是uuid","我就是code","base64");
4
    }
5

6
/**
7
     * 保存数据
8
     *
9
     * @param addressIp 请求的ip
10
     * @param uuid      uuid
11
     * @param rightCode 验证码正确的内容
12
     */
13
    private void savePictureValidationCode(String addressIp, String uuid, String rightCode, String imgBase64String) {
14
        PictureValidationCodeDO codeDO = new PictureValidationCodeDO();
15
        codeDO.setRightCode(rightCode);
16
        codeDO.setAddressIp(addressIp);
17
        codeDO.setUuid(uuid);
18
        codeDO.setImgBase64(imgBase64String);
19
        validateCodeService.save(codeDO);
20
    }

openfiegn

1
@FeignClient(value = "third")
2
public interface ThirdFeignClient {
3

4
    /**
5
     * 校验验证码
6
     */
7
    @PostMapping(value = "/kaptcha/validate")
8
    JsonResultVO<String> validate(@RequestBody ValidateCheckRequest checkRequest);
9

10
    @GetMapping(value = "/kaptcha/test")
11
    void test();
12

13
}