Java详细分析LCN框架分布式事务

Java详细分析LCN框架分布式事务攻略

介绍

随着系统规模不断扩大以及业务越来越复杂，单机系统已经无法满足业务需求，分布式系统被广泛应用。而分布式系统面临的一个重要问题就是事务一致性问题。LCN是一个非常好的分布式事务解决方案。在这篇文章中，我们将详细分析LCN框架的使用方法，包含两个示例说明。

安装

1. 引入LCN Jar包

在maven中引入LCN框架的Jar包：

<dependency>
     <groupId>com.codingapi</groupId>
     <artifactId>tx-lcn-client</artifactId>
     <version>5.0.2.RELEASE</version>
</dependency>

<dependency>
     <groupId>com.codingapi</groupId>
     <artifactId>tx-lcn-txmsg-netty</artifactId>
     <version>5.0.2.RELEASE</version>
</dependency>

2. LCN注册中心

在Docker中启动LCN注册中心：

docker run -d -p 8500:8500 -p 8600:8600 -h consul --name consul progrium/consul -server -bootstrap

3. LCN服务端

在Spring Boot项目中，引入LCN框架的服务端Jar包：

<dependency>
     <groupId>com.codingapi</groupId>
     <artifactId>tx-lcn-springcloud</artifactId>
     <version>5.0.2.RELEASE</version>
</dependency>

在application.yml文件中进行配置：

spring:
  application:
    name: spring-cloud-service
  cloud:
    consul:
      defaults:
        enabled: true
        tags: latest
      host: 127.0.0.1
  datasource:
    driver-class-name: com.mysql.cj.jdbc.Driver
    url: jdbc:mysql://localhost/test1?characterEncoding=utf-8&useSSL=false
    username: root
    password: root

lcn:
  tx-manager-address: localhost:8070
  redis:
    password:
    cluster: false
    mode:
  file:
    dir:
  params:
    transaction_wait_delay_time: 100
    transaction_max_time: 30
    transaction_netty_heart_time: 15

在启动类上添加@EnableDistributedTransaction注解：

@SpringBootApplication
@EnableDiscoveryClient
@EnableFeignClients
@EnableDistributedTransaction
public class SpringCloudServiceApplication {

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

在对应的Controller层方法上添加@LcnTransaction注解，表示该方法是一个原子事务：

@RestController
public class SpringCloudController {

    @Autowired
    private FeignService feignService;

    @Autowired
    private UserDao userDao;

    @GetMapping("/test")
    @LcnTransaction
    public String test() {
        // do something
        return feignService.sayHi() + " - " + userDao.getUser(1).getName();
    }

}

至此，LCN分布式事务框架的安装配置完成。

示例说明

示例一：分布式事务示例

我们使用两个服务作为示例，分别是OrderService和StockService，OrderService用于下订单，StockService用于扣减库存。假设库存不能小于0，否则下单失败。

OrderService

在OrderService的Controller层中，添加@LcnTransaction注解，表示该方法是一个原子事务：

@RestController
public class OrderController {

    @Autowired
    private OrderService orderService;

    @Autowired
    private StockFeign stockFeign;

    @PostMapping("/order")
    @LcnTransaction
    public String order(@RequestParam("productId") Integer productId,
                        @RequestParam("count") Integer count) {
        // 扣减库存
        if (!stockFeign.decreaseStock(productId, count)) {
            return "Decrease stock failed!";
        }

        // 创建订单
        Order order = orderService.createOrder(productId, count);
        if (order == null) {
            return "Create order failed!";
        }

        return "Create order succeed!";
    }

}

StockService

在StockService的Controller层中，同样添加@LcnTransaction注解，表示该方法是一个原子事务：

@RestController
public class StockController {

    @Autowired
    private StockService stockService;

    @PostMapping("/stock/decrease")
    @LcnTransaction
    public boolean decreaseStock(@RequestParam("productId") Integer productId,
                                 @RequestParam("count") Integer count) {
        return stockService.decreaseStock(productId, count);
    }
}

在StockService中添加@Transactional注解，表示该方法在本地数据库中执行一个事务：

@Service
public class StockService {

    @Autowired
    private StockDao stockDao;

    @Transactional
    public boolean decreaseStock(Integer productId, Integer count) {
        // 查询库存记录
        Stock stock = stockDao.getStock(productId);
        if (stock == null) {
            return false;
        }

        // 库存不足
        if (stock.getCount() < count) {
            return false;
        }

        // 扣减库存
        stock.setCount(stock.getCount() - count);
        return stockDao.updateStock(stock);
    }

}

示例二：分布式事务超时示例

在某些情况下，如果在指定的时间内分布式事务没有完成，则需要自动回滚事务，以免产生异常。以下是一个分布式事务超时的示例。

在OrderService的Controller层中添加如下注解，表示该方法最长执行时间为5秒：

@GetMapping("/test")
@LcnTransaction(timeout=5000)
public String test() {
    // do something
}

当一个分布式事务创建时，它的最长执行时间是30秒，可以在application.yml文件配置：

lcn:
  params:
    transaction_max_time: 30

超时时间可以被覆盖，所以我们可以针对不同的方法设置不同的超时时间。

总结

LCN框架是一个非常方便的分布式事务解决方案。在使用LCN时，我们首先需要引入相关的Jar包并且启动LCN注册中心和服务端。我们还可以对超时时间进行设置，自定义每个方法的执行时间。实战示例也展示了LCN框架在实际开发中的应用。