Tx-LCN SpringCloud分布式事务处理

小咪咪 2023-03-13 11:50 4阅读 0赞

TX-LCN官网http://www.txlcn.org/zh-cn/index.html

环境依赖：springboot2.0以上+springcloud+eureka+redis3.2+mysql5.6+feign

1.先新建一个springboot模块  
2.在pom文件中添加maven依赖：

<dependency>
        <groupId>com.codingapi.txlcn</groupId>
        <artifactId>txlcn-tm</artifactId>
        <version>5.0.2.RELEASE</version>
    </dependency>

3.在启动类上添加注解  
@EnableTransactionManagerServer

@SpringBootApplication
    @EnableTransactionManagerServer
    public class TransactionManagerApplication {
    
      public static void main(String[] args) {
          SpringApplication.run(TransactionManagerApplication.class, args);
      }
    
    }

4.填写配置  
填写配置前，先在mysql上创建一个数据库，名称为: tx-manager  
创建数据表:

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,
      `remark` varchar(4096) NULL DEFAULT  NULL,
      `ex_state` tinyint(4) NULL DEFAULT NULL COMMENT '0 未解决 1已解决',
      `create_time` datetime(0) NULL DEFAULT NULL,
      PRIMARY KEY (`id`) USING BTREE
    ) ENGINE = InnoDB AUTO_INCREMENT = 1 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci ROW_FORMAT = Dynamic;

根据你自己环境配置，主要是数据库地址和注册中心的地址

spring.application.name=tx-manager
    server.port=7970
    
    spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
    spring.datasource.url=jdbc:mysql://localhost:3306/tx-manager?characterEncoding=UTF-8
    spring.datasource.username=root
    spring.datasource.password=root
    #指定注册中心地址
    eureka.client.serviceUrl.defaultZone= http://localhost:8761/eureka/
    eureka.instance.instance-id=${spring.cloud.client.ip-address}:${server.port}
    eureka.instance.prefer-ip-address=true
    
    mybatis.configuration.map-underscore-to-camel-case=true
    mybatis.configuration.use-generated-keys=true
    
    # TxManager Host Ip
    tx-lcn.manager.host=127.0.0.1
    # TxClient连接请求端口
    tx-lcn.manager.port=8070
    # 心跳检测时间(ms)
    tx-lcn.manager.heart-time=15000
    # 分布式事务执行总时间
    tx-lcn.manager.dtx-time=30000
    #参数延迟删除时间单位ms
    tx-lcn.message.netty.attr-delay-time=10000
    tx-lcn.manager.concurrent-level=128
    # 开启日志
    tx-lcn.logger.enabled=true
    logging.level.com.codingapi=debug
    #redis 主机
    spring.redis.host=127.0.0.1
    #redis 端口
    spring.redis.port=6379
    #redis 密码
    spring.redis.password=

5.到此你的tm已经配置完成了，启动这个服务，打开浏览器访问http://localhost:7970/admin/index.html\#/login  
你可以看到tx-manager的后台管理，类似注册中心那种，可以看到你有哪些服务需要做事务处理的。登录的默认密码为codingapi  
![已注册的TC就是你要做事务的客服端，这里称为tc-client][TC_tc-client]

已注册的TC就是你要做事务的客服端，这里称为tc-client  
六、配置tc-client  
就是你要做事务的哪些微服务  
在你要做事务处理的每一个tc-client中添加如下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>

然后在启动类上加入注解  
@EnableDistributedTransaction

@SpringBootApplication
    @EnableDistributedTransaction
    public class DemoAApplication {
    
        public static void main(String[] args) {
            SpringApplication.run(DemoDubboClientApplication.class, args);
        }
    
    }

然后在你需要做的事务事务的方法上加入注解@LcnTransaction //分布式事务注解  
比如：这里两个服务，A服务给B服务转钱，A服务减一百，B服务加一百。这个处理就需要做事务处理了，以保证数据的一致性。  
那在A服务Service层上加入注解@LcnTransaction，A的服务层去调用B服务，在B服务中的service成也需要加上@LcnTransaction注解,在每个service方法上也要加上本地事务注解@Transaction  
在你处理的整个业务的时候，如果需要事务处理，那你就得在再涉及到你这个业务所有服务的所对应的处理的service层加上注解。  
最后说一下，在每一个tc-client配置文件中需要制定tx-manager的地址，因为我用的是默认配置，所以没有写。若有修改tx-manager 在tc-client中添加如下配置  
默认之配置为TM的本机默认端口  
tx-lcn.client.manager-address=127.0.0.1:8070  
七、github地址：[https://github.com/zhangjunli16811/tx-lcn-springcloud-transaction][https_github.com_zhangjunli16811_tx-lcn-springcloud-transaction]  
觉得不错的小伙伴可以去star一下哦。  
如果通过feign 调用时，feign注解中加了fallbackFactory =xxx.class的话；在Fallback方法里面加上这个  
DTXUserControls.rollbackGroup(TracingContext.tracing().groupId());

[TC_tc-client]: /images/20230312/c16135aa8ce24471b9e377352892520a.png
[https_github.com_zhangjunli16811_tx-lcn-springcloud-transaction]: https://github.com/zhangjunli16811/tx-lcn-springcloud-transaction