最近项目中需要增强系统的可靠性,比如某远程服务宕机或者网络抖动引起服务不可用,需要从本地或者其它地方获取业务数据,保证业务的连续稳定性等等。这里简单记录下业务实现,主要我们项目中调用远程接口失败时,需要从本地数据库中某表获取数据(本地数据库某表每天定时同步远程接口数据)。
调用大致逻辑:
前端–>服务A–>服务B(这里时公服,用于维护权限、人员等信息)
其中服务B调用远程服务故障,进行服务降级,从服务B的本地数据库查询数据。
一、创建切面,统一业务降级
项目中实际是通过故障注入方式,模拟远程接口宕机。这里简单通过除法异常模拟故障。
package com.example.demospringmybatisplus.service;import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.Around;
import org.aspectj.lang.annotation.Aspect;
import org.springframework.stereotype.Component;import lombok.extern.slf4j.Slf4j;/*** 调用远程服务异常降级处理类** @DATE 2024/5/8**/
@Slf4j
@Component
@Aspect
public class DataExceptionDegradeHandler {@Around("execution(* com.example.demospringmybatisplus.processors.DataOperationService.findList(..))")public Object degrade(ProceedingJoinPoint joinPoint) throws Throwable {System.out.println("Around,注解方式实现aop服务降级----");try {// 模拟调用远程服务异常int i = 1 / 0;return joinPoint.proceed();} catch (Exception e) {// 调用远程服务异常,改为从本地或其它地方获取业数据System.out.println("调用远程服务异常,这里模拟从其它地方获取业务数据");return 1;}}
}
二、测试验证
可以看到,前端请求服务A的某方法,会被AOP拦截,执行我们自定义的降级业务逻辑,实现了服务降级功能。
源码下载:点我下载 欢迎Star !