seata源码分析(02)_AT和TCC基础示例

本文介绍一下如何使用seata api实现AT、TCC模式的分布式事务。

AT模式示例

启动seata-server服务

在 (02)_源码启动seata-server服务 中。

创建undo日志表

script/client/at/db/mysql.sql 文件：

-- 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       NOT NULL COMMENT 'branch transaction id',`xid`           VARCHAR(128) 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 = utf8mb4 COMMENT ='AT mode undo table';
ALTER TABLE `undo_log` ADD INDEX `ix_log_created` (`log_created`);

添加nacos配置

本示例nacos使用1.2.1版本，创建seata-client.properties配置文件：

transport.type=TCP
transport.server=NIO
transport.heartbeat=true
transport.enableTmClientBatchSendRequest=false
transport.enableRmClientBatchSendRequest=true
transport.enableTcServerBatchSendResponse=false
transport.rpcRmRequestTimeout=30000
transport.rpcTmRequestTimeout=30000
transport.rpcTcRequestTimeout=30000
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
transport.serialization=seata
transport.compressor=none
service.vgroupMapping.default_tx_group=default
service.default.grouplist=127.0.0.1:8091
service.enableDegrade=false
service.disableGlobalTransaction=false
client.metadataMaxAgeMs=30000
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=true
client.rm.tableMetaCheckerInterval=60000
client.rm.sqlParserType=druid
client.rm.reportSuccessEnable=false
client.rm.sagaBranchRegisterEnable=false
client.rm.sagaJsonParser=fastjson
client.rm.tccActionInterceptorOrder=-2147482648
client.rm.sqlParserType=druid
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
client.undo.dataValidation=true
client.undo.logSerialization=jackson
client.undo.onlyCareUpdateColumns=true
client.undo.logTable=undo_log
client.undo.compress.enable=true
client.undo.compress.type=zip
client.undo.compress.threshold=64k
tcc.fence.logTableName=tcc_fence_log
tcc.fence.cleanPeriod=1h
tcc.contextJsonParserType=fastjson
log.exceptionRate=100
metrics.enabled=false
metrics.registryType=compact
metrics.exporterList=prometheus
metrics.exporterPrometheusPort=9898

创建registry.yml配置文件

在classpath下创建registry.yml配置文件：

config:type: nacosnacos:serverAddr: localhost:8848namespace: seata_examplegroup: SEATA_GROUPdataId: seata-client.propertiesusername: nacospassword: nacos
registry:type: nacosnacos:serverAddr: localhost:8848namespace: seata_examplegroup: SEATA_GROUPusername: nacospassword: nacosapplication: seata-servercluster: default

示例实现思路

  • 编写一个业务类，写一个业务方法
  • 使用@GlobalTransactional注解标注业务方法
  • 业务方法中在两个不同的线程、使用不同的数据源获取连接做更新操作
  • 使用TMClient、RMClient初始化TM和RM客户端
  • 使用DataSourceProxy类包装原始的DataSource
  • 创建业务类对象，并使用seata提供的ProxyUtil为其创建代理对象
  • 通过代理对象调用业务方法

示例实现

业务类和业务方法

