分布式事务之TX-LCN

Posted 北漂码农有话说

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了分布式事务之TX-LCN相关的知识，希望对你有一定的参考价值。

分布式事务-Tx-lcn



点击上方蓝字可以订阅哦

Tx-lcn

1. TX-LCN是什么？

TX-LCN 框架在2017年6月份发布第一个版本，从开始的1.0，已经发展到了5.0版本。LCN名称是由早期版本的LCN框架命名，在设计框架之初的1.0 ~ 2.0的版本时框架设计的步骤是如下,各取其首字母得来的LCN命名。

锁定事务单元（lock） 确认事务模块状态(confirm) 通知事务(notify)

5.0以后由于框架兼容了LCN、TCC、TXC三种事务模式，为了避免区分LCN模式，特此将LCN分布式事务改名为TX-LCN分布式事务框架。

2. 框架定位

LCN并不生产事务，LCN只是本地事务的协调工

TX-LCN定位于一款事务协调性框架，框架其本身并不操作事务，而是基于对事务的协调从而达到事务一致性的效果。

3. 解决方案

在一个分布式系统下存在多个模块协调来完成一次业务。那么就存在一次业务事务下可能横跨多种数据源节点的可能。TX-LCN将可以解决这样的问题。

例如存在服务模块A 、B、 C。A模块是mysql作为数据源的服务，B模块是基于redis作为数据源的服务，C模块是基于mongo作为数据源的服务。若需要解决他们的事务一致性就需要针对不同的节点采用不同的方案，并且统一协调完成分布式事务的处理。

方案：

若采用TX-LCN分布式事务框架，则可以将A模块采用LCN模式、B/C采用TCC模式就能完美解决。

4. SpringCloud集成TX-LCN

4.1 TX-LCN模块说明

Tx-Client(TC) Tx-Manager(TM). TC作为微服务下的依赖，TM是独立的服务

4.2 TM 配置与启动

4.2.1 所需配置

jdk1.8+

mysql5.6+

redis3.2+

4.2.2 导入数据库脚本

 
   
   
 
    
  
    
    
  
  1. /*
    2. 
  
    
    
  
  2.  Navicat Premium Data Transfer
    3. 
  
    
    
  

    4. 
  
    
    
  
  4.  Source Server : local
    5. 
  
    
    
  
  5.  Source Server Type : MySQL
    6. 
  
    
    
  
  6.  Source Server Version : 100309
    7. 
  
    
    
  
  7.  Source Host : localhost:3306
    8. 
  
    
    
  
  8.  Source Schema : tx-manager
    9. 
  
    
    
  

    10. 
  
    
    
  
  10.  Target Server Type : MySQL
    11. 
  
    
    
  
  11.  Target Server Version : 100309
    12. 
  
    
    
  
  12.  File Encoding : 65001
    13. 
  
    
    
  

    14. 
  
    
    
  
  14.  Date: 29/12/2018 18:35:59
    15. 
  
    
    
  
  15. */
    16. 
  
    
    
  
  16. CREATE DATABASE IF NOT EXISTS `tx-manager` DEFAULT CHARSET utf8 COLLATE utf8_general_ci;
    17. 
  
    
    
  
  17. USE `tx-manager`;
    18. 
  
    
    
  

    19. 
  
    
    
  
  19. SET NAMES utf8mb4;
    20. 
  
    
    
  
  20. SET FOREIGN_KEY_CHECKS = 0;
    21. 
  
    
    
  

    22. 
  
    
    
  
  22. -- ----------------------------
    23. 
  
    
    
  
  23. -- Table structure for t_tx_exception
    24. 
  
    
    
  
  24. -- ----------------------------
    25. 
  
    
    
  
  25. DROP TABLE IF EXISTS `t_tx_exception`;
    26. 
  
    
    
  
  26. CREATE TABLE `t_tx_exception`(
    27. 
  
    
    
  
  27. `id` bigint(20) NOT NULL AUTO_INCREMENT,
    28. 
  
    
    
  
  28. `group_id` varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL,
    29. 
  
    
    
  
  29. `unit_id` varchar(32) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL,
    30. 
  
    
    
  
  30. `mod_id` varchar(128) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL,
    31. 
  
    
    
  
  31. `transaction_state` tinyint(4) NULL DEFAULT NULL,
    32. 
  
    
    
  
  32. `registrar` tinyint(4) NULL DEFAULT NULL,
    33. 
  
    
    
  
  33. `ex_state` tinyint(4) NULL DEFAULT NULL COMMENT '0 待处理 1已处理',
    34. 
  
    
    
  
  34. `remark` varchar(10240) NULL DEFAULT NULL COMMENT '备注',
    35. 
  
    
    
  
  35. `create_time` datetime(0) NULL DEFAULT NULL,
    36. 
  
    
    
  
  36.  PRIMARY KEY (`id`) USING BTREE
    37. 
  
    
    
  
  37. ) ENGINE = InnoDB AUTO_INCREMENT = 967 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci ROW_FORMAT = Dynamic;
    38. 
  
    
    
  

    39. 
  
    
    
  
  39. SET FOREIGN_KEY_CHECKS = 1;
    40.

