共计 11165 个字符,预计需要花费 28 分钟才能阅读完成。
一、背景
最近在学习 Seata
,此处简略记录一下Seata Server
的分布式部署,其中的注册核心和配置核心应用 nacos
来实现,默认的 file
形式无奈实现分布式部署。其中 nocos 和 mysql 默认认为在机器上曾经部署好了。
二、部署机器
机器 ip | 部署资源 | 机器类型 |
---|---|---|
192.168.56.101 | seata server | 虚拟机 |
192.168.56.102 | seata server | 虚拟机 |
192.168.56.103 | seata server | 虚拟机 |
10.1.206.169 | nacos / mysql | 宿主机 |
三、部署步骤
1、在 seata 上创立命名空间
在 nacos 上创立 seata
的命名空间,须要记住的是 命名空间的 id,这个值在前期须要用到。
2、下载对应版本的 seata
下载解压:
# 下载
wget https://github.com/seata/seata/releases/download/v1.4.2/seata-server-1.4.2.zip
# 解压
unzip seata-server-1.4.2.zip
# 查看 seata 目录构造
tree seata -L 2
seata
└── seata-server-1.4.2
├── LICENSE
├── bin
├── conf(次要批改 registry.conf 配置文件)├── lib
└── logs
3、单机启动
此处演示的是在 192.168.56.101
这台机器上配置的 seata server。
1、批改 seata 配置文件
配置文件地位:$seata_server_home/conf/registry.conf
$seata_server_home
这是是 seata server 的解压目录。
1、批改注册核心为 nacos
vi conf/registry.conf
registry {
# file、nacos、eureka、redis、zk、consul、etcd3、sofa
type = "nacos"
nacos {
# 注册到 nacos 上的服务名
application = "seata-server"
# nacos 的地址
serverAddr = "10.1.168.152:8847"
# nacos 上的分组
group = "SEATA_GROUP"
# 命名空间,为上一步创立的
namespace = "774a5264-662f-4e27-a885-8d0783e5f26a"
# 集群,这个是事物分组的时候须要用到
cluster = "default"
# nacos 的用户名和明码
username = "nacos"
password = "nacos"
}
}
2、批改配置核心为 nacos
vi conf/registry.conf
config {
# file、nacos、apollo、zk、consul、etcd3
type = "nacos"
nacos {
serverAddr = "10.1.168.152:8848"
namespace = "774a5264-662f-4e27-a885-8d0783e5f26a"
group = "SEATA_GROUP"
username = "nacos"
password = "nacos"
# 此处的这个 dataId 的值,须要在 nacos 上创立,前期须要导入配置到这个命名空间中
dataId = "seataServer.properties"
}
}
2、导入配置到 nacos 中
数据的存储模式应用 db
,也能够应用 redis
,应用 db 须要创立 4 张表global_table
、branch_table
、lock_table
和distributed_lock
1、存储模式设置为 db,建表
建表语句为 https://github.com/seata/seat…
-- -------------------------------- The script used when storeMode is 'db' --------------------------------
-- the table to store GlobalSession data
CREATE 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_gmt_modified_status` (`gmt_modified`, `status`),
KEY `idx_transaction_id` (`transaction_id`)
) ENGINE = InnoDB
DEFAULT CHARSET = utf8;
-- the table to store BranchSession data
CREATE 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 = utf8;
-- the table to store lock data
CREATE 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),
`gmt_create` DATETIME,
`gmt_modified` DATETIME,
PRIMARY KEY (`row_key`),
KEY `idx_branch_id` (`branch_id`)
) ENGINE = InnoDB
DEFAULT CHARSET = utf8;
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);
2、简化的配置
残缺的配置: https://github.com/seata/seata/tree/develop/script/config-center/config.txt
留神:
- 此处指定的存储模式是
db
,因而须要配置数据库连贯信息,指定的数据库须要存在上一步
创立的表。 - 此处配置了多个分组,也指定了多个集群
# 这个中央的事物分组能够配置多个,多个配置多行
service.vgroupMapping.my_test_tx_group=default
service.vgroupMapping.product-service=hangzhou
service.vgroupMapping.order-service=hangzhou
# 指定存储模式为 db
store.mode=db
store.db.datasource=druid
store.db.dbType=mysql
store.db.driverClassName=com.mysql.jdbc.Driver
store.db.url=jdbc:mysql://10.1.168.152:3306/seata?useUnicode=true&rewriteBatchedStatements=true
store.db.user=root
store.db.password=root
3、残缺的配置
transport.type=TCP
transport.server=NIO
transport.heartbeat=true
transport.enableClientBatchSendRequest=true
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.default.grouplist=127.0.0.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.tableMetaCheckerInterval=60000
client.rm.sqlParserType=druid
client.rm.reportSuccessEnable=false
client.rm.sagaBranchRegisterEnable=false
client.rm.tccActionInterceptorOrder=-2147482648
client.tm.commitRetryCount=5
client.tm.rollbackRetryCount=5
client.tm.defaultGlobalTransactionTimeout=60000
client.tm.degradeCheck=false
client.tm.degradeCheckAllowTimes=10
client.tm.degradeCheckPeriod=2000
client.tm.interceptorOrder=-2147482648
store.mode=db
store.lock.mode=file
store.session.mode=file
store.publicKey=
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.jdbc.Driver
store.db.url=jdbc:mysql://10.1.168.152:3306/seata?useUnicode=true&rewriteBatchedStatements=true
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.distributedLockTable=distributed_lock
store.db.queryLimit=100
store.db.lockTable=lock_table
store.db.maxWait=5000
store.redis.mode=single
store.redis.single.host=127.0.0.1
store.redis.single.port=6379
store.redis.sentinel.masterName=
store.redis.sentinel.sentinelHosts=
store.redis.maxConn=10
store.redis.minConn=1
store.redis.maxTotal=100
store.redis.database=0
store.redis.password=
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
server.distributedLockExpireTime=10000
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.undo.compress.enable=true
client.undo.compress.type=zip
client.undo.compress.threshold=64k
log.exceptionRate=100
transport.serialization=seata
transport.compressor=none
metrics.enabled=false
metrics.registryType=compact
metrics.exporterList=prometheus
metrics.exporterPrometheusPort=9898
4、导入到 nacos 中
3、启动 seata server
./seata-server.sh -h 192.168.56.101 -p 8091 -n 1
-h: 注册到注册核心的 ip
-p: Server rpc 监听端口
-m: 全局事务会话信息存储模式,file、db、redis,优先读取启动参数 (Seata-Server 1.3 及以上版本反对 redis)
-n: Server node,多个 Server 时,需辨别各自节点,用于生成不同区间的 transactionId,免得抵触
-e: 多环境配置参考 http://seata.io/en-us/docs/ops/multi-configuration-isolation.html
4、查看 seata server 列表
4、seata server 集群启动
1、拷贝 seata server 配置到 3 台机器上
已知,咱们下面的操作都是在 192.168.56.101 这台机器上操作的,那么咱们将 192.168.56.101 这台机器上的 seata 配置拷贝到 192.168.56.102 和 192.168.56.103,而后启动即可。
# 1、将 192.168.56.101 的 seata 配置拷贝到 102 和 103 上
scp -r /home/appuser/opt/seata/ appuser@192.168.56.102:/home/appuser/opt/
scp -r /home/appuser/opt/seata/ appuser@192.168.56.103:/home/appuser/opt/
通过上方 2 步操作,那么 101、102 和 103 三台机器的 seata 配置一摸一样。
顺次启动 3 台机器的 seata server
# 切换到 192.168.56.101 机器上操作
cd /home/appuser/opt/seata/seata-server-1.4.2/bin
./seata-server.sh -h 192.168.56.101 -p 8091 -n 1
# 切换到 192.168.56.102 机器上操作
cd /home/appuser/opt/seata/seata-server-1.4.2/bin
./seata-server.sh -h 192.168.56.102 -p 8091 -n 2
# 切换到 192.168.56.103 机器上操作
cd /home/appuser/opt/seata/seata-server-1.4.2/bin
./seata-server.sh -h 192.168.56.103 -p 8091 -n 3
2、查看 seata server 列表
5、在虚拟机上放行 8091 端口
# 防火墙放行 8091 端口
firewall-cmd --zone=public --add-port=8091/tcp --permanent
# 从新加载防火墙配置
firewall-cmd --reload
四、属性配置
1、外围关注的属性
服务端配置端 | 解释 | 客户端配置 | 解释 |
---|---|---|---|
registry.type | 注册核心类型 | registry.type | 注册核心类型 |
config.type | 配置核心类型 | config.type | 配置核心类型 |
#store.mode =db 须要以下配置 |
service.vgroupMapping.my_test_tx_group |
事物分组,对应的值是 集群 | |
store.db.driverClassName | 驱动类 | service.default.grouplist | TC 服务列表 仅注册核心为 file 时应用 |
store.db.url | 数据库连贯 url | service.disableGlobalTransaction | 是否开启全局事务 |
store.db.user | 数据库用户名 | client.rm.lock.retryInterval | 校验或占用全局锁重试距离 默认 10,单位毫秒 |
store.db.password | 数据库明码 | client.rm.lock.retryTimes | 校验或占用全局锁重试次数 默认 30 |
#store.mode=redis 须要以下配置 |
|||
store.redis.host | redis 地址 | ||
store.redis.port | redis 端口 | ||
store.redis.database | redis 数据库,默认是 0 | ||
store.redis.password | redis 明码,没有不填写 |
2、服务端配置
1、undo 日志保留天数
# undo 保留天数,默认是 7 天
server.undo.logSaveDays=7
2、事务会话信息存储形式
# 事务会话信息存储形式,file 本地文件(不反对 HA),db 数据库 |redis(反对 HA)
store.mode
=file
须要配置的属性
store.file.dir(file 模式文件存储文件夹名, 默认 sessionStore)
=db
须要配置的属性
store.db.datasource(db 模式数据源类型 dbcp、druid、hikari;无默认值, 必须指定。)
store.db.dbType(db 模式数据库类型 mysql、oracle、db2、sqlserver、sybaee、h2、sqlite、access、postgresql、oceanbase;无默认值,必须指定。)
store.db.driverClassName(db 模式数据库驱动, 必须指定)
store.db.url(db 模式数据库 url, 必须指定,在应用 mysql 作为数据源时,倡议在连贯参数中加上 rewriteBatchedStatements=true)
store.db.user(db 模式数据库账户, 必须指定)
store.db.password(db 模式数据库账户明码, 必须指定)
store.db.minConn db 模式数据库初始连接数 默认 1
store.db.maxConn db 模式数据库最大连接数 默认 20
store.db.maxWait db 模式获取连贯时最大等待时间 默认 5000,单位毫秒
store.db.globalTable db 模式全局事务表名 默认 global_table
store.db.branchTable db 模式分支事务表名 默认 branch_table
store.db.lockTable db 模式全局锁表名 默认 lock_table
store.db.queryLimit db 模式查问全局事务一次的最大条数 默认 100
=redis
须要配置的属性
store.redis.host redis 模式 ip 默认 127.0.0.1
store.redis.port redis 模式端口 默认 6379
store.redis.maxConn redis 模式最大连接数 默认 10
store.redis.minConn redis 模式最小连接数 默认 1
store.redis.database redis 模式默认库 默认 0
store.redis.password redis 模式明码(无可不填) 默认 null
store.redis.queryLimit redis 模式一次查问最大条数 默认 100
3、度量配置
metrics.enabled 是否启用 Metrics 默认 false 敞开,在 False 状态下,所有与 Metrics 相干的组件将不会被初始化,使得性能损耗最低
metrics.registryType 指标注册器类型 Metrics 应用的指标注册器类型,默认为内置的 compact(繁难)实现,这个实现中的 Meter 仅应用无限内存计数,性能高足够满足大多数场景;目前只能设置一个指标注册器实现
metrics.exporterList 指标后果 Measurement 数据输入器列表 默认 prometheus,多个输入器应用英文逗号宰割,例如 "prometheus,jmx",目前仅实现了对接 prometheus 的输入器
metrics.exporterPrometheusPort prometheus 输入器 Client 端口号 默认 9898
3、客户端配置
1、数据源代理
seata.enabled 是否开启 spring-boot 主动拆卸 true、false,(SSBS)专有配置,默认 true
seata.enableAutoDataSourceProxy=true 是否开启数据源主动代理 true、false,seata-spring-boot-starter(SSBS)专有配置,SSBS 默认会开启数据源主动代理, 可通过该配置项敞开.
seata.useJdkProxy=false 是否应用 JDK 代理作为数据源主动代理的实现形式 true、false,(SSBS)专有配置, 默认 false, 采纳 CGLIB 作为数据源主动代理的实现形式
2、事物分组的配置
service.vgroupMapping.my_test_tx_group 事务群组 my_test_tx_group 为分组,配置项值为 TC 集群名
service.default.grouplist TC 服务列表 仅注册核心为 file 时应用
3、分布式事务降级开关
client.tm.degradeCheck 降级开关 默认 false。业务侧依据间断谬误数主动降级不走 seata 事务
4、校验或占用全局锁重试
client.rm.lock.retryInterval 校验或占用全局锁重试距离 默认 10,单位毫秒
client.rm.lock.retryTimes 校验或占用全局锁重试次数 默认 30
5、一阶段全局后果上报次数
client.tm.commitRetryCount 一阶段全局提交后果上报 TC 重试次数 默认 1 次,倡议大于 1
client.tm.rollbackRetryCount 一阶段全局回滚后果上报 TC 重试次数 默认 1 次,倡议大于 1
五、参考文档
1、seata server 下载
2、Seata 老手部署指南(1.4.0 版本)
3、Seata 高可用部署
4、seata 配置属性