lcn分布式事务整合到spring cloud

客官°小女子只卖身不卖艺 2023-03-03 14:27 11阅读 0赞

## 什么是事务？ ##

> 事务（Transaction），一般是指要做的或所做的事情。在计算机术语中是指访问并可能更新数据库中各种数据项的一个程序执行单元(unit)。事务通常由高级数据库操纵语言或编程语言（如SQL，C++或Java）书写的用户程序的执行所引起，并用形如begin transaction和end transaction语句（或函数调用）来界定。事务由事务开始(begin transaction)和事务结束(end transaction)之间执行的全体操作组成

--------------------

假设你已经清楚的知道了事务是什么，但是还是不太明白事务在分布式系统中的作用

那分布式事务是用来做什么的呢？

一般是为了解决类似以下的一些问题:

1.  最经典的跨行转账，无论成功还是失败，网络异常还是金钱异常账户异常，用户的钱始终只能保持在一个数值(仅争对自己的账户 和自己的另一个银行账户转账)
2.  用户秒杀商品成功，领取的时候却被告知商品已经没有了
3.  用户注册到了一个集团公司的账户体系下，但是登陆某些app的时候却被告知用户不存在，但是重新注册的时候却又提示用户已经存在

--------------------

在我们java开发中，一般是基于sping cloud来进行开发，事务也是基于spring的spring-tx，事务一般只存在于本地事务，如果事务在两个模块，多个模块，甚至包含了其他公司等等情况，则无效

1.  下单的时候要先扣库存，然后同时下订单，但是用户超时未支付(30min)，所以需要取消订单并且回退库存，不过这种一般叫做长事务，会选择数据库持久化订单状态来解决，更长的事务甚至会超过一周一个月甚至一年
2.  写入数据库的同时也写入redis，但是都写入成功以后又发生了异常，这个时候需要同时回滚redis和mysql，spring的本地事务的TranscantionManager冲突导致的只能mysql事务管理器生效或者redis事务管理器生效，一旦冲突就意味着只有一个能回滚
3.  对接其他公司的事务

因此，我们需要引入分布式事务

--------------------

我们项目使用了LCN分布式事务的总线控制方案

启动服务后将服务注册到LCN的transcationManager服务器，简称**tm**服务，而注册到tm的TransactionClient服务，简称**tc**

**使用前我假设你已经知道tm服务是什么，并且启动了我们的tx-manager服务\[LCN的transcationManager\]，接下来你该做的事情就是尽情使用了**！

--------------------

step1. 引入pom依赖

<dependency>
                <groupId>com.codingapi.txlcn</groupId>
                <artifactId>txlcn-tc</artifactId>
                <scope>compile</scope>
            </dependency>
            <dependency>
                <groupId>com.codingapi.txlcn</groupId>
                <artifactId>txlcn-txmsg-netty</artifactId>
                <scope>compile</scope>
            </dependency>

step2. 加入配置文件

tx-lcn:
      client:
      	#这里本来不应该为空，但是我已经为lcn适配了eureka，启动的时候会去eureka拉取lcn的tm服务器列表，不需要再手动填充lcn的tm服务器列表
        manager-address:
      logger:
        enabled: true

step3. 使用@LcnTransaction和@Transactional，以下是伪代码:

@RestContorller
    public class TestController{
        
    	private TestService testService;
    
    	@LcnTransaction
    	@Transactional
    	@GetMapping
        public Result<String> testFunction(){
        
        	int i = testService.doSomeThing();
        	return Result.success();
    	}
    }
    
    public interface TestService {
        
    	int doSomeThing();
    }
    
    @Service
    public class TestServiceImpl implements TestService {
        
    	private KafkaTemplate<Object,Object> kafkaTemplate;
    	private TestMessageMapper testMessageMapper;
    	private TestClient testClient;
    
        @LcnTransaction
        @Transactional
        @Override
    	int doSomeThing(){
        
    	    //发送kafka消息
    		kafkaTemplate.send(Topic,Key,Value);
            //写入数据库
    		testMessageMapper.sned(Message);
    		//远程调用，远程模块写入数据库
    		testClient.sendRemoteMessage(Message);
    		return 1;
    	}
    }
    }

使用的话也就以上三步，同一个事务里可以插入数据库,还可以发送kafka消息，也可以远程调用由远程服务器来插入数据库

--------------------

**注意: 一但发生异常，kafka发送的消息会回滚，插入数据库的数据也会回归，调用远程服务插入到远程服务器里的数据也会回滚\[实际上这样说不严谨，分布式事务的原理就是当每一方都提交到事务里并且没有异常的时候再统一提交事务，然后持久化事务，一旦发生异常就回滚全部事务\]**