Seata集成與部署

時間 2021-06-02

標籤 html java mysql git github redis spring sql docker shell 欄目 HTML 简体版

原文原文鏈接

Seata安裝以及Spring boot集成

Seata使用docker安裝的方式
官方文檔： Seata部署指南html

前提： Nacos安裝成功，具備docker環境java

安裝的三個角色(GitHub中的三個目錄)

Github地址: seata/script at 1.4.0 · seata/seata (github.com)mysql

client: 能夠理解爲集成Seata的Spring boot程序。在github中該目錄中主要存放undo_log.sql文件和項目的配置文件，其中undo_log.sql文件主要在業務數據庫中執行存放。
config-serverd: 這裏能夠理解爲配置中心，也就時Nacos。在github中該目錄主要存放各類配置中心須要導入的配置，這裏以Nacos爲例子：config.txt時須要導入的配置，nacos-config.sh或nacos-config.py是能夠將config.txt導入Nacos的腳本。
server：這裏理解爲Seata Server 部署的環境。在github中該目錄中保存的是須要執行的數據庫文件。（注意，這些腳本與undo_log.sql不一樣，它們不放在業務數據庫中）

Seata Server 部署

創建MySQL環境

在數據庫中新建seata的數據庫，並執行一下的SQL文件:git

seata/mysql.sql at 1.4.0 · seata/seata (github.com)github

編寫配置文件

獲取配置文件redis
在GitHub中下載Seat Server Release文件(這裏下載僅僅是爲了獲取配置文件，關於部署將使用docker方式)，而後解壓文件：spring
```
# 下載文件
wget -c https://github.com/seata/seata/releases/download/v1.4.2/seata-server-1.4.2.zip
# 解壓文件
unzipseata-server-1.4.2.zip
```

將配置文件報錯到本身定義的目錄中sql

# 新建目錄
mkdir /home/{user}/seata/config
# 將配置文件放入到自定義目錄中
cp /home/{user}/seata/seata/seata-server-1.4.2/config/file.conf /home/{user}/seata/config
cp /home/{user}/seata/seata/seata-server-1.4.2/config/registry.conf /home/{user}/seata/config

修改配置文件file.confdocker

# transaction log store, only used in seata-server
store {
  ## store mode: file、db、redis, 
  mode = "db" # 這裏修改成db
  ## rsa decryption public key
  publicKey = ""
  ......
## database store property 在這裏完善Seata將使用的數據庫相關屬性
  db {
    ## the implement of javax.sql.DataSource, such as DruidDataSource(druid)/BasicDataSource(dbcp)/HikariDataSource(hikari) etc.
    datasource = "druid"
    ## mysql/oracle/postgresql/h2/oceanbase etc.
    dbType = "mysql" # 表示使用mysql數據庫
    driverClassName = "com.mysql.cj.jdbc.Driver" 
    ## if using mysql to store the data, recommend add rewriteBatchedStatements=true in jdbc connection param
    url = "jdbc:mysql://192.168.1.1:3306/seata?rewriteBatchedStatements=true&serverTimezone=Asia/Shanghai&characterEncoding=utf-8&useSSL=false"
    user = "root"
    password = "root"
    minConn = 5
    maxConn = 100
    globalTable = "global_table"
    branchTable = "branch_table"
    lockTable = "lock_table"
    queryLimit = 100
    maxWait = 5000
  }
  ......
}

修改配置的registry.conf文件shell

registry {
  # file 、nacos 、eureka、redis、zk、consul、etcd三、sofa
  type = "nacos" # 由於使用的配置中心是Nacos，因此這裏選擇nacos

  # 這裏填寫nacos的相關屬性
  nacos {
    application = "seata-server"
    serverAddr = "192.168.1.1:8848"
    group = "SEATA_GROUP"
    namespace = ""
    cluster = "default"
    username = "nacos"
    password = "nacos"
  }
  ......
}
config {
  # file、nacos 、apollo、zk、consul、etcd3
  type = "file"
  ......
  file {
      # 這裏說名一下，由於使用docker部署的話沒有命令直接配置file.conf
      # 文件，所以直接在registry.conf裏生命file.conf文件的位置
      #（這裏file.conf的位置是在docker容器內的位置，
      # 在執行docker名令時會將實際的自定義配置文件目錄與docker環境中的目錄進行映射）
    name = "file:/root/seata-config/file.conf"
  }
}

