spring boot 分布式事务解决方案LCN

曾经终败给现在 2021-09-20 13:08 443阅读 0赞

对比LCN和saga(华为apache孵化器项目) ，LCN使用代理连接池封装补偿方法，saga需要手工写补偿方法，相对来说LCN使用更加方便。

参考官方地址：

[https://github.com/codingapi/tx-lcn/wiki/TxManager%E5%90%AF%E5%8A%A8%E8%AF%B4%E6%98%8E][https_github.com_codingapi_tx-lcn_wiki_TxManager_E5_90_AF_E5_8A_A8_E8_AF_B4_E6_98_8E]

## 1.    原理 ##

### 1.     事务控制原理 ###

![Image 1][]

LCN事务控制原理是由事务模块TxClient下的代理连接池与TxManager的协调配合完成的事务协调控制。

TxClient的代理连接池实现了javax.sql.DataSource接口，并重写了close方法，事务模块在提交关闭以后TxClient连接池将执行"假关闭"操作，等待TxManager协调完成事务以后在关闭连接。

### 2.     调用时序图 ###

#### 1.     正常 ####

![Image 1][]

#### 2.     异常 ####

![Image 1][]

## 2.    服务端 ##

tx-manager 4.1.0

## 3.    客户端 ##

### 1.     pom添加依赖 ###

<table> 
 <tbody> 
 <tr> 
 <td> &nbsp;&nbsp;&nbsp; &lt;properties&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;lcn.last.version&gt;4.1.0&lt;/lcn.last.version&gt; &nbsp;&nbsp;&nbsp; &lt;/properties&gt; </td> 
 </tr> 
 <tr> 
 <td> &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;dependency&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;groupId&gt;org.mybatis.spring.boot&lt;/groupId&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;artifactId&gt;mybatis-spring-boot-starter&lt;/artifactId&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;version&gt;1.1.1&lt;/version&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/dependency&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;dependency&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;groupId&gt;com.codingapi&lt;/groupId&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;artifactId&gt;transaction-springcloud&lt;/artifactId&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;version&gt;${lcn.last.version}&lt;/version&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;exclusions&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;exclusion&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;groupId&gt;org.slf4j&lt;/groupId&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;artifactId&gt;*&lt;/artifactId&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/exclusion&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/exclusions&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/dependency&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;dependency&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;groupId&gt;com.codingapi&lt;/groupId&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;artifactId&gt;tx-plugins-db&lt;/artifactId&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;version&gt;${lcn.last.version}&lt;/version&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;exclusions&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;exclusion&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;groupId&gt;org.slf4j&lt;/groupId&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;artifactId&gt;*&lt;/artifactId&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/exclusion&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/exclusions&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/dependency&gt; </td> 
 </tr> 
 </tbody> 
</table>

### 2.    配置文件 ###

<table> 
 <tbody> 
 <tr> 
 <td> #Ribbon的负载均衡策略：随机 #ribbon.NFLoadBalancerRuleClassName=com.netflix.loadbalancer.RandomRule #由于springcloud默认是开启的重试机制，开启次机制以后会导致当springcloud请求超时时会重复调用业务模块，从而会引发数据混乱，因此建议将其禁用。对于网络模块超时等故障问题建议使用hytrix方式。 #ribbon.MaxAutoRetriesNextServer=0 &nbsp; tm: &nbsp; manager: &nbsp;&nbsp;&nbsp; url: http://localhost:8899/tx/manager/ ribbon: &nbsp; NFLoadBalancerRuleClassName: com.netflix.loadbalancer.RandomRule &nbsp; MaxAutoRetriesNextServer: 0 init-db:true hystrix: &nbsp; command: &nbsp;&nbsp;&nbsp; default: &nbsp;&nbsp;&nbsp;&nbsp;&nbsp; execution: &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; isolation: &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; thread: &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; timeoutInMilliseconds: 6000 </td> 
 </tr> 
 </tbody> 
</table>

### 3.     Service包下处理http请求和对服务器的连接 ###

<table> 
 <tbody> 
 <tr> 
 <td> package com.svw.tbox.tcloud.commons.ms.service; &nbsp; import com.codingapi.tx.netty.service.TxManagerHttpRequestService; import com.lorne.core.framework.utils.http.HttpUtils; import org.springframework.stereotype.Service; &nbsp; @Service publicclass TxManagerHttpRequestServiceImpl implements TxManagerHttpRequestService{ &nbsp; &nbsp;&nbsp;&nbsp; @Override &nbsp;&nbsp;&nbsp; public String httpGet(String url) { &nbsp;&nbsp;&nbsp; //GET请求前 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; String res = HttpUtils.get(url); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //GET请求后 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; returnres; &nbsp;&nbsp;&nbsp; } &nbsp; &nbsp;&nbsp;&nbsp; @Override &nbsp;&nbsp;&nbsp; public String httpPost(String url, String params) { &nbsp;&nbsp;&nbsp; //POST请求前 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; String res = HttpUtils.post(url,params); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //POST请求后 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; returnres; &nbsp;&nbsp;&nbsp; } } </td> 
 </tr> 
 <tr> 
 <td> package com.svw.tbox.tcloud.commons.ms.service; &nbsp; import com.codingapi.tx.config.service.TxManagerTxUrlService; import org.springframework.beans.factory.annotation.Value; import org.springframework.stereotype.Service; &nbsp; @Service public class TxManagerTxUrlServiceImpl implements TxManagerTxUrlService{ &nbsp; &nbsp;&nbsp;&nbsp; @Value("${tm.manager.url}") &nbsp;&nbsp;&nbsp; private String url; &nbsp; &nbsp;&nbsp;&nbsp; @Override &nbsp;&nbsp;&nbsp; public String getTxUrl() { &nbsp;&nbsp;&nbsp; //load tm.manager.url &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; return url; &nbsp;&nbsp;&nbsp; } } </td> 
 </tr> 
 </tbody> 
</table>

### 4.    启动类配置代理连接池 ###

<table> 
 <tbody> 
 <tr> 
 <td> import javax.sql.DataSource; import org.mybatis.spring.annotation.MapperScan; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.cloud.client.discovery.EnableDiscoveryClient; import org.springframework.cloud.netflix.hystrix.EnableHystrix; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.ComponentScan; import org.springframework.core.env.Environment; import com.alibaba.druid.pool.DruidDataSource; &nbsp; @SpringBootApplication @EnableDiscoveryClient @EnableHystrix @MapperScan(basePackages = "com.svw.tbox.tcloud.commons.ms.dao") @ComponentScan(basePackages = { "com.svw.tbox.tcloud" }) publicclass MsApplication { &nbsp;&nbsp;&nbsp; …… @Autowired &nbsp;&nbsp;&nbsp; private Environment env; &nbsp; &nbsp;&nbsp;&nbsp; @Bean &nbsp;&nbsp;&nbsp; public DataSource dataSource() { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; DruidDataSource dataSource = new DruidDataSource(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; dataSource.setUrl(env.getProperty("spring.datasource.url")); &nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp; dataSource.setUsername(env.getProperty("spring.datasource.username"));//用户名 &nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp; dataSource.setPassword(env.getProperty("spring.datasource.password"));//密码 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; dataSource.setInitialSize(2); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; dataSource.setMaxActive(20); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; dataSource.setMinIdle(0); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; dataSource.setMaxWait(60000); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; dataSource.setValidationQuery("SELECT 1"); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; dataSource.setTestOnBorrow(false); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; dataSource.setTestWhileIdle(true); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; dataSource.setPoolPreparedStatements(false); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; returndataSource; &nbsp;&nbsp;&nbsp; } </td> 
 </tr> 
 </tbody> 
</table>

### 5.    测试代码 ###

调用方tcloud-mds => 参与方tcloud-commons

#### 1.     调用方：tcloud-mds ####

<table> 
 <tbody> 
 <tr> 
 <td> package com.svw.tbox.tcloud.commons.api.feign; &nbsp; import org.springframework.cloud.netflix.feign.FeignClient; import com.svw.tbox.tcloud.commons.api.config.TxFeignConfiguration; import com.svw.tbox.tcloud.commons.api.service.SysErrorCodeMappingService; &nbsp; /** &nbsp;* &lt;p&gt;ClassName: SysErrorCodeMappingFeign&lt;/p&gt; &nbsp;* &lt;p&gt;Description: 远程调用错误码服务&lt;/p&gt; &nbsp;* &lt;p&gt;Author: hurf&lt;/p&gt; &nbsp;* &lt;p&gt;Date: 2017年12月11日&lt;/p&gt; &nbsp;*/ @FeignClient(value = "tcloud-commons-ms") publicinterface SysErrorCodeMappingFeign extends SysErrorCodeMappingService { } </td> 
 </tr> 
 </tbody> 
</table>

#### 2.     事务发起@TxTransaction(isStart=true) ####

<table> 
 <tbody> 
 <tr> 
 <td> import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; &nbsp; import com.codingapi.tx.annotation.TxTransaction; import com.svw.tbox.tcloud.commons.api.entity.SysErrorCodeMapping; import com.svw.tbox.tcloud.commons.api.feign.SysErrorCodeMappingFeign; import com.svw.tbox.tcloud.commons.api.service.CmnService; import com.svw.tbox.tcloud.commons.api.service.JedisTemplate; import com.svw.tbox.tcloud.commons.util.DateUtil; import com.svw.tbox.tcloud.mds.entity.ThUserLogin; &nbsp; /** &nbsp;* @Title&lt;p&gt;ClassName: UserTokenService&lt;/p&gt; &nbsp;* @Description&lt;p&gt;Description: 登录服务&lt;/p&gt; &nbsp;* @Author&lt;p&gt;Author: hurf&lt;/p&gt; &nbsp;* @Date&lt;p&gt;Date: 2018年2月6日&lt;/p&gt; &nbsp;*/ @Service publicclass UserTokenService extends CmnService&lt;ThUserLogin&gt;{ &nbsp;&nbsp;&nbsp; @Autowired &nbsp;&nbsp;&nbsp; private JedisTemplate jedisTemplate; &nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp; @Autowired &nbsp;&nbsp;&nbsp; private SysErrorCodeMappingFeign sysErrorCodeMappingFeign; &nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp; @Transactional &nbsp;&nbsp;&nbsp; @TxTransaction(isStart=true) &nbsp;&nbsp;&nbsp; public String add(SysErrorCodeMapping sysErrorCodeMapping) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; // 远程调用新增 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; sysErrorCodeMappingFeign.add(sysErrorCodeMapping); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; // 本地新增db &nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp; insertSelective(ThUserLogin.builder().accessToken(sysErrorCodeMapping.getApiCode()) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; .refreshToken(sysErrorCodeMapping.getInnerErrorCode()).createBy("测试事务").build()); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //本地缓存事务 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; jedisTemplate.set("isStart", DateUtil.getNow()); //&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; int ii = 1/0;//异常 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; return"测试分布式事务成功"; &nbsp;&nbsp;&nbsp; } } </td> 
 </tr> 
 </tbody> 
</table>

#### 3.     事务参与方tcloud-commons-ms: @Transactional ####

<table> 
 <tbody> 
 <tr> 
 <td> @RestController publicclass SysErrorCodeMappingController implements SysErrorCodeMappingService { &nbsp; &nbsp;&nbsp;&nbsp; @Autowired &nbsp;&nbsp;&nbsp; private MsService msService; &nbsp; &nbsp;&nbsp;&nbsp; @ApiOperation("添加错误码信息") &nbsp;&nbsp;&nbsp; @Override &nbsp;&nbsp;&nbsp; public SystemResponse add(@RequestBody SysErrorCodeMapping sysErrorCodeMapping) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; returnmsService.add(sysErrorCodeMapping); &nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp; 。。。。。。 </td> 
 </tr> 
 <tr> 
 <td> importcom.codingapi.tx.annotation.ITxTransaction; &nbsp; @Service @CacheConfig(cacheNames = "sys-code-resource") publicclass MsService implements ITxTransaction{ &nbsp; &nbsp;&nbsp;&nbsp; @Autowired &nbsp;&nbsp;&nbsp; private JedisTemplate jedisTemplate; &nbsp; &nbsp;&nbsp;&nbsp; @Autowired &nbsp;&nbsp;&nbsp; private SysErrorCodeMappingMapper sysErrorCodeMappingMapper; &nbsp;&nbsp;&nbsp; /** &nbsp;&nbsp;&nbsp; &nbsp;* &lt;p&gt;Title: 事务参与方&lt;/p&gt; &nbsp;&nbsp;&nbsp; &nbsp;* &lt;p&gt;Description: &lt;/p&gt; &nbsp;&nbsp;&nbsp; &nbsp;* @param sysErrorCodeMapping &nbsp;&nbsp;&nbsp; &nbsp;* @return &nbsp;&nbsp;&nbsp; &nbsp;*/ &nbsp;&nbsp;&nbsp; @Transactional &nbsp;&nbsp;&nbsp; public SystemResponse add(SysErrorCodeMapping sysErrorCodeMapping) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //db操作 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; sysErrorCodeMapping.setVersion(1); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; sysErrorCodeMapping.setDelFlag(Short.valueOf("0")); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; sysErrorCodeMapping.setCreatedBy("admin"); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; sysErrorCodeMapping.setCreateDate(new Date()); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; sysErrorCodeMappingMapper.insertSelective(sysErrorCodeMapping); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //redis操作 &nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp; jedisTemplate.set("addTest"+DateUtil.getNow(),"tttttttttttttttttttttt"); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; return ResultUtil.success(refreshAll()); &nbsp;&nbsp;&nbsp; } </td> 
 </tr> 
 </tbody> 
</table>

### 6.     效果 ###

启动两个微服务，访问调用方接口

#### 1.     正常情况 ####

![Image 1][]

#### 2.     异常回滚情况 ####

删除刚刚的测试数据，开启异常情况：

<table> 
 <tbody> 
 <tr> 
 <td> &nbsp;&nbsp;&nbsp; @Transactional &nbsp;&nbsp;&nbsp; @TxTransaction(isStart=true) &nbsp;&nbsp;&nbsp; public String add(SysErrorCodeMapping sysErrorCodeMapping) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; // 远程调用新增 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; sysErrorCodeMappingFeign.add(sysErrorCodeMapping); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; // 本地新增db &nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp; insertSelective(ThUserLogin.builder().accessToken(sysErrorCodeMapping.getApiCode()) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; .refreshToken(sysErrorCodeMapping.getInnerErrorCode()).createBy("测试事务").build()); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //本地缓存事务 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; jedisTemplate.set("isStart", DateUtil.getNow()); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; intii = 1/0;//异常 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; return"测试分布式事务成功"; &nbsp;&nbsp;&nbsp; } </td> 
 </tr> 
 </tbody> 
</table>

![Image 1][]

发现mysql已经回滚了，但是redis没有回滚 =》 目前只支持db分布式事务。

转载于:https://www.cnblogs.com/dousnl/p/9772632.html

[https_github.com_codingapi_tx-lcn_wiki_TxManager_E5_90_AF_E5_8A_A8_E8_AF_B4_E6_98_8E]: https://github.com/codingapi/tx-lcn/wiki/TxManager%E5%90%AF%E5%8A%A8%E8%AF%B4%E6%98%8E
[Image 1]: