前提

本文不介绍LCN理论知识，如不清楚，建议先通过文章进行了解，8种常用的分布式事务解决方案详细分析，该文章中有关于LCN模式的简要说明。

快速开始

1、环境准备

环境依赖：

JDK1.8+、Mysql5.6+、Redis3.2+

数据库初始化脚本：

创建数据库名称为：tx-manager，并在此数据库下新建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(32) 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(32) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL,
  `transaction_state` tinyint(4) NULL DEFAULT NULL,
  `registrar` tinyint(4) NULL DEFAULT NULL COMMENT '-1 未知 0 Manager 通知事务失败， 1 client询问事务状态失败2 事务发起方关闭事务组失败',
  `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 = 967 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci ROW_FORMAT = Dynamic;

SET FOREIGN_KEY_CHECKS = 1;

2、TM角色服务准备

新建一个最基础的SpringBoot工程

添加配置文件

#服务名
spring.application.name=tx-manager
#端口
server.port=7970

#数据库配置
spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
spring.datasource.url=jdbc:mysql://10.0.0.50:3306/tx-manager?characterEncoding=UTF-8&serverTimezone=Asia/Shanghai
spring.datasource.username=root
spring.datasource.password=123456

#mybatis配置
mybatis.configuration.map-underscore-to-camel-case=true
mybatis.configuration.use-generated-keys=true

#redis配置
spring.redis.host=10.0.0.150
spring.redis.port=6379

#开启日志
tx-lcn.logger.enabled=true

#TxManager Host IP
tx-lcn.manager.host=127.0.0.1
#TxClient 连接请求端口
tx-lcn.manager.port=8070

pom依赖

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

添加注解

SpringApplication，只需要添加一个@EnableTransactionManagerServer即可

import com.codingapi.txlcn.tm.config.EnableTransactionManagerServer;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
@EnableTransactionManagerServer
public class LcnTmApplication {

    public static void main(String[] args) {
        SpringApplication.run(LcnTmApplication.class, args);
    }

}

验证

TM最基础的准备就已经完成了，启动服务，访问7970端口，登录TM提供的后台管理，密码默认codingapi。

3、TC模块准备

由于最终需要演示分布式事务，需要TC准备两台SpringCloud服务，服务之间通过Feign进行远程调用。

配置文件

TC端的配置文件修改很简单，只需要额外添加一个配置项即可

#之间在TM服务里配置的IP、TxClient连接请求端口
tx-lcn.client.manager-address=127.0.0.1:8070

pom依赖

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

添加启动注解

SpringApplication，也只需要添加一个@EnableDistributedTransaction即可

import com.codingapi.txlcn.tc.config.EnableDistributedTransaction;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.circuitbreaker.EnableCircuitBreaker;
import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
import org.springframework.cloud.openfeign.EnableFeignClients;
import org.springframework.context.annotation.Bean;
import org.springframework.web.client.RestTemplate;

@EnableEurekaClient
@SpringBootApplication
@EnableFeignClients
@EnableCircuitBreaker
@EnableDistributedTransaction
@MapperScan("com.wyl.springcloud.mapper")
public class MembershipApplication {

    public static void main(String[] args) {
        SpringApplication.run(MembershipApplication.class, args);
    }

    @Bean
    @LoadBalanced
    public RestTemplate restTemplate() {
        return new RestTemplate();
    }
}

再搭一个配置一样的服务，最终准备好两台服务，一台order服务，一台member服务。

TC端事务方法添加注解

order服务

    /**
     * 通过添加@LcnTransaction注解，控制分布式事务
     */
    @LcnTransaction
    public void update() {
        ///本地事务
        userMapper.update();
    }

member服务

    /**
     * 通过添加@LcnTransaction注解，控制分布式事务
     */
    @LcnTransaction
    public void update() {
        //通过feign远程调用order服务
        orderFeign.update();
        //本地事务
        userMapper.update();
        //模拟远程调用后，本地执行异常
        int i = 1/0;
    }

验证

启动两台服务后，再看TM系统观后，服务已在线。

4、调用流程说明

演示两台服务之间的调用流程

演示业务表

当前tran_test表数据。

异常、回滚

调用服务，异常

两条数据都未被修改，达到分布式事务效果。

正常完成请求调用

把member服务的本地异常去掉，再次尝试。

    /**
     * 通过添加@LcnTransaction注解，控制分布式事务
     */
    @LcnTransaction
    public void update() {
        //通过feign远程调用order服务
        orderFeign.update();
        //本地事务
        userMapper.update();
        //模拟远程调用后，本地执行异常
        //int i = 1/0;
    }

调用成功

数据修改成功