目录

  • 简介
    • `TX-LCN` 框架的特点
  • 工作模式
    • `LCN` 模式
    • `TCC` 模式
    • `TXC` 模式
  • 工作原理
    • `TX-LCN` 框架的工作原理
    • 事务补偿机制
    • `TX-LCN` 框架的工作时序
      • 正常
      • 异常
    • 架构原理图
  • `TX-LCN` 整合 `springcloud` 示例
    • 环境版本
    • 示例项目准备
    • `TX-LCN` 客户端
      • 引入 `Maven` 依赖
      • 在 `TX-LCN` 的客户端的配置文件中添加配置
      • 在 `TX-LCN` 的客户端主类上开启分布式事务注解
      • `TX-LCN` 的客户端分布式事务服务调用配置示例，`ClientA` 服务调用 `ClientB` 服务
      • `ClientB` 服务

简介

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的使用-编程知识网

异常

分布式事务解决方案之TX-LCN的使用-编程知识网

架构原理图

分布式事务解决方案之TX-LCN的使用-编程知识网

TX-LCN 整合 springcloud 示例

环境版本

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

示例项目准备

分布式事务解决方案之TX-LCN的使用-编程知识网

  • 运行 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
  • 解压如下

分布式事务解决方案之TX-LCN的使用-编程知识网

  • 修改 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，对整个源码包进行打包

分布式事务解决方案之TX-LCN的使用-编程知识网

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

分布式事务解决方案之TX-LCN的使用-编程知识网

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