在Nacos中添加Seata相關配置

修改config.txt文件

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.my_test_tx_group=default
service.vgroupMapping.default_tx_group=default
# 這裏須要修改成 Seata的網絡訪問地址
# service.default.grouplist=127.0.0.1:8091
service.default.grouplist=192.168.1.1:8091
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
# 這裏須要修改爲db
# store.mode=file
store.mode=db
store.file.dir=file_store/data
store.file.maxBranchSessionSize=16384
store.file.maxGlobalSessionSize=512
store.file.fileWriteBufferCacheSize=16384
store.file.flushDiskMode=async
store.file.sessionReloadReadSize=100
# 接下來修改成本身數據庫的信息
store.db.datasource=druid
store.db.dbType=mysql
store.db.driverClassName=com.mysql.cj.jdbc.Driver
store.db.url=jdbc:mysql://192.168.1.1:3306/seata?useUnicode=true&rewriteBatchedStatements=true&serverTimezone=Asia/Shanghai&characterEncoding=utf-8&useSSL=false
store.db.user=root
store.db.password=root
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
store.redis.host=127.0.0.1
store.redis.port=6379
store.redis.maxConn=10
store.redis.minConn=1
store.redis.database=0
store.redis.password=null
store.redis.queryLimit=100
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

將配置文件上傳到Nacos配置中心中

# 獲取nacos-config.sh文件: https://github.com/seata/seata/blob/1.4.0/script/config-center/nacos/nacos-config.sh
# 爲文件授予執行權限
sudo chmod +x nacos-config.sh
# 執行下述命令, 其中-u後是nacos的用戶名, -w是nacos的密碼
./nacos-config.sh -h 192.168.1.1 -p 8848 -g SEATA_GROUP -u nacos -w nacos

docker啓動Seata Server環境

docker run --name seata-server -p 8091:8091 -e SEATA_IP=192.168.1.1 -e STORE_MODE=db -e SEATA_CONFIG_NAME=file:/root/seata-config/registry -v /home/{user}/seate/config:/root/seata-config -d seataio/seata-server:1.4.2

其中 SEATA_CONFIG_NAME獲取的是docker容器中registry.conf配置文件的位置

-v /home/{user}/seate/config:/root/seata-config是將本地的/home/{user}/seate/config的目錄掛載到/root/seata-config目錄中。

Spring Boot集成Seata環境

前提： 數據庫和Mybatis plus已經集成上了，項目單獨可以正常的運行。

業務數據庫建表

-- 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 = utf8 COMMENT ='AT transaction mode undo table';

引用pom依賴

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

yml配置文件

## seata配置
seata:
  enabled: true
  application-id: ${spring.application.name}
  # 下面這個須要跟剛剛config.txt上傳到nacos配置中心的相同
  # config.txt中：service.vgroupMapping.default_tx_group=default（本身看，本身理解）
  tx-service-group: default_tx_group 
  # 這裏開啓自動的數據源配置，不然後秒要本身手動配置
  enable-auto-data-source-proxy: true
  data-source-proxy-mode: AT
  use-jdk-proxy: false
  registry:
    type: nacos
    nacos:
      application: seata-server
      server-addr: 192.168.1.1:8848
      group : "SEATA_GROUP"
      namespace: ""
      username: "nacos"
      password: "nacos"
  config:
    type: nacos
    nacos:
      server-addr: 192.168.1.1:8848
      namespace: ""
      group: "SEATA_GROUP"
      username: "nacos"
      password: "nacos"
  log:
    exception-rate: 100
  tcc-fence:
    enable: true
    config:
      log-table-name: tcc_fence_log
      clean-mode: hour
      clean-period: 1