4.2.3 TM版本下载

https://github.com/codingapi/tx-lcn/releases

4.2.4 源码编译

编辑配置文件/tx-lcn/txlcn-tm/src/main/resources/application.properties如下：

 
   
   
 
    
  
    
    
  
  1. spring.application.name=TransactionManager
    2. 
  
    
    
  
  2. server.port=7970
    3. 
  
    
    
  
  3. spring.datasource.driver-class-name=com.mysql.jdbc.Driver
    4. 
  
    
    
  
  4. spring.datasource.url=jdbc:mysql://114.55.34.44:3306/tx-manager?characterEncoding=UTF-8
    5. 
  
    
    
  
  5. spring.datasource.username=root
    6. 
  
    
    
  
  6. spring.datasource.password=root
    7. 
  
    
    
  

    8. 
  
    
    
  
  8. #spring.jpa.database-platform=org.hibernate.dialect.MySQL5InnoDBDialect
    9. 
  
    
    
  
  9. #spring.jpa.hibernate.ddl-auto=update
    10. 
  
    
    
  

    11. 
  
    
    
  

    12. 
  
    
    
  
  12. mybatis.configuration.map-underscore-to-camel-case=true
    13. 
  
    
    
  
  13. mybatis.configuration.use-generated-keys=true
    14. 
  
    
    
  

    15. 
  
    
    
  
  15. #tx-lcn.logger.enabled=true
    16. 
  
    
    
  
  16. # TxManager Host Ip
    17. 
  
    
    
  
  17. #tx-lcn.manager.host=127.0.0.1
    18. 
  
    
    
  
  18. # TxClient连接请求端口
    19. 
  
    
    
  
  19. #tx-lcn.manager.port=8070
    20. 
  
    
    
  
  20. # 心跳检测时间(ms)
    21. 
  
    
    
  
  21. #tx-lcn.manager.heart-time=15000
    22. 
  
    
    
  
  22. # 分布式事务执行总时间
    23. 
  
    
    
  
  23. #tx-lcn.manager.dtx-time=30000
    24. 
  
    
    
  
  24. #参数延迟删除时间单位ms
    25. 
  
    
    
  
  25. #tx-lcn.message.netty.attr-delay-time=10000
    26. 
  
    
    
  
  26. #tx-lcn.manager.concurrent-level=128
    27. 
  
    
    
  
  27. # 开启日志
    28. 
  
    
    
  
  28. #tx-lcn.logger.enabled=true
    29. 
  
    
    
  
  29. #logging.level.com.codingapi=debug
    30. 
  
    
    
  
  30. #redis 主机
    31. 
  
    
    
  
  31. spring.redis.host=114.55.34.44
    32. 
  
    
    
  
  32. #redis 端口
    33. 
  
    
    
  
  33. spring.redis.port=6379
    34. 
  
    
    
  
  34. #redis 密码
    35. 
  
    
    
  
  35. spring.redis.password=root
    36.

注意：pom.xml文件中添加如下配置，否则无法正常运行

 
   
   
 
    
  
    
    
  
  1. <build>
    2. 
  
    
    
  
  2. <plugins>
    3. 
  
    
    
  
  3. <plugin>
    4. 
  
    
    
  
  4. <groupId>org.springframework.boot</groupId>
    5. 
  
    
    
  
  5. <artifactId>spring-boot-maven-plugin</artifactId>
    6. 
  
    
    
  
  6. </plugin>
    7. 
  
    
    
  
  7. </plugins>
    8. 
  
    
    
  
  8. </build>
    9.

编译：

 
   
   
 
    
  
    
    
  
  1. mvn clean package-Dmaven.test.skip=true
    2.

编译成功显示如下：

分布式事务-Tx-lcn

4.2.4 启动

 
   
   
 
    
  
    
    
  
  1. java -jar txlcn-tm-5.0.2.RELEASE.jar
    2.

成功启动，访问 http://127.0.0.1:7970/admin/index.html#/login 默认密码 codingapi

分布式事务-Tx-lcn

4.3 TC 微服务模块

