dubbo 统一异常处理

依赖包 pom.xml

如下：

<dependency>
    <groupId>org.apache.dubbo</groupId>
    <artifactId>dubbo-registry-nacos</artifactId>
    <version>3.0.4</version>
</dependency>

dubbo 服务：

示例：

@DubboService(interfaceClass = PersonService.class, group = "HSF", version = "2.0.0")
@Component
public class PersonServiceImpl implements PersonService {


}

dubbo 统一异常处理

指定切入点，进行环绕通知。如果有异常，就捕获后处理。

@Aspect
@Component
@Slf4j
public class DubboExceptionAop {

    /**
     * 定义切入点。 指定dubbo service的注解。
     * 如果是旧版本，使用
     * @Pointcut("@within(org.apache.dubbo.config.annotation.Service)")
     *
     */
    @Pointcut("@within(org.apache.dubbo.config.annotation.DubboService)")
    public void dubboException() {

    }

    /**
     * 环绕通知
     *
     */
    @Around(value = "dubboException()")
    public Object handlerException(ProceedingJoinPoint proceedingJoinPoint) {
        Object result = null;
        Long time = System.currentTimeMillis();
        Signature signature = proceedingJoinPoint.getSignature();
        String params = JSON.toJSONString(proceedingJoinPoint.getArgs());
        try {
            result = proceedingJoinPoint.proceed();
        } catch (BusinessException businessException) {
        	//业务异常
            log.error("{} dubbo businessException:{},param:{}", signature.getName(), businessException.getMessage(), params,businessException);
            result = new Response<>(Response.Status.FAILED.getCode(), businessException.getMessage());
        } catch (Throwable throwable) {
            log.error("{} dubbo exception:{},param:{}", signature.getName(), params,throwable);
            result = new Response<>(Response.Status.FAILED.getCode(), "失败");
        } finally {
            Long cost = System.currentTimeMillis() - time;
			//统计耗时
            log.info("{} biz over,it takes time:{}", signature.getName(), cost);
        }
        return result;
    }


}