public class AtGlobalTransactionSimpleTest {// 为业务方法启用全局事务@GlobalTransactionalpublic void globalTransactionTest() throws SQLException {changeAccountBalance();changeProductRemain();// 此处抛出自定义的运行时异常，之后全局事务会回滚throw new TransactionException("测试异常");}// 以下两个方法使用jdbc操作数据库protected void changeAccountBalance() throws SQLException {System.out.printf("[%s] %s\n", Thread.currentThread().getName(), "changeAccountBalance");String sql = "update account set balance=? where id=?";try (Connection connection = accountDs.getConnection();PreparedStatement ps = connection.prepareStatement(sql)) {ps.setDouble(1, 1000);ps.setInt(2, 3);int rows = ps.executeUpdate();if (rows != 1) {throw new TransactionException("修改账户余额失败");}}}protected void changeProductRemain() throws SQLException {System.out.printf("[%s] %s\n", Thread.currentThread().getName(), "changeProductRemain");String sql = "update product set remaining_count=? where id=?";try (Connection connection = productDs.getConnection();PreparedStatement ps = connection.prepareStatement(sql)) {ps.setInt(1, 1000);ps.setInt(2, 2);int rows = ps.executeUpdate();if (rows != 1) {throw new TransactionException("修改产品库存失败");}}}
}// 模拟在不同的线程执行更新操作
public class AtGlobalTransactionMultiThreadTest extends AtGlobalTransactionSimpleTest {private static final ExecutorService CH_ACCOUNT_EXECUTOR;private static final ExecutorService CH_PRODUCT_EXECUTOR;static {CH_ACCOUNT_EXECUTOR = new ThreadPoolExecutor(2, 2, 60, TimeUnit.SECONDS,new LinkedBlockingQueue<>(100), new MyThreadFactory("ch-account"));CH_PRODUCT_EXECUTOR = new ThreadPoolExecutor(2, 2, 60, TimeUnit.SECONDS,new LinkedBlockingQueue<>(100), new MyThreadFactory("ch-product"));}@Override@GlobalTransactionalpublic void globalTransactionTest()

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/843760.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

三层交换机基本配置,动态路由链接

三层交换机基本配置,动态路由链接

<Huawei>system-view //进入系统视图[Huawei]undo info-center enable //关日志[Huawei]vlan batch 2 3 //创建vlan2与3[Huawei]display vlan //检查[Huawei]interface GigabitEthernet 0/0/2 //进2口[Huawei-GigabitEthernet0/0/2]port link-type access //配置…
阅读更多...
Redis教程(十七)：Redis的Redisson分布式锁

Redis教程(十七)：Redis的Redisson分布式锁

传送门：Redis教程汇总篇，让你从入门到精通 Redis分布式锁 Redis分布式锁的主要作用是在分布式系统环境下提供一种机制，用于确保在同一时间只有一个进程（或线程）能够执行某个关键代码段或访问特定的资源。这主要用于控制对共享资源的并发访问，以避免因多个进程同时修改同…
阅读更多...
C语言 | Leetcode C语言题解之第117题填充每个节点的下一个右侧节点指针II

C语言 | Leetcode C语言题解之第117题填充每个节点的下一个右侧节点指针II

题目&#xff1a; 题解&#xff1a; void handle(struct Node **last, struct Node **p, struct Node **nextStart) {if (*last) {(*last)->next *p;}if (!(*nextStart)) {*nextStart *p;}*last *p; }struct Node *connect(struct Node *root) {if (!root) {return NULL…
阅读更多...
开源博客项目Blog .NET Core源码学习（29：App.Hosting项目结构分析-17）

开源博客项目Blog .NET Core源码学习（29：App.Hosting项目结构分析-17）

本文学习并分析App.Hosting项目中后台管理页面的按钮管理页面。   按钮管理页面用于显示、新建、编辑、删除页面按钮数据&#xff0c;以便配置后台管理页面中每个页面的工具栏、操作栏、数据列中的按钮的事件及响应url。按钮管理页面附带一新建及编辑页面&#xff0c;以支撑新…
阅读更多...
Unity之如何使用Localization来实现文本+资源多语言

Unity之如何使用Localization来实现文本+资源多语言

前言 使用Unity实现本地化&#xff08;Localization&#xff09;功能 在当今的游戏开发中&#xff0c;支持多语言已成为一项基本需求。Unity作为主流的游戏开发引擎&#xff0c;提供了强大的本地化工具&#xff0c;使开发者能够方便地为游戏添加多语言支持。本文将介绍如何在U…
阅读更多...
从0开始学会做标书：新手学习做标书制作必修(95节课)

从0开始学会做标书：新手学习做标书制作必修(95节课)

入门框架 电子标书 商务标书 文档排版 技术标书 实操演示 你是否也有同样的问题 1、做标书公司没人教、没人带? 2、如何看懂招标文件? 3、小白零基础能不能学习做标书? 4、商务标、技术标如何得高分? 5、做标书需要什么软件? 6、如何制作电子标书? 7、如何避…
阅读更多...
Vue2 基础六前端工程化

Vue2 基础六前端工程化

代码下载 模块化相关规范 传统开发模式的主要问题&#xff1a;命名冲突、文件依赖。 模块化就是把单独的一个功能封装到一个模块&#xff08;文件&#xff09;中&#xff0c;模块之间相互隔离&#xff0c;但是可以通过特定的接口公开内部成员&#xff0c;也可以依赖别的模块…
阅读更多...
Java核心: 使用asm操作字节码

Java核心: 使用asm操作字节码

在上一篇<Java核心: 注解处理器>中我们提到&#xff0c;通过实现AbstractProcessor&#xff0c;并调用javac -processor能够生成代码来实现特殊逻辑。不过它存在两个明显的问题: 只能新增源文件来扩展逻辑&#xff0c;无法修改现有的类或方法 必须有一个单独的编译过程&a…
阅读更多...
三步走，Halo DB 安装指引

三步走，Halo DB 安装指引

前文介绍了国产数据库新星 Halo 数据库是什么&#xff0c; 哈喽&#xff0c;国产数据库&#xff01;Halo DB! ★ HaloDB是基于原生PG打造的新一代高性能安全自主可控全场景通用型统一数据库。 业内首次创造性的提出插件式内核架构设计&#xff0c;通过配置的方式&#xff0c;适…
阅读更多...
国产卫星星座，为什么一定要“走出去”？

国产卫星星座，为什么一定要“走出去”？

今天这篇文章&#xff0c;我们来聊聊卫星和星座。 2024年行将过半&#xff0c;全球卫星通信产业的发展&#xff0c;又有了新的变化。 在卫星星座方面&#xff0c;各大企业的竞争博弈全面进入白热化阶段。卫星的发射速度在不断加快&#xff0c;而全球星座项目的数量和规模也在持…
阅读更多...
如何在生产环境中以非 Root 用户启动 Kafka

如何在生产环境中以非 Root 用户启动 Kafka

目录 如何在生产环境中以非 Root 用户启动 Kafka1. 创建 Kafka 用户2. 设置目录权限3. 配置 systemd 服务文件4. 启动和启用 Kafka 服务5. 验证 Kafka 服务经验总结 为了在生产环境中以非 root 用户&#xff08;如 kafka 用户&#xff09;启动 Kafka&#xff0c;您需要确保 Ka…
阅读更多...
为什么建立数据库连接耗时？究竟耗时多久？

为什么建立数据库连接耗时？究竟耗时多久？

数据库连接从连接池中取这已经是大家的共识了&#xff0c;因为频繁的建立或者关闭连接代价太大&#xff0c;那么代价究竟有多大&#xff1f; 我们先准备一个简单的数据库连接代码段 public static void main(String[] args) throws ClassNotFoundException, SQLException, Int…
阅读更多...
秋招突击——算法打卡——5/27——复习{寻找特定中位数}——新做：{最长回文字串、Z 字形变换}

秋招突击——算法打卡——5/27——复习{寻找特定中位数}——新做：{最长回文字串、Z 字形变换}

文章目录 复习——寻找特定中位数新作——最长回文子串个人思路分析实现代码参考学习和上述思路相同&#xff0c;枚举中心点字符串哈希二分 新作——Z 字形变换个人做法思路分析实现代码 参考解法分析总结 复习——寻找特定中位数 第一次的链接&#xff1a;寻找中位数本来以为…
阅读更多...
Ai终点站，全系统商业闭环矩阵打造，帮电商、实体降70%成本，12款Ai联合深度实战

Ai终点站，全系统商业闭环矩阵打造，帮电商、实体降70%成本，12款Ai联合深度实战

说白了&#xff0c;你之前5个人的团队&#xff0c;当团队人数不变的情况下&#xff0c;借助于ChatGPT和各种软件的结合&#xff0c;赋能电商直播带货&#xff0c;可以让之前一年销售额2.000万变成2.500万或者是3.000万&#xff0c;这就是这套课程的核心作用: 【1】系统课程从1…
阅读更多...
深度神经网络——贝叶斯与朴素贝叶斯定理

深度神经网络——贝叶斯与朴素贝叶斯定理

概述 贝叶斯定理是概率论中一个非常重要的概念&#xff0c;它提供了一种在已知某些相关事件的概率时&#xff0c;计算另一个事件发生概率的方法。在你提供的内容中&#xff0c;贝叶斯定理被描述为一种“魔法”&#xff0c;因为它能够使计算机通过分析大量的数据来预测人们可能…
阅读更多...
100个 Unity小游戏系列七 -Unity 抽奖游戏专题五 刮刮乐游戏

100个 Unity小游戏系列七 -Unity 抽奖游戏专题五 刮刮乐游戏

一、演示效果 二、知识点讲解 2.1 布局 void CreateItems(){var rewardLists LuckyManager.Instance.CalculateRewardId(rewardDatas, Random.Range(4, 5));reward_data_list reward_data_list ?? new List<RewardData>();reward_data_list.Clear();for (int i 0; …
阅读更多...
图像处理中的维度元素复制技巧

图像处理中的维度元素复制技巧

新书上架~&#x1f447;全国包邮奥~ python实用小工具开发教程http://pythontoolsteach.com/3 欢迎关注我&#x1f446;&#xff0c;收藏下次不迷路┗|&#xff40;O′|┛ 嗷~~ 目录 一、引言 二、维度元素复制的基本概念 三、如何实现维度元素复制 1. 方法介绍 2. 代码示…
阅读更多...
Petalinux 制作ZYNQ镜像文件流程

Petalinux 制作ZYNQ镜像文件流程

1概述 在Zynq-7000 SoC中搭建运行Linux&#xff0c;嵌入式软件栈。 处理器系统引导是一个分两个阶段的过程。第一个阶段是一个内部 BootROM&#xff0c;它存储 stage-0 的引导代码。BootROM 在 CPU 0 上执行&#xff0c;CPU 1 执行等待事件&#xff08;WFE&#xff09;指令。…
阅读更多...
深入探索Qt框架系列之三大编译器

深入探索Qt框架系列之三大编译器

Qt是一个强大的跨平台框架&#xff0c;广泛用于开发具有丰富图形用户界面的应用程序。Qt不仅仅是一个库&#xff0c;它还提供了一套工具&#xff0c;帮助开发者从底层实现到最终的用户界面设计。在本文中&#xff0c;我们将深入探讨Qt中三个核心的编译器工具&#xff1a;元对象…
阅读更多...
openresty(Nginx) 隐藏 软包名称及版本号 升级版本

openresty(Nginx) 隐藏 软包名称及版本号 升级版本

1 访问错误或者异常的URL 2 修改配置&#xff0c;重新编译&#xff0c;升级 #修改版本等 vim ./bundle/nginx-1.13.6/src/core/nginx.h #define nginx_version 1013006 #define NGINX_VERSION "1.13.6" #define NGINX_VER "openresty/&q…
阅读更多...
最新文章

Copyright @ 2022~2023