springboot2.x集成lcn5.0.2分布式事务

忘是亡心i 2024-04-18 08:05 40阅读 0赞

### springboot2.x集成lcn5.0.2分布式事务 ###

*  本地运行tx-manager
 *  客户端集成lcn
 *  lcn框架理解
 *   *  lcn实现原理
     *  tx-lcn三种模式
     *  事务控制原理
     *   *  核心步骤

[LCN文档查看][LCN]  
[LCNgithub代码下载][LCNgithub]

# 本地运行tx-manager #

代码从github下载后导入IDEA目录如下：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MTIwNTE0OA_size_16_color_FFFFFF_t_70]

1.1、修改**application.properties**(\\txlcn-tm\\src\\main\\resources)配置文件

spring.application.name=TransactionManager
    server.port=7970
    
    ###############数据库##################################
    spring.datasource.driver-class-name=com.mysql.jdbc.Driver
    spring.datasource.url=jdbc:mysql://192.168.130.200:3306/tx-manager?useUnicode=true&characterEncoding=utf8&useSSL=false&allowMultiQueries=true
    spring.datasource.username=pica_dev
    spring.datasource.password=pkv#sqvSGn@O1@tg
    # 验证连接是否有效。此参数必须设置为非空字符串，下面三项设置成true才能生
    spring.datasource.validationQuery=SELECT 1
    # 指明连接是否被空闲连接回收器(如果有)进行检验.如果检测失败,则连接将被从池中去除.
    spring.datasource.testWhileIdle=true
    # 指明是否在从池中取出连接前进行检验,如果检验失败,则从池中去除连接并尝试取出另一个
    spring.datasource.testOnBorrow=true
    # 指明是否在归还到池中前进行检验
    spring.datasource.testOnReturn=false
    
    # 以下可省略
    # 初始化大小，最小，最大
    spring.datasource.initialSize=5
    spring.datasource.minIdle=10
    spring.datasource.maxActive=1000
    # 配置获取连接等待超时的时间
    spring.datasource.maxWait=60000
    #配置间隔多久才进行一次检测，检测需要关闭的空闲连接，单位是毫秒
    spring.datasource.timeBetweenEvictionRunsMillis=60000
    #配置一个连接在池中最小生存的时间，单位是毫秒
    spring.datasource.minEvictableIdleTimeMillis=300000
    #打开PSCache，并且指定每个连接上PSCache的大小
    spring.datasource.poolPreparedStatements=true
    spring.datasource.maxPoolPreparedStatementPerConnectionSize=20
    #配置监控统计拦截的filters，去掉后监控界面sql无法统计，'wall'用于防火墙
    spring.datasource.filters=stat,wall,log4j
    #通过connectProperties属性来打开mergeSql功能；慢SQL记录
    spring.datasource.connectionProperties=druid.stat.mergeSql=true;druid.stat.slowSqlMillis=1000;druid.stat.logSlowSql=true
    #合并多个DruidDataSource的监控数据
    spring.datasource.useGlobalDataSourceStat=true
    #spring.datasource.WebStatFilter.exclusions="*.js,*.gif,*.jpg,*.png,*.css,*.ico,/druid/*"
    #spring.datasource.stat-view-servlet.login-username=admin
    #spring.datasource.stat-view-servlet.login-password=admin
    
    ####################### 数据库方言 ############################################
    spring.jpa.database-platform=org.hibernate.dialect.MySQL5InnoDBDialect
    # 第一次运行可以设置为: create, 为TM创建持久化数据库表
    spring.jpa.hibernate.ddl-auto=update
    
    ####################### Redis ############################################
    spring.redis.host=192.168.110.241
    spring.redis.port=6380
    spring.redis.password=
    
    ####################### 事务 ############################################
    # TM监听IP. 默认为 127.0.0.1
    tx-lcn.manager.host=127.0.0.1
    # TM监听Socket端口. 默认为 ${ server.port} - 100
    tx-lcn.manager.port=8070
    # 心跳检测时间(ms). 默认为 300000
    tx-lcn.manager.heart-time=300000
    # 分布式事务执行总时间(ms). 默认为36000
    tx-lcn.manager.dtx-time=8000
    # 参数延迟删除时间单位ms  默认为dtx-time值
    tx-lcn.message.netty.attr-delay-time=${ tx-lcn.manager.dtx-time}
    # 事务处理并发等级. 默认为机器逻辑核心数5倍
    tx-lcn.manager.concurrent-level=160
    # TM后台登陆密码，默认值为codingapi
    tx-lcn.manager.admin-key=123456
    # 分布式事务锁超时时间 默认为-1，当-1时会用tx-lcn.manager.dtx-time的时间
    tx-lcn.manager.dtx-lock-time=${ tx-lcn.manager.dtx-time}
    # 雪花算法的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/393538042@qq.com
    # 开启日志记录
    tx-lcn.logger.enabled=true

