深圳网站建设 贴吧,wordpress w3,编译安装wordpress,备案域名出售文章目录 前言参考目录Saga 模式知识点简单整理1、适用场景、优缺点2、Saga 模式的使用3、可能出现的问题以及解决方法 Docker 部署 Nacos 单机#xff08;基于 Jpom#xff09;步骤 1#xff1a;拉取镜像步骤 2#xff1a;构建容器步骤 3#xff1a;Nacos 设置 Seata 配置… 文章目录 前言参考目录Saga 模式知识点简单整理1、适用场景、优缺点2、Saga 模式的使用3、可能出现的问题以及解决方法 Docker 部署 Nacos 单机基于 Jpom步骤 1拉取镜像步骤 2构建容器步骤 3Nacos 设置 Seata 配置文件步骤 4修改 Seata Server 相关配置步骤5修改 Seata Client 相关配置 前言
这篇文章的内容比较简单没有像前几篇做 Demo 的流程分析因为 Saga 实际应用比较少下文只是简单整理一下顺便补充一下基于 Jpom 安装的 Nacos 单机的相关配置。
参考目录
Seata 官方文档Seata Saga 模式《阿里云云原生架构实践》 书本章节 3.5 介绍了分布式事务模式的相关内容。
在官方文档中对于 Saga 模式的使用作了比较详细的说明从原理到使用方法还有操作视频文末还有常见问题以及回答如果对 Saga 模式感兴趣的朋友可以自行查看。下文也会截取一些内容进行整理。
Saga 模式知识点简单整理
1、适用场景、优缺点 截图自官方文档 来简单比较一下 AT 模式、TCC 模式和 Saga 模式三种 弱一致性模型 的调用方式
模式调用方式AT 模式底层生成前后镜像不需要编写任何回滚代码由 Seata 完成TCC 模式需要自定义提交以及回滚代码由注解指定相关方法Seata 进行调用Saga 模式需要自定义提交以及回滚代码并且在状态图流程图中指定相关方法
2、Saga 模式的使用 截图自官方文档 简单点来说需要完成以下操作
编写好相关业务逻辑包括提交以及回滚的相关操作。使用 Seata 提供的状态机设计器画好状态图流程图变成 json。使用 Seata 引擎读取解析相关 json执行相关业务。
状态机设计器传送门
代码传送门状态机设计器演示地址状态机设计器视频教程
3、可能出现的问题以及解决方法
Saga 模式和 TCC 模式比较相似因此也存在着和 TCC 模式类似的问题
幂等性问题空回滚问题悬挂问题
而官方文档也对此进行了说明 截图自官方文档 隔离性问题以及性能优化问题 截图自官方文档 Docker 部署 Nacos 单机基于 Jpom
在之前说明 Seata-Server 部署的博客里面就有用到 Jpom但是没有讲到关于 Nacos 相关配置这篇文章来补充说明一下。
步骤 1拉取镜像 步骤 2构建容器 上图一开始环境变量没有设置 ip 以及 mysql 相关配置。
如果没有指定 ip则启动之后会变成内网 ip 导致无法注册。
参考seata注册到nacos服务无法访问问题 Nacos 单机模式支持 MySQL因此加入了 MySQL 相关配置 相关配置sql传送门
/** Copyright 1999-2018 Alibaba Group Holding Ltd.** 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.*//******************************************/
/* 数据库全名 nacos_config */
/* 表名称 config_info */
/******************************************/
CREATE TABLE config_info (id bigint(20) NOT NULL AUTO_INCREMENT COMMENT id,data_id varchar(255) NOT NULL COMMENT data_id,group_id varchar(128) DEFAULT NULL,content longtext NOT NULL COMMENT content,md5 varchar(32) DEFAULT NULL COMMENT md5,gmt_create datetime NOT NULL DEFAULT 2010-05-05 00:00:00 COMMENT 创建时间,gmt_modified datetime NOT NULL DEFAULT 2010-05-05 00:00:00 COMMENT 修改时间,src_user text COMMENT source user,src_ip varchar(20) DEFAULT NULL COMMENT source ip,app_name varchar(128) DEFAULT NULL,tenant_id varchar(128) DEFAULT COMMENT 租户字段,c_desc varchar(256) DEFAULT NULL,c_use varchar(64) DEFAULT NULL,effect varchar(64) DEFAULT NULL,type varchar(64) DEFAULT NULL,c_schema text,encrypted_data_key text NOT NULL COMMENT 秘钥,PRIMARY KEY (id),UNIQUE KEY uk_configinfo_datagrouptenant (data_id,group_id,tenant_id)
) ENGINEInnoDB DEFAULT CHARSETutf8 COLLATEutf8_bin COMMENTconfig_info;/******************************************/
/* 数据库全名 nacos_config */
/* 表名称 config_info_aggr */
/******************************************/
CREATE TABLE config_info_aggr (id bigint(20) NOT NULL AUTO_INCREMENT COMMENT id,data_id varchar(255) NOT NULL COMMENT data_id,group_id varchar(128) NOT NULL COMMENT group_id,datum_id varchar(255) NOT NULL COMMENT datum_id,content longtext NOT NULL COMMENT 内容,gmt_modified datetime NOT NULL COMMENT 修改时间,app_name varchar(128) DEFAULT NULL,tenant_id varchar(128) DEFAULT COMMENT 租户字段,PRIMARY KEY (id),UNIQUE KEY uk_configinfoaggr_datagrouptenantdatum (data_id,group_id,tenant_id,datum_id)
) ENGINEInnoDB DEFAULT CHARSETutf8 COLLATEutf8_bin COMMENT增加租户字段;/******************************************/
/* 数据库全名 nacos_config */
/* 表名称 config_info_beta */
/******************************************/
CREATE TABLE config_info_beta (id bigint(20) NOT NULL AUTO_INCREMENT COMMENT id,data_id varchar(255) NOT NULL COMMENT data_id,group_id varchar(128) NOT NULL COMMENT group_id,app_name varchar(128) DEFAULT NULL COMMENT app_name,content longtext NOT NULL COMMENT content,beta_ips varchar(1024) DEFAULT NULL COMMENT betaIps,md5 varchar(32) DEFAULT NULL COMMENT md5,gmt_create datetime NOT NULL DEFAULT 2010-05-05 00:00:00 COMMENT 创建时间,gmt_modified datetime NOT NULL DEFAULT 2010-05-05 00:00:00 COMMENT 修改时间,src_user text COMMENT source user,src_ip varchar(20) DEFAULT NULL COMMENT source ip,tenant_id varchar(128) DEFAULT COMMENT 租户字段,encrypted_data_key text NOT NULL COMMENT 秘钥,PRIMARY KEY (id),UNIQUE KEY uk_configinfobeta_datagrouptenant (data_id,group_id,tenant_id)
) ENGINEInnoDB DEFAULT CHARSETutf8 COLLATEutf8_bin COMMENTconfig_info_beta;/******************************************/
/* 数据库全名 nacos_config */
/* 表名称 config_info_tag */
/******************************************/
CREATE TABLE config_info_tag (id bigint(20) NOT NULL AUTO_INCREMENT COMMENT id,data_id varchar(255) NOT NULL COMMENT data_id,group_id varchar(128) NOT NULL COMMENT group_id,tenant_id varchar(128) DEFAULT COMMENT tenant_id,tag_id varchar(128) NOT NULL COMMENT tag_id,app_name varchar(128) DEFAULT NULL COMMENT app_name,content longtext NOT NULL COMMENT content,md5 varchar(32) DEFAULT NULL COMMENT md5,gmt_create datetime NOT NULL DEFAULT 2010-05-05 00:00:00 COMMENT 创建时间,gmt_modified datetime NOT NULL DEFAULT 2010-05-05 00:00:00 COMMENT 修改时间,src_user text COMMENT source user,src_ip varchar(20) DEFAULT NULL COMMENT source ip,PRIMARY KEY (id),UNIQUE KEY uk_configinfotag_datagrouptenanttag (data_id,group_id,tenant_id,tag_id)
) ENGINEInnoDB DEFAULT CHARSETutf8 COLLATEutf8_bin COMMENTconfig_info_tag;/******************************************/
/* 数据库全名 nacos_config */
/* 表名称 config_tags_relation */
/******************************************/
CREATE TABLE config_tags_relation (id bigint(20) NOT NULL COMMENT id,tag_name varchar(128) NOT NULL COMMENT tag_name,tag_type varchar(64) DEFAULT NULL COMMENT tag_type,data_id varchar(255) NOT NULL COMMENT data_id,group_id varchar(128) NOT NULL COMMENT group_id,tenant_id varchar(128) DEFAULT COMMENT tenant_id,nid bigint(20) NOT NULL AUTO_INCREMENT,PRIMARY KEY (nid),UNIQUE KEY uk_configtagrelation_configidtag (id,tag_name,tag_type),KEY idx_tenant_id (tenant_id)
) ENGINEInnoDB DEFAULT CHARSETutf8 COLLATEutf8_bin COMMENTconfig_tag_relation;/******************************************/
/* 数据库全名 nacos_config */
/* 表名称 group_capacity */
/******************************************/
CREATE TABLE group_capacity (id bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT 主键ID,group_id varchar(128) NOT NULL DEFAULT COMMENT Group ID空字符表示整个集群,quota int(10) unsigned NOT NULL DEFAULT 0 COMMENT 配额0表示使用默认值,usage int(10) unsigned NOT NULL DEFAULT 0 COMMENT 使用量,max_size int(10) unsigned NOT NULL DEFAULT 0 COMMENT 单个配置大小上限单位为字节0表示使用默认值,max_aggr_count int(10) unsigned NOT NULL DEFAULT 0 COMMENT 聚合子配置最大个数0表示使用默认值,max_aggr_size int(10) unsigned NOT NULL DEFAULT 0 COMMENT 单个聚合数据的子配置大小上限单位为字节0表示使用默认值,max_history_count int(10) unsigned NOT NULL DEFAULT 0 COMMENT 最大变更历史数量,gmt_create datetime NOT NULL DEFAULT 2010-05-05 00:00:00 COMMENT 创建时间,gmt_modified datetime NOT NULL DEFAULT 2010-05-05 00:00:00 COMMENT 修改时间,PRIMARY KEY (id),UNIQUE KEY uk_group_id (group_id)
) ENGINEInnoDB DEFAULT CHARSETutf8 COLLATEutf8_bin COMMENT集群、各Group容量信息表;/******************************************/
/* 数据库全名 nacos_config */
/* 表名称 his_config_info */
/******************************************/
CREATE TABLE his_config_info (id bigint(64) unsigned NOT NULL,nid bigint(20) unsigned NOT NULL AUTO_INCREMENT,data_id varchar(255) NOT NULL,group_id varchar(128) NOT NULL,app_name varchar(128) DEFAULT NULL COMMENT app_name,content longtext NOT NULL,md5 varchar(32) DEFAULT NULL,gmt_create datetime NOT NULL DEFAULT 2010-05-05 00:00:00,gmt_modified datetime NOT NULL DEFAULT 2010-05-05 00:00:00,src_user text,src_ip varchar(20) DEFAULT NULL,op_type char(10) DEFAULT NULL,tenant_id varchar(128) DEFAULT COMMENT 租户字段,encrypted_data_key text NOT NULL COMMENT 秘钥,PRIMARY KEY (nid),KEY idx_gmt_create (gmt_create),KEY idx_gmt_modified (gmt_modified),KEY idx_did (data_id)
) ENGINEInnoDB DEFAULT CHARSETutf8 COLLATEutf8_bin COMMENT多租户改造;/******************************************/
/* 数据库全名 nacos_config */
/* 表名称 tenant_capacity */
/******************************************/
CREATE TABLE tenant_capacity (id bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT 主键ID,tenant_id varchar(128) NOT NULL DEFAULT COMMENT Tenant ID,quota int(10) unsigned NOT NULL DEFAULT 0 COMMENT 配额0表示使用默认值,usage int(10) unsigned NOT NULL DEFAULT 0 COMMENT 使用量,max_size int(10) unsigned NOT NULL DEFAULT 0 COMMENT 单个配置大小上限单位为字节0表示使用默认值,max_aggr_count int(10) unsigned NOT NULL DEFAULT 0 COMMENT 聚合子配置最大个数,max_aggr_size int(10) unsigned NOT NULL DEFAULT 0 COMMENT 单个聚合数据的子配置大小上限单位为字节0表示使用默认值,max_history_count int(10) unsigned NOT NULL DEFAULT 0 COMMENT 最大变更历史数量,gmt_create datetime NOT NULL DEFAULT 2010-05-05 00:00:00 COMMENT 创建时间,gmt_modified datetime NOT NULL DEFAULT 2010-05-05 00:00:00 COMMENT 修改时间,PRIMARY KEY (id),UNIQUE KEY uk_tenant_id (tenant_id)
) ENGINEInnoDB DEFAULT CHARSETutf8 COLLATEutf8_bin COMMENT租户容量信息表;CREATE TABLE tenant_info (id bigint(20) NOT NULL AUTO_INCREMENT COMMENT id,kp varchar(128) NOT NULL COMMENT kp,tenant_id varchar(128) default COMMENT tenant_id,tenant_name varchar(128) default COMMENT tenant_name,tenant_desc varchar(256) DEFAULT NULL COMMENT tenant_desc,create_source varchar(32) DEFAULT NULL COMMENT create_source,gmt_create bigint(20) NOT NULL COMMENT 创建时间,gmt_modified bigint(20) NOT NULL COMMENT 修改时间,PRIMARY KEY (id),UNIQUE KEY uk_tenant_info_kptenantid (kp,tenant_id),KEY idx_tenant_id (tenant_id)
) ENGINEInnoDB DEFAULT CHARSETutf8 COLLATEutf8_bin COMMENTtenant_info;CREATE TABLE users (username varchar(50) NOT NULL PRIMARY KEY,password varchar(500) NOT NULL,enabled boolean NOT NULL
);CREATE TABLE roles (username varchar(50) NOT NULL,role varchar(50) NOT NULL,constraint uk_username_role UNIQUE (username,role)
);CREATE TABLE permissions (role varchar(50) NOT NULL,resource varchar(512) NOT NULL,action varchar(8) NOT NULL,constraint uk_role_permission UNIQUE (role,resource,action)
);INSERT INTO users (username, password, enabled) VALUES (nacos, $2a$10$EuWPZHzz32dJN7jexM34MOeYirDdFAZm2kuWj7VEOJhhZkDrxfvUu, TRUE);INSERT INTO roles (username, role) VALUES (nacos, ROLE_ADMIN);再补充一下完整的配置
容器名称nacos-server端口8848:88489848:9848挂载卷1 宿主/usr/local/jpom/nacos/logs容器/root/nacos/logs 挂载卷2 宿主/usr/local/jpom/nacos/conf容器/root/nacos/conf
环境变量
变量名变量值备注MODEstandalone单机模式JVM_XMS256mJVM_XMX512mTIME_ZONEAsia/Shanghai时区NACOS_SERVER_IP192.168.2.158指定 ip如果不指定启动时 ip 为内网 ip无法注册SPRING_DATASOURCE_PLATFORMmysqlMYSQL_SERVICE_HOST192.168.2.158MYSQL_SERVICE_PORT3326MYSQL_SERVICE_DB_NAMEnacos_configMYSQL_SERVICE_USERrootMYSQL_SERVICE_PASSWORDroot 访问 Nacos用户名nacos密码nacos
http://192.168.2.158:8848/步骤 3Nacos 设置 Seata 配置文件 service.vgroupMapping.my_test_tx_groupdefaultservice.enableDegradefalse
service.disableGlobalTransactionfalse#Transaction storage configuration, only for the server. The file, DB, and redis configuration values are optional.
store.modedb
store.lock.modedb
store.session.modedb
#Used for password encryption
store.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.datasourcehikari
store.db.dbTypemysql
store.db.driverClassNamecom.mysql.cj.jdbc.Driver
store.db.urljdbc:mysql://192.168.2.158:3326/seata?useUnicodetruerewriteBatchedStatementstrueallowPublicKeyRetrievaltrue
store.db.userroot
store.db.passwordroot
store.db.minConn5
store.db.maxConn30
store.db.globalTableglobal_table
store.db.branchTablebranch_table
store.db.distributedLockTabledistributed_lock
store.db.queryLimit100
store.db.lockTablelock_table
store.db.maxWait5000# redis 模式 store.moderedis 开启 (控制台查询功能有限,不影响实际执行功能)
# store.redis.host127.0.0.1
# store.redis.port6379
# 最大连接数
# store.redis.maxConn10
# 最小连接数
# store.redis.minConn1
# store.redis.database0
# store.redis.password
# store.redis.queryLimit100#Transaction rule configuration, only for the server
server.recovery.committingRetryPeriod60000
server.recovery.asynCommittingRetryPeriod60000
server.recovery.rollbackingRetryPeriod60000
server.recovery.timeoutRetryPeriod60000
server.maxCommitRetryTimeout-1
server.maxRollbackRetryTimeout-1
server.rollbackRetryTimeoutUnlockEnablefalse
server.distributedLockExpireTime100000
server.xaerNotaRetryTimeout600000
server.session.branchAsyncQueueSize5000
server.session.enableBranchAsyncRemovefalse#Transaction rule configuration, only for the client
client.rm.asyncCommitBufferLimit60000
client.rm.lock.retryInterval10
client.rm.lock.retryTimes30
client.rm.lock.retryPolicyBranchRollbackOnConflicttrue
client.rm.reportRetryCount5
client.rm.tableMetaCheckEnabletrue
client.rm.tableMetaCheckerInterval60000
client.rm.sqlParserTypedruid
client.rm.reportSuccessEnablefalse
client.rm.sagaBranchRegisterEnablefalse
client.rm.sagaJsonParserfastjson
client.rm.tccActionInterceptorOrder-2147482648
client.tm.commitRetryCount5
client.tm.rollbackRetryCount5
client.tm.defaultGlobalTransactionTimeout600000
client.tm.degradeCheckfalse
client.tm.degradeCheckAllowTimes10
client.tm.degradeCheckPeriod2000
client.tm.interceptorOrder-2147482648
client.undo.dataValidationtrue
client.undo.logSerializationjackson
client.undo.onlyCareUpdateColumnstrue
server.undo.logSaveDays7
server.undo.logDeletePeriod86400000
client.undo.logTableundo_log
client.undo.compress.enabletrue
client.undo.compress.typezip
client.undo.compress.threshold64k#For TCC transaction mode
tcc.fence.logTableNametcc_fence_log
tcc.fence.cleanPeriod1h#Log rule configuration, for client and server
log.exceptionRate100#Metrics configuration, only for the server
metrics.enabledfalse
metrics.registryTypecompact
metrics.exporterListprometheus
metrics.exporterPrometheusPort9898#For details about configuration items, see https://seata.io/zh-cn/docs/user/configurations.html
#Transport configuration, for client and server
transport.typeTCP
transport.serverNIO
transport.heartbeattrue
transport.enableTmClientBatchSendRequestfalse
transport.enableRmClientBatchSendRequesttrue
transport.enableTcServerBatchSendResponsefalse
transport.rpcRmRequestTimeout300000
transport.rpcTmRequestTimeout300000
transport.rpcTcRequestTimeout300000
transport.threadFactory.bossThreadPrefixNettyBoss
transport.threadFactory.workerThreadPrefixNettyServerNIOWorker
transport.threadFactory.serverExecutorThreadPrefixNettyServerBizHandler
transport.threadFactory.shareBossWorkerfalse
transport.threadFactory.clientSelectorThreadPrefixNettyClientSelector
transport.threadFactory.clientSelectorThreadSize1
transport.threadFactory.clientWorkerThreadPrefixNettyClientWorkerThread
transport.threadFactory.bossThreadSize1
transport.threadFactory.workerThreadSizedefault
transport.shutdown.wait3
transport.serializationseata
transport.compressornone步骤 4修改 Seata Server 相关配置 步骤5修改 Seata Client 相关配置
如果使用的是 XA 模式 Demo修改以下内容
配置文件
seata.registry.typenacos
seata.registry.nacos.applicationseata-server
seata.registry.nacos.server-addr192.168.2.158:8848
seata.registry.nacos.groupSEATA_GROUPseata.data-source-proxy-modeXApom 文件 把数据源配置注释掉前面在配置文件里面指定了 完
