通过AOP实现项目中业务服务降级功能

news2025/2/26 0:25:06

最近项目中需要增强系统的可靠性，比如某远程服务宕机或者网络抖动引起服务不可用，需要从本地或者其它地方获取业务数据，保证业务的连续稳定性等等。这里简单记录下业务实现，主要我们项目中调用远程接口失败时，需要从本地数据库中某表获取数据（本地数据库某表每天定时同步远程接口数据）。

调用大致逻辑：
前端–>服务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;
        }
    }
}