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
相关文章推荐
- spring事务异常捕获问题
- spring cloud feign 接口继承以及参数传递的问题
- spring cloud feign 调用微服务转发不了request请求头和参数问题解决方案
- SpringBoot + MultipartFile 实现文件上传以及文件转移的功能以及配置全局捕获上传文件过大异常
- Spring配置事务 service 异常捕获回滚问题
- 发锁事务重试机制(JPA高并发下的乐观锁异常)总结,以及中间遇到各种问题和解决方案
- Spring cloud多模块开发下Feign的使用,以及@FeignClient注入bean找不到异常解决
- Spring配置事务 service 异常捕获回滚问题
- Tomcat于Eclipse集成开发问题以及解决方案
- Spring异常捕获而且回滚事务的方法
- spring boot 拦截器的实现以及遇到的问题的解决方案
- spring与hibernate集成的session事务控制问题解析
- Spring事务异常回滚,捕获异常不抛出就不会回滚
- Spring-MVC开发之全局异常捕获全面解读
- SpringCloud关于@FeignClient和Hystrix集成对http线程池监控问题
- spring2.5整合ibatis2.3事务管理时遇到的问题以及需要的jar包
- 异常捕获不抛出,Spring事务无法回滚【转载】
- Spring事务异常回滚,捕获异常不抛出就不会回滚
- spring boot 全局异常捕获
- Spring事务异常回滚,捕获异常不抛出就不会回滚