tx-lcn使用
tx-lcn是啥
tx-lcn是一个分布式事务框架,有两个模块组成管理端(server)和client端。
管理端用于分布式事务的注册,事务消息接收,事务消息下发等管理工作。
client端包括事务发起方,事务参与方。
LCN名称是各取如下单词首字母得来的:锁定事务单元(lock)、确认事务模块状态(confirm)、通知事务(notify) 。
分布式事务的本质是多个数据库事务的统一管理。
分布式数据事务多采用二阶段提交协议:
阶段一为准备(prepare)阶段。即所有的参与者准备执行事务并锁住需要的资源。参与者ready时,向transaction manager报告已准备就绪。
阶段二为提交阶段(commit)。当transaction manager确认所有参与者都ready后,向所有参与者发送commit命令。
tx-lcn的模式
一、lcn模式:通过代理数据库连接来实现分布式事务的统一管理,适合于mysql等关系型数据库,使用注解即可,所以对代码侵入性较小。由于使用数据库本身的事务机制,对数据的一致性有较高保证。但是由于代理链接跟发起方链接一起释放,连接占用时间较长。
遵循二阶段提交,执行流程如下描述:
1、事务发起方(client端)调用管理端创建事务组,生成一个事务组。
2、事务发起方调用事务参与方执行业务逻辑,然后事务参与方将执行结果通知给事务管理端。
3、事务发起方将自己模块的执行结果通知给管理端。
4、管理端根据发起方和所有参与方的执行结果通知发起方和所有参与方是提交还是回滚。
二、tcc模式:不依赖于数据库的事务实现分布式事务管理。也不需要事务管理端,而是由代码逻辑控制事物的提交和回滚。为需要使用分布式事物的方发编写确认提交逻辑和回滚逻辑,使用注解参数指定例如:@TccTransaction(confirmMethod=“method1”,cancelMethod=“method2”)。由于每个事务方法都要写这两个逻辑,比较繁琐,对代码侵入性较强,但适用面广,任何数据库都适用。
三、txc模式:执行sql前,先查询影响的数据,然后保存这些数据,并对这些数据加锁,执行SQL,如果执行失败,则用保存的数据回滚。目前分布式锁采用redis的分布式锁
tx-lcn的使用
一、lcn模式:
创建一个管理项目
- pom文件引入依赖
<dependencies><dependency><groupId>com.codingapi.txlcn</groupId><artifactId>txlcn-tm</artifactId><version>5.0.2.RELEASE</version></dependency>
</dependencies>
- 使用application.properties配置属性,或者保留空的application.properties文件新建一个application.yml文件在其中配置属性:
spring:redis:host: 127.0.0.1port: 6381application:name: txManagerdatasource:driver-class-name: com.mysql.cj.jdbc.Driver url: jdbc:mysql://localhost:3306/tx-manager?useUnicode=true&characterEncoding=UTF-8&serverTimezone=Asia/Shanghaiusername: rootpassword: root
tx-lcn:manager:host: 127.0.0.1 # tx-manager ip(client请求ip)port: 8070 # client 请求端口heart-time: 12000 # 心跳检测时间 单位:msdtx-time: 3000 # 事务执行总时间admin-key: 123456 #TM后台登陆密码,默认密码是codingapilogger:enabled: true #开启日志,默认为false,开发阶段最好开启日志,并设置为debug等级,这样方便追踪排查问题#日志记录表 t_loggerdriver-class-name: ${spring.datasource.driver-class-name}jdbc-url: ${spring.datasource.url}username: ${spring.datasource.username}password: ${spring.datasource.password}
- 从引入的jar包中找到tx-manager.sql,用它创建管理端需要的数据库表
- 启动类上加注解@EnableTransactionManagerServer
创建一个业务项目
- pom文件引入依赖
<dependency><groupId>com.codingapi.txlcn</groupId><artifactId>txlcn-txmsg-netty</artifactId><version>5.0.2.RELEASE</version>
</dependency>
<dependency><groupId>com.codingapi.txlcn</groupId><artifactId>txlcn-tc</artifactId><version>5.0.2.RELEASE</version>
</dependency>
- yml配置
tx-lcn:client:manager-address: 127.0.0.1:8070 #上述管理端的IP
- 启动类上加注解@EnableDistributedTransaction
在需要使用分布式事务的方法上加注解@LcnTransaction
@LcnTransaction属性propagation可取值
DTXPropagation.REQUIRED:默认值,表示如果当前没有事务组创建事务组,如果有事务组,加入事务组。多用在事务发起方。
DTXPropagation.SUPPORTS:如果当前没有事务组以本地事务运行,如果当前有事务组加入事务组。多用在事务参与方法。
二、tcc模式:
创建一个业务项目
- pom文件引入依赖
<dependency><groupId>com.codingapi.txlcn</groupId><artifactId>txlcn-txmsg-netty</artifactId><version>5.0.2.RELEASE</version>
</dependency>
<dependency><groupId>com.codingapi.txlcn</groupId><artifactId>txlcn-tc</artifactId><version>5.0.2.RELEASE</version>
</dependency>
- 启动类上加注解@EnableDistributedTransaction
- 在需要使用分布式事务的方法上加注解@TccTransaction(confirmMethod=“confirmMethod”,cancelMethod=“cancelMethod”)
- 为方法创建confirmMethod和cancelMethod方法
参考文章:
https://blog.csdn.net/m0_56182317/article/details/130288633
https://www.cnblogs.com/64Byte/p/13426818.html
https://www.bilibili.com/read/cv10537863/
https://zhuanlan.zhihu.com/p/325602044?utm_id=0
相关文章:
tx-lcn使用
tx-lcn是啥 tx-lcn是一个分布式事务框架,有两个模块组成管理端(server)和client端。 管理端用于分布式事务的注册,事务消息接收,事务消息下发等管理工作。 client端包括事务发起方,事务参与方。 LCN名称是…...
oracle恢复异常处理
问题现象: RMAN> 2> 3> 4> 5> 6> 7> 8> 9> 10> 11> 12> 13> 14> 15> 16> 17> 18> 19> 20> 21> 22> 23> 24> using target database control file instead of recovery catalog allocate…...
谈谈什么是 Redis
🔥博客主页:fly in the sky - CSDN博客 🚀欢迎各位:点赞👍收藏⭐️留言✍️🚀 🎆慢品人间烟火色,闲观万事岁月长🎆 📖希望我写的博客对你有所帮助,如有不足,请指正&#…...
备战蓝桥杯(java)(日益更新)
备战蓝桥杯(java)(日益更新) 文章目录 备战蓝桥杯(java)(日益更新)前言:一、c 到 java 须要注意的地方:二、多练java代码:(用java代码…...
06 Php学习:字符串
PHP 中的字符串变量 在 PHP 中,字符串是一种常见的数据类型,用于存储文本数据。字符串变量可以包含字母、数字、符号等字符,并且可以进行各种操作和处理。以下是关于 PHP 中字符串变量的一些重要信息: 定义字符串变量࿱…...
python画图Matplotlib和Seaborn
python画图Matplotlib和Season 一、Matplotlib1、介绍2、安装3、内容二、Seaborn1、介绍2、安装3、内容一、Matplotlib Matplotlib官网 1、介绍 Matplotlib 是一个 Python 的绘图库,用于创建高质量的二维图表和一些基本的三维图表。它广泛应用于科学计算、数据分析、工程学和…...
一体式I/O模块与RS485串口联动,实现工业网络无缝对接
在现代工业自动化领域中,一体化I/O模块和RS485串口的联动应用已经成为实现工业设备高效、稳定通信的关键技术手段之一。这种联动机制能够有效地将各种现场设备的数据实时、准确地传输到上位机系统,从而实现工业网络的无缝对接。 一体化I/O模块ÿ…...
如何在Uniapp真机中使用H.265无插件流媒体播放器EasyPlayer
流媒体播放器EasyPlayer是TSINGSEE青犀流媒体组件系列中关注度较高的产品,经过多年的发展和迭代,目前已经有多个应用版本,包括RTSP版、RTMP版、Pro版,以及js版,其中js版本作为网页播放器,受到了用户的广泛使…...
【MySQL数据库 | 第二十五篇】深入探讨MVCC底层原理
前言: 在当今互联网时代,数据库扮演着数据存储和管理的关键角色。对于大型Web应用程序和企业级系统而言,高效地处理并发访问和事务管理是至关重要的。多版本并发控制(MVCC)是一种数据库事务处理的技术,旨…...
【LAMMPS学习】八、基础知识(1.6) LAMMPS 与其他代码耦合
8. 基础知识 此部分描述了如何使用 LAMMPS 为用户和开发人员执行各种任务。术语表页面还列出了 MD 术语,以及相应 LAMMPS 手册页的链接。 LAMMPS 源代码分发的 examples 目录中包含的示例输入脚本以及示例脚本页面上突出显示的示例输入脚本还展示了如何设置和运行各…...
ArrayList中多线程的不安全问题
ArrayList中的不安全问题 正常的输出 List<String> list Arrays.asList("1","2","3"); list.forEach(System.out::println);为什么可以这样输出,是一种函数是接口,我们先过个耳熟 Arrys.asList是返回一个ArrayL…...
ALTER TABLE 之 定点变更(in-place alter)
定点变更算法可以提供优于慢速变更算法的诸多性能优势: 定点变更算法: 1,增加了表的可用性 ALTER TABLE操作使用定点变更算法时,其他用户稍后可以访问该表,因为数据库服务器只在更新表定义和重建包含更改列的索引时才锁…...
【RAG实践】Rerank,让大模型 RAG 更近一步
RAGRerank原理 上一篇【RAG实践】基于LlamaIndex和Qwen1.5搭建基于本地知识库的问答机器人 我们介绍了什么是RAG,以及如何基于LLaMaIndex和Qwen1.5搭建基于本地知识库的问答机器人,原理图和步骤如下: 这里面主要包括包括三个基本步骤&#…...
私有化客服系统:在线客服搭建与部署的创新之路
随着互联网技术的飞速发展,企业与客户之间的沟通方式也在不断地演变。在这个信息爆炸的时代,一个高效、便捷、智能的在线客服系统成为了企业提升服务质量、增强客户满意度的重要工具。本文将详细介绍在线客服系统的构建、部署以及私有化客服的优势&#…...
VM-UNet: Vision Mamba UNet for Medical Image Segmentation
VM-UNet: Vision Mamba UNet for Medical Image Segmentation VM-UNet:基于视觉Mamba UNet架构的医学图像分割 论文链接:http://arxiv.org/abs/2402.02491 代码链接:https://github.com/JCruan519/VM-UNet 1、摘要 文中利用状态空间模型SS…...
面向对象编程:在Python中的面向对象编程奥秘
面向对象编程在Python中的奥秘 在编程的世界里,面向对象编程(Object-Oriented Programming,简称OOP)是一种非常重要的编程范式。它改变了我们思考问题和设计代码的方式。Python作为一种支持面向对象的语言,为我们提供…...
考研数学|零基础100分保底复习方案+资料分享
目标100分其实很好实现,只要你有决心,不需要去看任何人的学习技巧 其实基础差,你只要专攻基础就好了,现在的很多考研课程和资料真的很不照顾基础不好的同学,好像就默认你什么都会一样,但是还是有对于基础差…...
【MATLAB源码-第29期】基于matlab的MIMO,MISO,SIMO,SISO瑞利rayleigh信道容量对比。
操作环境: MATLAB 2022a 1、算法描述 1. SISO(单输入单输出): - SISO 是指在通信系统中,只有一个天线用于传输信号,也只有一个天线用于接收信号的情况。这是最简单的通信方式。 2. SIMO(单…...
JRT高效率开发
得益于前期的基础投入,借助代码生成的加持,本来计划用一周实现质控物维护界面,实际用来四小时左右完成质控物维护主体,效率大大超过预期。 JRT从设计之初就是为了证明Spring打包模式不适合软件服务模式,觉得Spring打包…...
Spring Boot 切面的一种的测试方法,java中级开发面试
void afterReturnName() { Assertions.assertEquals(studentController.getNameById(123L).getName(), "测试姓名Yz");} } 但往往切面中的逻辑并非这么简单,在实际的测试中其实我们也完成没有必要关心在切面中到底发生了什么(发生了什么应该在…...
RT-Thread aarch64虚拟平台文件系统移植实战:从QEMU virt到LittleFS
1. 项目概述与核心价值最近在折腾RT-Thread的aarch64虚拟平台,特别是qemu-virt64-aarch64这个BSP(Board Support Package,板级支持包)上的文件系统支持。这看起来像是一个很具体的移植工作,但实际上,它触及…...
构建统一AI服务网关:OpenAI兼容门面模式实践指南
1. 项目概述:一个兼容OpenAI API的轻量级门面最近在折腾大模型应用开发,发现一个挺普遍的需求:很多团队或个人开发者,手里可能握着不止一个AI服务提供商的API密钥,比如既有官方的OpenAI,也有国内的一些合规…...
基于RP2040与VL53L1X的自动触发空气炮:嵌入式感知-决策-执行系统实践
1. 项目概述:一个会“思考”的自动空气炮如果你玩过或者听说过那些在鬼屋里突然喷气吓人的恶作剧道具,那你大概能想象出这个项目的最终效果。但今天我们要做的,远不止一个简单的“吓人盒子”。这是一个融合了现代嵌入式系统、高精度传感器和气…...
Swift集成飞书API:使用feishu-swift SDK构建高效机器人
1. 项目概述:一个连接飞书与Swift生态的桥梁 最近在折腾一个内部工具,需要把服务端的一些数据变动实时同步到飞书群里,方便团队同学及时跟进。服务端是用Swift写的,而飞书官方虽然有开放的API,但直接上手去调…...
Godot集成CEF:用Web技术构建高性能跨平台桌面应用
1. 项目概述:一个被低估的桌面应用开发利器 如果你正在寻找一个能让你用熟悉的Web技术(HTML、CSS、JavaScript)来构建高性能、跨平台桌面应用的工具,并且对Electron的臃肿和资源占用感到头疼,那么你很可能已经听说过C…...
基于CircuitPython与伺服电机的自动调光眼镜制作指南
1. 项目概述与核心思路 最近在整理工作室的零件盒,翻出来一块Adafruit的Circuit Playground Express开发板和几个闲置的微伺服电机。看着窗外刺眼的阳光,我忽然想到,能不能用这些手头的“边角料”做个实用的小玩意儿?于是&#x…...
Vivado XADC IP核 配置与接口实战解析
1. XADC IP核基础入门 XADC(Xilinx Analog-to-Digital Converter)是Xilinx FPGA芯片内置的高精度模拟数字转换模块,它能实时监测芯片内部的电压、温度以及外部模拟信号。在Vivado开发环境中,我们可以通过XADC Wizard IP核快速配置…...
OpenTelemetry可观测系统之Metrics学习
概念 OpenTelemetry 是一套通用监控工具包,不生产监控数据,只负责采集监控数据;Metrics 是它专门用来抓「数字指标」的模块 理解:OTel Metrics 1.区分三大可观测核心 OTel 只干三件事,你可以把服务运行状态想象成人&am…...
别再卡在‘Setup is running’了!PowerBuilder 9.0保姆级安装避坑指南(附安全模式备用方案)
PowerBuilder 9.0安装全攻略:从卡死困境到高效部署 "Setup is running"这个看似简单的提示框,曾让无数PowerBuilder开发者陷入漫长的等待和反复的重启循环。作为一款承载了二十余年企业级应用开发记忆的经典工具,PowerBuilder 9.0的…...
Python实时通信实战:Flask-SocketIO深度解析
Python实时通信实战:Flask-SocketIO深度解析 引言 在Python开发中,实时通信是构建现代Web应用的核心技术。作为一名从Rust转向Python的后端开发者,我深刻体会到Flask-SocketIO在实时通信方面的优势。Flask-SocketIO为Flask应用提供了WebSocke…...
