您的位置:首页 > 编程语言 > Java开发

springcloud+feign 集成LCN5.0.2分布式事务,以及全局异常捕获问题的解决方案

2020-02-25 16:33 549 查看

springcloud+feign+LCN5.0.2来处理分布式事务

LCN集成springcloud

可以参考这个大佬的博客:https://blog.csdn.net/zhuwei_clark/article/details/97927248

分布式事务想干什么

自己的理解就是保证强一致性,比如我A服务调用B服务,两者都对数据库进行了操作
我又要保证着两次操作必须同时进行,如果B服务出错了,出现了异常,那么A服务对数据
库的操作就要进行回滚。保证一致性。

问题

按照 https://blog.csdn.net/zhuwei_clark/article/details/97927248
集成后,B服务出错,A服务不能进行回滚 而反之能执行回滚

原因

就是Feign调用服务的时候出现异常,我的项目由于设置了全局异常捕获,导致异常不能被Feign捕获,就不能去触发熔断
器,导致不能执行熔断器中的回滚方法 DTXUserControls.rollbackGroup(TracingContext.tracing().groupId());
但是为什么LCN不根据B服务出错,直接进行回滚操作呢,为什么要去熔断器中执行手动回滚呢?不知道是我环境的原因还
是LCN的BUG,还是本来就是这样的。
我去对B服务的执行方法进行AOP切面编程(下面出代码),发现就算这个方法内部出错,也执行了原来的return方法
比如
Repository.save(S);
return 1;
就算save方法出现异常,但是return还是会执行,这里我不知道原因,望有大佬解答!
所以我这里的问题就是Feign得不到异常,不触发熔断器,不回滚!

解决方案

刚刚提到了切面编程。这里贴上一个我的切面类,具体看方法注释
/**
* aop切面
*/
@Aspect
@Component
public class TxAspect {
/**
* 定义切入点,切入点为com.example.demo.aop.AopController中的所有函数
* 通过@Pointcut注解声明频繁使用的切点表达式
*/
@Pointcut("@annotation(com.codingapi.txlcn.tc.annotation.LcnTransaction)") //只需拦截使用了LcnTransaction注解的方法
public void BrokerAspect() {

}

/**
* @description 在连接点执行之前执行的通知
*/
@Before("BrokerAspect()")
public void doBefore() {
System.out.println(" 在连接点执行之前执行的通知 ");
}

/**
* @description 在连接点执行之后执行的通知(返回通知和异常通知的异常)
*/
@After("BrokerAspect()")
public void doAfter() {
System.out.println("在连接点执行之后执行的通知!");
}

/**
* @description 在连接点执行之后执行的通知(返回通知)
*/

@AfterReturning(returning = "rvt", pointcut = "@annotation(com.codingapi.txlcn.tc.annotation.LcnTransaction)")
public void doAfterReturning(JoinPoint joinPoint, Object rvt) {
//rvt为返回值
System.out.println("在连接点执行之后执行的通知(返回通知)");
}

/**
* @description 在连接点执行之后执行的通知(异常通知)
*/
@AfterThrowing("BrokerAspect()")
public void doAfterThrowing() {

System.out.println("在连接点执行之后执行的通知(异常通知)!");
}

}
既然上面说到B服务出现异常会return,那我们怎么办呢
1、取消全局异常捕获,B服务出错后进入熔断器,手动回滚。
2、在A服务定义切面类,我们不去B服务取他的返回值,我们在A服务调用那里取返回值,我们会发现这个返回值就
是全局异常捕获的返回值,可以自定义,那么我们就能在A服务中判断B服务是否出错(通过切面类取返回值判断,手动
回滚)这样我们就能回滚了
/**
* @description  在连接点执行之后执行的通知(返回通知)
*/
@AfterReturning(returning="rvt", pointcut="@annotation(com.codingapi.txlcn.tc.annotation.LcnTransaction)")
public void doAfterReturningGame(JoinPoint joinPoint, Object rvt){
//rvt 为返回值 这里为如果调用服务的返回值不为10000就进行回滚,说明调用的服务发生错误
System.out.println(rvt.toString());
if(JsonUtils.jsonToPojo(JsonUtils.objectToJson(rvt),ResponseResult.class).getCode() != 10000){
DTXUserControls.rollbackGroup(TracingContext.tracing().groupId());
System.out.println("回滚成功");
}
System.out.println("返回通知:在连接点执行之后执行的通知!");
}

做个记录,以后再看看Seata

内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: