4LCN-TXC模式 · SpringCloud微服务实战 · 看云

导航

本节代码地址

GitHub:https://github.com/xuyisu/fw-spring-cloud/tree/master/fw-cloud-transaction/fw-cloud-transaction-lcn/fw-cloud-transaction-lcn-txc
GitHub:https://github.com/xuyisu/fw-spring-cloud/tree/master/fw-cloud-transaction/fw-cloud-transaction-lcn/fw-cloud-transaction-lcn-txmanager

1. 原理介绍：

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

2. 模式特点:

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

3. 环境准备

中间件 版本
MySQL（可以参照容器化章节） 5.7+
Redis（可以参照容器化章节） 4.0+

3.1 数据库准备

新建fw-txmanager数据库，并且执行以下脚本创建异常表，表名不能变。

CREATE TABLE `t_tx_exception` (
  `id` bigint(20) NOT NULL AUTO_INCREMENT,
  `group_id` varchar(64) DEFAULT NULL,
  `unit_id` varchar(32) DEFAULT NULL,
  `mod_id` varchar(128) DEFAULT NULL,
  `transaction_state` tinyint(4) DEFAULT NULL,
  `registrar` tinyint(4) DEFAULT NULL,
  `remark` varchar(4096) DEFAULT NULL,
  `ex_state` tinyint(4) DEFAULT NULL COMMENT '0 未解决 1已解决',
  `create_time` datetime DEFAULT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='tx-manager异常表'

4. 新建TXC 模块

本模块中我们将新建两个模块，我们将模拟电商购物环节中的下单->发货的过程，两个服务通过Feign进行远程调用。两个模块的名称分别为fw-cloud-transaction-lcn-txc-order和fw-cloud-transaction-lcn-txc-send

4.1 maven 依赖

两个模块所使用的依赖也是相同的，这里可以看到，我们依赖了上面封装的fw-cloud-transaction-base-dao，不需要再自己写基本的mapper等，因为是基于Eureka 服务发现和Feign 远程调用的，因此引入了响应的包。其中最重要的就是引入txlcn-tc，txlcn-txmsg-netty包，否者不能实现和TxManager的通信及事务控制。

<dependencies>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
    <!-- base-dao -->
    <dependency>
        <groupId>com.yisu.cloud</groupId>
        <artifactId>fw-cloud-transaction-base-dao</artifactId>
        <version>${version}</version>
    </dependency>
    <!-- TC依赖 -->
    <dependency>
        <groupId>com.codingapi.txlcn</groupId>
        <artifactId>txlcn-tc</artifactId>
    </dependency>
    <!-- TC和TM通信依赖于Netty -->
    <dependency>
        <groupId>com.codingapi.txlcn</groupId>
        <artifactId>txlcn-txmsg-netty</artifactId>
    </dependency>
    <!--服务发现-->
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
    </dependency>
    <!--feign-->
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-openfeign</artifactId>
    </dependency>
    <!-- 数据连接池-->
    <dependency>
        <groupId>com.zaxxer</groupId>
        <artifactId>HikariCP</artifactId>
        <version>${HikariCP.version}</version>
    </dependency>
</dependencies>

并在MySql中新建fw_transaction库,并执行以下脚本，供fw-cloud-transaction-lcn-txc-order和fw-cloud-transaction-lcn-txc-send使用

CREATE TABLE `fw_trade_log` (
  `id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT '主键id',
  `status` tinyint(3) unsigned NOT NULL DEFAULT '0' COMMENT '订单状态 1.待支付 2.待发货 3.待收货 4.订单完成 5.订单关闭',
  `status_dsc` varchar(100) CHARACTER SET utf8 DEFAULT '' COMMENT '状态描述',
  `product_id` bigint(20) NOT NULL DEFAULT '0' COMMENT '商品id',
  `product_name` varchar(100) NOT NULL DEFAULT '' COMMENT '商品名称',
  `user_id` bigint(20) NOT NULL DEFAULT '0' COMMENT '用户id',
  `order_id` bigint(20) NOT NULL DEFAULT '0' COMMENT '订单id',
  `order_amount` decimal(10,2) NOT NULL DEFAULT '0.00' COMMENT '订单总额',
  `create_time` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '创建时间',
  PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='订单表'

4.2 fw-cloud-transaction-lcn-txc-order模块

4.2.1 订单接口创建

再订单模块中创建一个订单接口，并在接口中设置支付成功的方法


public interface OrderService{

    
    void saveAndPayOrder(String productName);

}

4.2.2 订单接口实现

订单在支付成功以后会远程调用发货服务进行发货，需要在Service 上加上@Transactional，开启本地事务


@Service
@Slf4j
public class OrderServiceImpl implements OrderService {

    @Autowired
    private FwTradeLogService fwTradeLogService;

    @Autowired
    private RemoteSendServiceFeign remoteSendServiceFeign;


    @Transactional
    @Override
    public void saveAndPayOrder(String productName) {

        FwTradeLog fwTradeLog =new FwTradeLog(StatusEnum.TWO);
        fwTradeLog.setProductId(System.currentTimeMillis());
        fwTradeLog.setProductName(productName);
        fwTradeLogService.save(fwTradeLog);
        log.info("[订单状态{}]=>{},当前商品id=>{},商品名称=>{}",fwTradeLog.getOrderId(), StatusEnum.TWO.getDesc(),fwTradeLog.getProductId(),fwTradeLog.getProductName());

        remoteSendServiceFeign.sendOrder(fwTradeLog);
        
    }



}

4.2.3 Feign 接口配置

这里我们配置远程调用的服务名称是fw-transaction-lcn-txc-send，并且设置了fallback，并且指定了远程调用的方法是sendOrder。

@FeignClient(value = "fw-transaction-lcn-tcc-send", fallbackFactory = RemoteSendServiceFallback.class)
public interface RemoteSendServiceFeign {

    @PostMapping("send")
    void sendOrder(@RequestBody  FwTradeLog tradeLog);
}

4.2.4 Fallback 接口配置

在fallback输出异常日志

@Component
@Slf4j
public class RemoteSendServiceFallback implements FallbackFactory<RemoteSendServiceFeign> {

    @Override
    public RemoteSendServiceFeign create(Throwable throwable) {

        return tradeLog -> log.error("远程调用失败",throwable);
    }
}

4.2.5 Controller 控制层

配置订单服务对外的接口，方便演示


@RestController
public class OrderController {

    @Autowired
    private OrderService orderService;

    
    @GetMapping("saveOrder")
    public FwResult saveOrder(String productName){
         orderService.saveAndPayOrder(productName);
         return FwResult.ok();
    }


}

4.2.6 启动类配置

这里需要加上@EnableDistributedTransaction开启分布式的调用，加上@EnableFeignClients开启Feign的远程调用，加上@EnableDiscoveryClient开启服务的注册和发现。

@EnableDistributedTransaction
@SpringBootApplication
@EnableFeignClients
@EnableDiscoveryClient
public class FwTransactionLcnTxcOrderApplication {
    public static void main(String[] args) {
        SpringApplication.run(FwTransactionLcnOrderApplication.class, args);
    }


}

4.2.7 应用配置

配置中需要配置数据库和Redis的基本信息，以及TxManager的连接信息，并且设置了Eureka的连接信息和开启Feign的远程调用

server:
  port: 9002
spring:
  application:
    name: fw-transaction-lcn-txc-order
  #数据库配置  start
  datasource:
    type: com.zaxxer.hikari.HikariDataSource
    url: jdbc:mysql://${dbIp}:3306/fw_transaction?useUnicode=true&characterEncoding=utf8&allowMultiQueries=true&useSSL=false
    username: root
    password: 123456
    driver-class-name: com.mysql.jdbc.Driver
    hikari:
      connection-timeout: 20000
      auto-commit: true
      max-lifetime: 1200000
      minimum-idle: 5
      maximum-pool-size: 12
      idle-timeout: 300000
  redis:
    port: 6379
    host: ${redisIp}
    database: 0
    password: 123456
eureka:
  client:
    service-url:
      defaultZone: http://localhost:8761/eureka/
tx-lcn:
  client:
    manager-address: 127.0.0.1:8888
  logger:
    enabled: true
feign:
  hystrix:
    enabled: true
hystrix:
  shareSecurityContext: true #设置为true，这样做会自动配置Hystrix并发策略插件挂钩，将SecurityContext从主线程传输到Hystrix命令使用的线程

4.3 fw-cloud-transaction-lcn-txc-send模块

4.3.1 发货接口创建

配置发货接口，并且创建发货的方法


public interface SendService {

    
    void sendOrder(FwTradeLog fwTradeLog);

}

4.3.2 发货接口实现

这里在实现方法上加上@TxcTransaction，并且设置订单的状态为待收货，设置事务的超时时间为2000毫秒，默认是0


@Service
@Slf4j
public class SendServiceImpl implements SendService {

    @Autowired
    private FwTradeLogService fwTradeLogService;

    ConcurrentHashMap<String, Long> hashMap = new ConcurrentHashMap<>();

    @TxcTransaction(timeout = 2000)
    @Override
    public void sendOrder(FwTradeLog fwTradeLog) {
        fwTradeLog.setStatus(StatusEnum.THREE.getValue());
        fwTradeLog.setStatusDsc(StatusEnum.THREE.getDesc());
        fwTradeLogService.save(fwTradeLog);
        log.info("[订单状态{}]=>{},当前商品id=>{},商品名称=>{}",fwTradeLog.getOrderId(), StatusEnum.THREE.getDesc(),fwTradeLog.getProductId(),fwTradeLog.getProductName());
        hashMap.put(TracingContext.tracing().groupId(), fwTradeLog.getId());
    }
}

4.3.3 发货控制层实现

提供给订单模块调用的接口，注意方法名和请求方式要保持一致


@RestController
public class SendController {

    @Autowired
    private SendService sendService;

    
    @PostMapping("send")
    public void sendOrder(@RequestBody FwTradeLog tradeLog) {
         sendService.sendOrder(tradeLog);
    }
}

4.3.4 启动类

需要加上@EnableDistributedTransaction注解开启分布式事务，加上@EnableDiscoveryClient注解开启服务的注册与发现


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


}

4.3.5 应用配置

配置中需要配置数据库和Redis的基本信息，以及TxManager的连接信息，并且设置了Eureka的连接信息和开启Feign的远程调用

server:
  port: 9003
spring:
  application:
    name: fw-transaction-lcn-txc-send
  #数据库配置  start
  datasource:
    type: com.zaxxer.hikari.HikariDataSource
    url: jdbc:mysql://${dbIp}:3306/fw_transaction?useUnicode=true&characterEncoding=utf8&allowMultiQueries=true&useSSL=false
    username: root
    password: 123456
    driver-class-name: com.mysql.jdbc.Driver
    hikari:
      connection-timeout: 20000
      auto-commit: true
      max-lifetime: 1200000
      minimum-idle: 5
      maximum-pool-size: 12
      idle-timeout: 300000
  redis:
    port: 6379
    host: ${redisIp}
    database: 0
    password: 123456
eureka:
  client:
    service-url:
      defaultZone: http://localhost:8761/eureka/
tx-lcn:
  client:
    manager-address: 127.0.0.1:8888

4.4 启动服务

分别启动Eureka、fw-transaction-lcn-txc-send、fw-transaction-lcn-txc-order
7d827bd9ed381221eeed404b04beb991_MD5.png

TxManager 可以看到两个事务注册上来
659040ec6b1d9d4ce1a41306a8873294_MD5.png

Postman输入localhost:9002/saveOrder
af1cea21c04c3aca13756054649dac97_MD5.png

可以看到订单服务的日志如下

2020-04-06 20:10:22.292  INFO 3829 --- [nio-9002-exec-1] c.y.t.l.o.service.impl.OrderServiceImpl  : [订单状态348582]=>待发货,当前商品id=>1586094502191,商品名称=>Mac pro 2019款

发货服务的日志如下

2020-04-06 20:10:23.202  INFO 3841 --- [nio-9003-exec-1] c.y.t.l.s.service.impl.SendServiceImpl   : [订单状态348582]=>待收货,当前商品id=>1586094502191,商品名称=>Mac pro 2019款

数据库记录两条记录
c0479f4ced6ccd964c1c57292defc86e_MD5.png

现在让订单服务的方法抛出异常
直接在方法中加一个抛异常的语句int i=1/0;，如下所示

@Transactional
@Override
public void saveAndPayOrder(String productName) {

    FwTradeLog fwTradeLog =new FwTradeLog(StatusEnum.TWO);
    fwTradeLog.setProductId(System.currentTimeMillis());
    fwTradeLog.setProductName(productName);
    fwTradeLogService.save(fwTradeLog);
    log.info("[订单状态{}]=>{},当前商品id=>{},商品名称=>{}",fwTradeLog.getOrderId(), StatusEnum.TWO.getDesc(),fwTradeLog.getProductId(),fwTradeLog.getProductName());

    remoteSendServiceFeign.sendOrder(fwTradeLog);
    int i=1/0;
}

重启订单服务
Postman输入localhost:9002/saveOrder
f15a6f74d633c63562e5c42743b75573_MD5.png

可以看到订单服务的日志如下，可以看到实际新增了一条记录，但是因为抛异常，被回滚掉了

2020-04-06 20:10:27.626  INFO 4680 --- [nio-9002-exec-4] c.y.t.t.o.service.impl.OrderServiceImpl  : [订单状态444893]=>待发货,当前商品id=>1586175027566,商品名称=>Mac pro 2020款
2020-04-06 20:10:27.829 ERROR 4680 --- [nio-9002-exec-4] o.a.c.c.C.[.[.[/].[dispatcherServlet]    : Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Request processing failed; nested exception is java.lang.ArithmeticException: / by zero] with root cause

java.lang.ArithmeticException: / by zero

发货服务的日志如下，可以看到发送被调用到了

2020-04-06 20:10:27.758  INFO 4675 --- [nio-9003-exec-3] c.y.t.t.s.service.impl.SendServiceImpl   : [订单状态444893]=>待收货,当前商品id=>1586175027566,商品名称=>Mac pro 2020款

数据库记录并没有，说明TxManager 进行了回滚
3edff946480bc4731a71e24e84a560ec_MD5.png