4.3.1 微服务模块

服务A作为DTX发起方，远程调用服务B

4.3.2 引入maven依赖

 
   
   
 
    
  
    
    
  
  1. <dependency>
    2. 
  
    
    
  
  2. <groupId>com.codingapi.txlcn</groupId>
    3. 
  
    
    
  
  3. <artifactId>txlcn-tc</artifactId>
    4. 
  
    
    
  
  4. <version>5.0.2.RELEASE</version>
    5. 
  
    
    
  
  5. </dependency>
    6. 
  
    
    
  

    7. 
  
    
    
  
  7. <dependency>
    8. 
  
    
    
  
  8. <groupId>com.codingapi.txlcn</groupId>
    9. 
  
    
    
  
  9. <artifactId>txlcn-txmsg-netty</artifactId>
    10. 
  
    
    
  
  10. <version>5.0.2.RELEASE</version>
    11. 
  
    
    
  
  11. </dependency>
    12.

4.3.3 TC开启分布式事务注解

在主类上使用@EnableDistributedTransaction

 
   
   
 
    
  
    
    
  
  1. @SpringBootApplication
    2. 
  
    
    
  
  2. @EnableDistributedTransaction
    3. 
  
    
    
  
  3. publicclassDemoAApplication{
    4. 
  
    
    
  

    5. 
  
    
    
  
  5. publicstaticvoid main(String[] args) {
    6. 
  
    
    
  
  6. SpringApplication.run(DemoDubboClientApplication.class, args);
    7. 
  
    
    
  
  7. }
    8. 
  
    
    
  

    9. 
  
    
    
  
  9. }
    10.

TC微服务A业务方法配置

 
   
   
 
    
  
    
    
  
  1. @Service
    2. 
  
    
    
  
  2. publicclassServiceA{
    3. 
  
    
    
  

    4. 
  
    
    
  
  4. @Autowired
    5. 
  
    
    
  
  5. privateValueDao valueDao; //本地db操作
    6. 
  
    
    
  

    7. 
  
    
    
  
  7. @Autowired
    8. 
  
    
    
  
  8. privateServiceB serviceB;//远程B模块业务
    9. 
  
    
    
  

    10. 
  
    
    
  
  10. @LcnTransaction//分布式事务注解
    11. 
  
    
    
  
  11. @Transactional//本地事务注解
    12. 
  
    
    
  
  12. publicString execute(String value) throwsBusinessException{
    13. 
  
    
    
  
  13. // step1. call remote service B
    14. 
  
    
    
  
  14. String result = serviceB.rpc(value); // (1)
    15. 
  
    
    
  
  15. // step2. local store operate. DTX commit if save success, rollback if not.
    16. 
  
    
    
  
  16.  valueDao.save(value); // (2)
    17. 
  
    
    
  
  17.  valueDao.saveBackup(value); // (3)
    18. 
  
    
    
  
  18. return result + " > "+ "ok-A";
    19. 
  
    
    
  
  19. }
    20. 
  
    
    
  
  20. }
    21.

TC微服务B业务方法配置

 
   
   
 
    
  
    
    
  
  1. @Service
    2. 
  
    
    
  
  2. publicclassServiceB{
    3. 
  
    
    
  

    4. 
  
    
    
  
  4. @Autowired
    5. 
  
    
    
  
  5. privateValueDao valueDao; //本地db操作
    6. 
  
    
    
  

    7. 
  
    
    
  
  7. @LcnTransaction//分布式事务注解
    8. 
  
    
    
  
  8. @Transactional//本地事务注解
    9. 
  
    
    
  
  9. publicString rpc(String value) throwsBusinessException{
    10. 
  
    
    
  
  10.  valueDao.save(value); // (4)
    11. 
  
    
    
  
  11.  valueDao.saveBackup(value); // (5)
    12. 
  
    
    
  
  12. return"ok-B";
    13. 
  
    
    
  
  13. }
    14. 
  
    
    
  
  14. }
    15.

TC配置信息说明 默认之配置为TM的本机默认端口

tx-lcn.client.manager-address=127.0.0.1:8070

4.4 springcloud集成tx-lcn源码

https://github.com/FocusProgram/springcloud-txlcn


·END·

技术精选

专注技术，聚焦科技前沿



以上是关于分布式事务之TX-LCN的主要内容，如果未能解决你的问题，请参考以下文章

浅谈分布式事务与TX-LCN

TX-LCN：分布式事务框架

TX-LCN：分布式事务框架

tx-lcn探险

使用tx-lcn分布式事务框架无法连接远程TM管理服务

你知道什么是分布式事务吗