springcloud 分布式事务之 TX-LCN

蔚落 2022-12-27 02:12 74阅读 0赞

分为两个部分 协调器TM，多个TC,TM用来协调多个TC

TX-LCN 主要有两个模块，Tx-Client(TC) Tx-Manager(TM). TC作为微服务下的依赖，TM是独立的服务

模式特点：

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

TM端：

引入相关依赖

<dependency>
                <groupId>com.codingapi.txlcn</groupId>
                <artifactId>txlcn-tm</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>
            <dependency>
                <groupId>com.codingapi.txlcn</groupId>
                <artifactId>txlcn-txmsg-netty</artifactId>
                <version>5.0.2.RELEASE</version>
            </dependency>

配置文件 properties：

# TM事务管理器的服务端WEB访问端口。提供一个可视化的界面。端口自定义。
    server.port=7970
    
    # TM事务管理器，需要访问数据库，实现分布式事务状态记录。
    spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
    spring.datasource.url=jdbc:mysql://localhost:3306/tx-manager?characterEncoding=UTF-8&serverTimezone=Asia/Shanghai
    spring.datasource.username=root
    spring.datasource.password=root
    
    # TM事务管理器，是依赖Redis使用分布式事务协调的。尤其是TCC和TXC两种事务模型。
    spring.redis.host=127.0.0.1
    spring.redis.port=6379
    spring.redis.database=0
    
    # 为spring应用起名。
    spring.application.name=tx-lcn-transaction-manager
    
    # TM事务管理器，提供的WEB管理平台的登录密码。无用户名。 默认是codingapi
    tx-lcn.manager.admin-key=msb
    # 日志。如果需要TM记录日志。则开启，赋值为true，并提供后续的配置。
    tx-lcn.logger.enabled=true
    
    # 为日志功能，提供数据库连接。和之前配置的分布式事务管理依赖使用的数据源不同。
    tx-lcn.logger.driver-class-name=com.mysql.cj.jdbc.Driver
    tx-lcn.logger.jdbc-url=jdbc:mysql://localhost:3306/tx-manager?characterEncoding=UTF-8&serverTimezone=Asia/Shanghai
    tx-lcn.logger.username=root
    tx-lcn.logger.password=root

在启动类上增加注解：

@EnableTransactionManagerServer

TC 端（订单系统）

引入相关依赖

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

yml配置文件

server:
      port: 1001
    
    #应用名称及验证账号
    spring:
      application:
        name: lcn-order
    
    
      datasource:
        type: com.alibaba.druid.pool.DruidDataSource
        driver-class-name: com.mysql.cj.jdbc.Driver
        url: jdbc:mysql://localhost:3306/lcn-order?characterEncoding=UTF-8&serverTimezone=Asia/Shanghai
        username: root
        password: root
        dbcp2:
          initial-size: 5
          min-idle: 5
          max-total: 5
          max-wait-millis: 200
          validation-query: SELECT 1
          test-while-idle: true
          test-on-borrow: false
          test-on-return: false
    
    mybatis:
      mapper-locations:
      - classpath:mapper/*.xml
    
    eureka:
      client:
        service-url:
          defaultZone: http://localhost:7900/eureka/
    
    # tm配置
    tx-lcn:
      client:
        manager-address: 127.0.0.1:8070 #tm的地址，并非tm的服务端口号，是对外提供服务的端口

启动类上增加注解：

@EnableDistributedTransaction

业务方法配置，一般写在service 层，为了演示方便，我写在了controller层

增加本地事务和lcn事务

import com.codingapi.txlcn.tc.annotation.LcnTransaction;
    
    import net.sf.json.JSONObject;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.transaction.annotation.Transactional;
    import org.springframework.web.bind.annotation.PostMapping;
    import org.springframework.web.bind.annotation.RequestBody;
    import org.springframework.web.bind.annotation.RestController;
    import org.springframework.web.client.RestTemplate;
    
    @RestController
    public class OrderController {
    
    
        @Autowired
        private RestTemplate restTemplate;
    
        @PostMapping("/add-order")
        @Transactional(rollbackFor = Exception.class)
        @LcnTransaction
        public String add(@RequestBody 数据库实体类 bean){
    
            JSONObject date = new JSONObject();
            date.put("payName",bean.getOrderName()+"pay");
    
            restTemplate.postForEntity("http://lcn-pay/add-pay",date,String.class);
            
           //执行数据库操作
            ……
            
            return "新增订单成功";
        }
    }

TC端(支付系统  服务名称lcn-pay)

业务代码：

import com.codingapi.txlcn.tc.annotation.LcnTransaction;
    
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.transaction.annotation.Transactional;
    import org.springframework.web.bind.annotation.PostMapping;
    import org.springframework.web.bind.annotation.RequestBody;
    import org.springframework.web.bind.annotation.RestController;
    
    @RestController
    public class PayController {
    
    
    
        @PostMapping("/add-pay")
        @Transactional(rollbackFor = Exception.class)
        @LcnTransaction
        public String addPay(@RequestBody 实体类 bean){
           
            //执行数据库操作
            return "新增支付成功";
    
        }
    }

TM 可以配置集群：

这样客户端配置修改为

tx-lcn:
      client:
        manager-address: 127.0.0.1:8071,127.0.0.1:8072

参考文章：[https://www.codingapi.com/docs/txlcn-preface/][https_www.codingapi.com_docs_txlcn-preface]

[https_www.codingapi.com_docs_txlcn-preface]: https://www.codingapi.com/docs/txlcn-preface/