简介

LCN 分布式事务框架其本身并不创建事务，而是基于对本地事务的协调从而达到事务一致性的效果。它的核心采用了 3PC + TCC 的补偿机制

TX-LCN 框架的特点

• 兼容 SpringCloud、Dubbo
• 使用简单，低依赖，代码完全开源
• 基于切面的强一致性事务框架
• 高可用，模块可以依赖 Dubbo 或 SpringCloud 的集群方式做集群化，TxManager 也可以做集群化
• 支持本地事务和分布式事务共存
• 事务补偿机制，服务故障或挂机再启动时可恢复事务

官方文档：https://www.codingapi.com/docs/txlcn-preface/

工作模式

LCN 5.x 有 3 种模式，分别是 LCN 模式，TCC 模式，TXC 模式

LCN 模式

• LCN 模式：是通过代理 Connection 的方式实现对本地事务的操作，然后在由 TxManager 统一协调控制事务。当本地事务提交回滚或者关闭连接时将会执行假操作，该代理的连接将由 LCN 连接池管理
• 特点：该模式对代码的嵌入性较低，该模式仅限于本地存在连接对象且可通过连接对象控制事务的模块，该模式下的事务提交与回滚是由本地事务方控制，对于数据一致性上有较高的保障，该模式缺陷在于代理的连接需要随事务发起方一共释放连接，增加了连接占用的时间

TCC 模式

• TCC 事务机制相对于传统事务机制，其特征在于它不依赖资源管理器对 XA 的支持，而是通过对（由业务系统提供的）业务逻辑的调度来实现分布式事务。主要由三步操作，Try：尝试执行业务、 Confirm：确认执行业务、 Cancel：取消执行业务
• 特点：该模式对代码的嵌入性高，要求每个业务需要写三种步骤的操作，该模式对有无本地事务控制都可以支持使用面广，数据一致性控制几乎完全由开发者控制，对业务开发难度要求高

TXC 模式

• TXC 模式命名来源于淘宝，实现原理是在执行 SQL 之前，先查询 SQL 的影响数据，然后保存执行的 SQL 快走信息和创建锁。当需要回滚的时候就采用这些记录数据回滚数据库，目前锁实现依赖 redis 分布式锁控制
• 特点：该模式同样对代码的嵌入性低，该模式仅限于对支持 SQL 方式的模块支持，该模式由于每次执行 SQL 之前需要先查询影响数据，因此相比 LCN 模式消耗资源与时间要多，该模式不会占用数据库的连接资源

工作原理

TX-LCN 框架的工作原理

• 创建事务组：是指在事务发起方开始执行业务代码之前先调用 TxManager 创建事务组对象，然后拿到事务标示 GroupId 的过程
• 添加事务组：是指参与方在执行完业务方法以后，将该模块的事务信息添加通知给 TxManager 的操作
• 关闭事务组：是指在发起方执行完业务代码以后，将发起方执行结果状态通知给 TxManager 的动作。当执行完关闭事务组的方法以后，TxManager 将根据事务组信息来通知相应的参与模块提交或回滚事务

事务补偿机制

• 为什么需要事务补偿：事务补偿是指在执行某个业务方法时，本应该执行成功的操作却因为服务器挂机或者网络抖动等问题导致事务没有正常提交，此种场景就需要通过补偿来完成事务，从而达到事务的一致性
• 补偿机制的触发条件：当执行关闭事务组步骤时，若发起方接受到失败的状态后将会把该次事务识别为待补偿事务，然后发起方将该次事务数据异步通知给 TxManager，TxManager 接受到补偿事务以后先通知补偿回调地址，然后再根据是否开启自动补偿事务状态来补偿或保存该次切面事务数据
• 补偿事务机制：LCN 的补偿事务原理是模拟上次失败事务的请求，然后传递给 TxClient 模块然后再次执行该次请求事务

TX-LCN 框架的工作时序

正常

异常

架构原理图

TX-LCN 整合 springcloud 示例

环境版本

• springboot 版本 2.0.6 RELEASE
• springcloud 版本 Finchley.SR4
• TX-LCN 版本 5.0.2 RELEASE
• mysql 版本 8.0.17

示例项目准备

• 运行 TX-Manager 服务端需要 redis 和 mysql 的支持
• 创建 mysql 数据库表

CREATE DATABASE IF NOT EXISTS  `tx-manager` DEFAULT CHARSET utf8 COLLATE utf8_general_ci;
USE `tx-manager`;SET NAMES utf8mb4;
SET FOREIGN_KEY_CHECKS = 0;-- ----------------------------
-- Table structure for t_tx_exception
-- ----------------------------
DROP TABLE IF EXISTS `t_tx_exception`;
CREATE TABLE `t_tx_exception`  (`id` bigint(20) NOT NULL AUTO_INCREMENT,`group_id` varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL,`unit_id` varchar(32) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL,`mod_id` varchar(128) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL,`transaction_state` tinyint(4) NULL DEFAULT NULL,`registrar` tinyint(4) NULL DEFAULT NULL,`ex_state` tinyint(4) NULL DEFAULT NULL COMMENT '0 待处理 1已处理',`remark` varchar(10240) NULL DEFAULT NULL COMMENT '备注',`create_time` datetime(0) NULL DEFAULT NULL,PRIMARY KEY (`id`) USING BTREE
) ENGINE = InnoDB AUTO_INCREMENT = 967 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci ROW_FORMAT = Dynamic;SET FOREIGN_KEY_CHECKS = 1;