1.2、修改/txlcn-tm/pom.xml 文件 注释掉docker构建代码，使用maven构建

<?xml version="1.0" encoding="UTF-8"?>
    <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
        <modelVersion>4.0.0</modelVersion>
        <parent>
            <groupId>com.codingapi.txlcn</groupId>
            <artifactId>tx-lcn</artifactId>
            <version>5.0.2.RELEASE</version>
        </parent>
    
        <artifactId>txlcn-tm</artifactId>
        <version>5.0.2.RELEASE</version>
        <packaging>jar</packaging>
    
        <dependencies>
    
            <dependency>
                <groupId>com.codingapi.txlcn</groupId>
                <artifactId>txlcn-logger</artifactId>
            </dependency>
    
            <dependency>
                <groupId>com.codingapi.txlcn</groupId>
                <artifactId>txlcn-common</artifactId>
            </dependency>
    
            <dependency>
                <groupId>com.codingapi.txlcn</groupId>
                <artifactId>txlcn-txmsg-netty</artifactId>
            </dependency>
    
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
    
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-data-redis</artifactId>
            </dependency>
    
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-mail</artifactId>
            </dependency>
    
            <dependency>
                <groupId>mysql</groupId>
                <artifactId>mysql-connector-java</artifactId>
            </dependency>
    
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-data-jpa</artifactId>
            </dependency>
    
        </dependencies>
    
    
        
        <build>
            <plugins>
                <plugin>
                    <groupId>org.apache.maven.plugins</groupId>
                    <artifactId>maven-jar-plugin</artifactId>
                    <version>2.6</version>
                    <configuration>
                        <archive>
                            <manifest>
                                <mainClass>com.codingapi.txlcn.tm.TMApplication</mainClass>
                                <addClasspath>true</addClasspath>
                                <classpathPrefix>lib/</classpathPrefix>
                            </manifest>
                            <manifestEntries>
                                <Class-Path>./</Class-Path>
                            </manifestEntries>
                        </archive>
                        <excludes>
                            <exclude>config/**</exclude>
                        </excludes>
                    </configuration>
                </plugin>
    
                <plugin>
                    <artifactId>maven-assembly-plugin</artifactId>
                    <configuration>
                        <appendAssemblyId>false</appendAssemblyId>
                        <descriptors>
                            <descriptor>src/main/build/package.xml</descriptor>
                        </descriptors>
                    </configuration>
                    <executions>
                        <execution>
                            <id>make-assembly</id>
                            <phase>package</phase>
                            <goals>
                                <goal>single</goal>
                            </goals>
                        </execution>
                    </executions>
                </plugin>
    
                
                
                    
                    
                    
                    
                        
                        
                        
                            
                                
                                
                                
                            
                        
                        
                            
                        
    
                        
                        
                    
                
    
            </plugins>
        </build>
    </project>

1.3、tx-manager启动类如下：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MTIwNTE0OA_size_16_color_FFFFFF_t_70 1]

1.3、奔跑起来吧，代码(/txlcn-tm/src/main/java/com/codingapi/txlcn/tm/TMApplication.java)  
访问：http://localhost:7970/admin/index.html  
数据配置好的密码：123456  
![tx-manager后台登录页面][tx-manager]  
![tx-manager首页][tx-manager 1]

# 客户端集成lcn #

2.1、pom.xml引入依赖

<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>

2.2、所有需要使用LCN分布式事务的微服务项目，无论是调用方，还是被调用方的启动类都需要加上@EnableDistributedTransaction注解，否则分布式事务不生效  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MTIwNTE0OA_size_16_color_FFFFFF_t_70 2]

2.3、所有需要使用LCN分布式事务的微服务项目，application.yml配置文件都要引入如下配置，将服务注册到LCN事务管理者里面

#lcn分布式事务   
    tx-lcn:
      client:
        manager-address: 127.0.0.1:7970

2.4、客户端调用方法开启分布式事务

服务A：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MTIwNTE0OA_size_16_color_FFFFFF_t_70 3]

服务B:  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MTIwNTE0OA_size_16_color_FFFFFF_t_70 4]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MTIwNTE0OA_size_16_color_FFFFFF_t_70 5][]

特别注意：无论是调用方，还是被调用方，都需要设置开启分布式事务，如果有任何一方不开启，则分布式事务不生效

# lcn框架理解 #

## lcn实现原理 ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MTIwNTE0OA_size_16_color_FFFFFF_t_70 6]

1.  LCN客户端（发起方和参与方都必须要注册到事务协调者中）， 建立一个长连接。（长连接 减宽带 但是消耗内存 连接后不断开）
2.  订单服务（发起方）调用库存服务接口（参与方）之前，会向TxManager事务协调者创建一个事务的分组id。
3.  订单服务（发起方）调用库存服务接口（参与方）的时候，会在请求头（底层是HTTP协议，LCN底层重写了Feigin客户端）中存放该事务的分组id，给库存服务。  
    （TxClient的代理连接池实现了Javax.sql.DataSource接口，并重写了close方法，事务模块在提交关闭后，TxClient连接池将执行‘假关闭’操作，等待TxManager协调完成事务后再关闭连接）
4.  如果库存服务获取到请求头中有对应的事务分组id，库存服务业务逻辑代码执行完毕的，会采用假关闭，不会提交该事务。

微服务里面的服务和服务之间 协调在一起 通过注册中心。  
分布式是事务中， 解决事务和事务之间的关系 靠的是类似的平台 TxManager 去协调事务

1.  参与方在什么时候提交事务，不能一直不提交。  
    肯定在发起方 执行成功下。  
    订单服务（发起方）调用库存服务接口（参与方）之后，如果订单服务（发起方）执行没有问题的下，  
    订单服务（发起方）使用对应的事务分组id，通知给TxManager事务协调者，让后TxManager事务协调者在根据该事务分组id，通知给所有的参与方提交事务。

**PS：长连接 好处减少宽带传输 弊端比较占内存。**  
使用LCN很简单 加个注解就OK了  
需要redis，事务分组ID都是缓存到Redis中的

## tx-lcn三种模式 ##

LCN5.0.2有3种模式，分别是LCN模式，TCC模式，TXC模式

*  lcn模式：

>  *  该模式对代码的嵌入性为低。
>  *  该模式仅限于本地存在连接对象且可通过连接对象控制事务的模块。
>  *  该模式下的事务提交与回滚是由本地事务方控制，对于数据一致性上有较高的保障。
>  *  该模式缺陷在于代理的连接需要随事务发起方一共释放连接，增加了连接占用的时间。

*  TCC模式：  
    TCC事务机制相对于传统事务机制（X/Open XA Two-Phase-Commit），其特征在于它不依赖资源管理器(RM)对XA的支持，而是通过对（由业务系统提供的）业务逻辑的调度来实现分布式事务。主要由三步操作，Try: 尝试执行业务、 Confirm:确认执行业务、 Cancel: 取消执行业务。  
    该模式的特点：

>  *  该模式对代码的嵌入性高，要求每个业务需要写三种步骤的操作。
>  *  该模式对有无本地事务控制都可以支持使用面广。
>  *  数据一致性控制几乎完全由开发者控制，对业务开发难度要求高。

*  TXC模式：  
    TXC模式命名来源于淘宝，实现原理是在执行SQL之前，先查询SQL的影响数据，然后保存执行的SQL快走信息和创建锁。当需要回滚的时候就采用这些记录数据回滚数据库，目前锁实现依赖redis分布式锁控制。  
    该模式的特点：

>  *  该模式同样对代码的嵌入性低。
>  *  该模式仅限于对支持SQL方式的模块支持。
>  *  该模式由于每次执行SQL之前需要先查询影响数据，因此相比LCN模式消耗资源与时间要多。
>  *  该模式不会占用数据库的连接资源。

## 事务控制原理 ##

TX-LCN由两大模块组成, TxClient、TxManager，TxClient作为模块的依赖框架，提供TX-LCN的标准支持，TxManager作为分布式事务的控制放。事务发起方或者参与反都由TxClient端来控制。  
原理图：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MTIwNTE0OA_size_16_color_FFFFFF_t_70 7]

### 核心步骤 ###

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

[LCN]: http://www.txlcn.org/zh-cn/docs/preface.html
[LCNgithub]: https://github.com/codingapi/tx-lcn
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MTIwNTE0OA_size_16_color_FFFFFF_t_70]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/17/6dc3798ecf144657bb971442d6d44c36.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MTIwNTE0OA_size_16_color_FFFFFF_t_70 1]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/17/ecc49cefbcc04156820ae74758f27c4a.png
[tx-manager]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/17/806d98d379e941c49167651f1c41daac.png
[tx-manager 1]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/17/44e864d040774b2bbe3f48794d6d5cdb.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MTIwNTE0OA_size_16_color_FFFFFF_t_70 2]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/17/dc09cb7f07204fd6b84dc3e37364fd31.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MTIwNTE0OA_size_16_color_FFFFFF_t_70 3]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/17/71ede463996743b290fa39f6a1b91965.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MTIwNTE0OA_size_16_color_FFFFFF_t_70 4]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/17/f62581393f6c415c942795e368884553.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MTIwNTE0OA_size_16_color_FFFFFF_t_70 5]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/17/e07697a406e6456d85245ddc6cb3330e.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MTIwNTE0OA_size_16_color_FFFFFF_t_70 6]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/17/08030110f7b7476b9caba45c5f305a65.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MTIwNTE0OA_size_16_color_FFFFFF_t_70 7]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/17/409917fcb72146e7acc04f24fce8ef7e.png