• 下载源码包：https://github.com/codingapi/tx-lcn/releases
• 解压如下

• 修改 txlcn-tm 的 application.proerties 的配置文件

spring.application.name=TransactionManager
server.port=7970
spring.datasource.url=jdbc:mysql://127.0.0.1:3306/tx_manager?useUnicode=true&characterEncoding=UTF-8&serverTimezone=UTC&verifyServerCertificate=false&useSSL=false
spring.datasource.username=root
spring.datasource.password=123456
spring.jpa.database-platform=org.hibernate.dialect.MySQL5InnoDBDialect# 第一次运行项目，初始化用create创建表，以后用none或者update
spring.jpa.hibernate.ddl-auto=none# TxManager Ip，默认为127.0.0.1
tx-lcn.manager.host=127.0.0.1
# TM监听scoket端口，默认为8070
tx-lcn.manager.port=8070
#T M后台登录密码
tx-lcn.manager.admin-key=123456# 心跳检测时间（ms）
tx-lcn.manager.heart-time=15000
# 分布式事务执行总时间（ms）
tx-lcn.manager.dtx-time=300000
# 参数延迟删除时间ms
tx-lcn.message.netty.attr-delay-time=10000
# 事务处理并发等级，默认为机器核心数5倍
tx-lcn.manager.concurrent-level=150#redis地址
spring.redis.host=127.0.0.1
#redis端口
spring.redis.port=6379
#redis密码
spring.redis.password=##redis集群配置
#spring.redis.cluster.nodes=192.168.1.81:7000,192.168.1.81:7001,192.168.1.81:7002
##连接超时时间（毫秒）
#spring.redis.timeout=60000
##连接池最大连接数（使用负值表示没有限制）
#spring.redis.pool.max-active=300
##连接池最大阻塞等待时间（使用负值表示没有限制）
#spring.redis.pool.max-wait=-1
##连接池中的最大空闲连接
#spring.redis.pool.max-idle=100
##连接池中的最小空闲连接
#spring.redis.pool.min-idle=20#是否启用日志
#tx-lcn.logger.enabled=true
#设置日志级别
#logging.level.com.codingapi=debug# 雪花算法的sequence位长度，默认为12位
tx-lcn.manager.seq-len=12# 异常回调开关，开启时请制定ex-url
tx-lcn.manager.ex-url-enabled=false# 事务异常通知(任何http协议地址。未指定协议时，为TM提供内置功能接口)。默认是邮件通知
tx-lcn.manager.ex-url=/provider/email-to/***@**.com

• 项目打包，不要单独打包这个项目，容易出现 bug，直接右键 tx-lcn-5.0.2.RELEASE，对整个源码包进行打包

• 打包结束后，在 txlcn-tm 的 target 下会多出来几个文件，其中 txlcn-tm-5.0.2.zip 就是我们需要的文件，她包含了 TM 的单独项目源码，jar 包和源码 jar 包，三个部分。jar 包可直接运行（运行前先启动 reids 和 mysql）

TX-LCN 客户端

引入 Maven 依赖

<dependency><groupId>com.codingapi.txlcn</groupId><artifactId>txlcn-tc</artifactId><version>5.0.2.RELEASE</version>
</dependency><dependency><groupId>com.codingapi.txlcn</groupId><artifactId>txlcn-txmsg-netty</artifactId><version>5.0.2.RELEASE</version>
</dependency>

在 TX-LCN 的客户端的配置文件中添加配置

# TX-LCN 的客户端主机地址
tx-lcn.client.manager-address=127.0.0.1:8070

在 TX-LCN 的客户端主类上开启分布式事务注解

@SpringBootApplication
@EnableDistributedTransaction // 开启分布式事务注解
public class DemoAApplication {public static void main(String[] args) {SpringApplication.run(DemoAApplication.class, args);}
}

TX-LCN 的客户端分布式事务服务调用配置示例，ClientA 服务调用 ClientB 服务

@Service
public class ClientA {@Autowiredprivate ValueDao valueDao; // 本地db操作@Autowiredprivate ClientB clientB;// 远程B模块业务@LcnTransaction // 分布式事务注解@Transactional // 本地事务注解public String execute(String value) throws BusinessException {// step1. call remote service BString result = clientB.rpc(value);  // (1)// step2. local store operate. DTX commit if save success, rollback if not.valueDao.save(value);  // (2)valueDao.saveBackup(value);  // (3)return result + " > " + "ok-A";}
}

ClientB 服务

@Service
public class ClientB {@Autowiredprivate ValueDao valueDao; // 本地db操作@LcnTransaction // 分布式事务注解@Transactional  // 本地事务注解public String rpc(String value) throws BusinessException {valueDao.save(value);  // (4)valueDao.saveBackup(value);  // (5)return "ok-B";}
}

参考：https://blog.csdn.net/ningjiebing/article/details/89948050

参考：https://blog.csdn.net/weixin_42629535/article/details/88646965

分布式事务解决方案之TX-LCN的使用相关推荐

1. 分布式事务解决方案框架（LCN）

   事务概念 事务特性(ACID) 原子性(A) 所谓的原子性就是说,在整个事务中的所有操作,要么全部完成,要么全部不做,没有中间状态.对于事务在执行中发生错误,所有的操作都会被回滚,整个事务就像从没被执 ...

2. 常用的分布式事务解决方案

   首页 博客 专栏·视频 下载 论坛 问答 代码 直播 能力认证 高校 会员中心 收藏 动态 消息 创作中心 常用的分布式事务解决方案 凌澜星空 2018-03-11 14:44:55  75315   ...

3. 分布式事务解决方案，Seata的基本配置和使用

   文章目录 1. 分布式事务介绍 ①:本地事务 ②:分布式事务 ③:常见的分布式事务解决方案 3. 2PC与3PC ①:2PC与3PC的区别 3. Seata介绍 ①:Seata的三种角色 ②:Seat ...

4. 基于activemq的分布式事务解决方案

   1.分布式事务出现场景 场景描述:支付宝转账余额宝 分布式事务必须满足的条件: 1.远程RPC调用,支付宝和余额宝存在接口调用 2.支付宝和余额宝使用不同的数据库 如图: 2.分布式事务解决方案 1. ...

5. kafka实现分布式事务解决方案

   分布式事务 概念: 分布式事务就是指事务的参与者.支持事务的服务器.资源服务器以及事务管理器分别位于不同的分布式系统的不同节点之上.以上是百度百科的解释,简单的说,就是一次大的操作由不同的小操作组成, ...

6. 微服务分布式事务解决方案Seata

   文章目录 一.Seata是什么? 二.使用步骤 1.引入库 2.读入数据 总结 一.什么是Seata? Seata 是一款开源的分布式事务解决方案,致力于提供高性能和简单易用 的分布式事务服务.Sea ...

7. SpringCloud分布式事务解决方案汇总收集

   SpringCloud分布式事务解决方案汇总收集 分布式事务产生的背景 解决分布式事务的基本思想Base与CAP理论 CAP(帽子原理) BASE理论 柔性事务与刚性事务的区别 理解解决分布式事务核心 ...

8. Spring cloud的分布式事务解决方案(txlcn)

   Spring cloud的分布式事务解决方案 一.分布式CAP定律 C:Consistency一致性 所有节点访问最新的数据副本. A:Availability 可用性 当一个节点宕机,不影响数据的读 ...

9. 关于分布式事务: 阿里开源的分布式事务框架 Seata 和 LCN的分析

   之前使用过LCN分布式事务, 最近看到面试者简历中另一种方案 Seata, 通过它来在实战中解决分布式事务的问题.故 去简单了解了一下Seata是什么, 和LCN的区别在哪里, 如果是你 你怎么选择解 ...

10. SpringCloud分布式事务解决方案 整合 TX-LCN分布式事务框架

    第一章 分布式事务介绍 一.什么是分布式事务 分布式事务是指事务的参与者.支持事务的服务器.资源服务器以及事务管理器分别位于不同的分布式系统的不同节点之上. 举个栗子: 电商系统中的订单系统与库存系统 ...

最新文章

1. linux系统重启网络delaying initialization错误的解决方法
2. 面试题目--MPEG4与H.264的区别
3. POJ 2182 Lost Cows [树状数组+二分]
4. 双系统，重装windows后修复linux的grub启动
5. Kubernetes：通过自动化节省IT预算的4种方法
6. 使用spring-session外部化Spring-boot应用程序的会话状态
7. 三网融合试点，是一个商机还是烫山芋？
8. bat文件运行java的jar包不弹出dos窗口，开机自启jar包
9. Flutter Duration详细概述
10. Java == equal
11. nand flash驱动编写步骤
12. html5鼠标右键事件,js鼠标右键点击事件
13. 使用ConnectBot开源项目在android设备上管理你的linux系统
14. Python基础;个人名片制作程序
15. android中多渠道打包的三种方式
16. 老虎证券web端PWA实践总结
17. python学习—第一步—跟着黑马学Python（一）
18. kafka mysql秒杀框架_一次模拟简单秒杀场景的实践 Docker Node.js Kafka Redis MySQL...
19. php fopen创建文件,php fopen函数用法(打开创建文件）
20. 软件研发公司的招聘实习生的工资会有6000~8000这么高？是骗人的吗？

热门文章

1. 199.二叉树的右视图
2. boost库BOOST_FOREACH使用说明
3. No matching distribution found for docx（配置cmd控制台代理）
4. CS231n李飞飞计算机视觉 神经网络训练细节part1下
5. 【NLP】揭秘马尔可夫模型神秘面纱系列文章（一）
6. TCMalloc原理
7. 第八界中国云计算大会---简单回忆
8. 数学分析 复合函数求导法则
9. 大学数学实验习题--统计推断 （附答案）
10. Raki的读paper小记：Kernel Continual Learning