栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > Java

Dubbo全局异常处理

Java 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

Dubbo全局异常处理

@ControllerAdvice
@Activate(group = {CommonConstants.PROVIDER})
public class AuthInfoProviderFilter implements Filter {
    private static final String LOGIN_INTERFACE = "com.techhf.tenant.client.api.IAuthFeign";
    private static final String LOGIN_METHOD = "login";

    @SneakyThrows
    @Override
    public Result invoke(Invoker invoker, Invocation invocation) throws RpcException {
        String serviceInterface = invoker.getUrl().getServiceInterface();
        String methodName = invocation.getMethodName();

        if (LOGIN_INTERFACE.equals(serviceInterface) && LOGIN_METHOD.equals(methodName)) {
            return invoking(invoker, invocation);
        } else {
            String token = RpcContext.getServiceContext().getAttachment("token");
            if (token == null) {
                return AsyncRpcResult.newDefaultAsyncResult(R.failed("token不能为空"), invocation);
            }
            try {
                AuthInfo authInfo = JSON.parseObject(token, AuthInfo.class);
                AuthContextHolder.setAuthInfo(authInfo);
                return invoking(invoker, invocation);
            } finally {
                AuthContextHolder.clear();
            }
        }
    }


    @SneakyThrows
    public Result invoking(Invoker invoker, Invocation invocation) throws RpcException {
        Result result = invoker.invoke(invocation);
        if (result.hasException()) {
            ExceptionHandlerMethodResolver resolver = new ExceptionHandlerMethodResolver(this.getClass());
            Exception exception = (Exception) result.getException();
            Method method = resolver.resolveMethod(exception);
            Object obj = method.invoke(this, exception);
            return AsyncRpcResult.newDefaultAsyncResult(obj, invocation);
        }
        return result;
    }


    @ExceptionHandler(value = BusinessServiceException.class)
    public Object businessServiceException(BusinessServiceException e) {
        return R.failed(e.getMessage());
    }

}

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/877920.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号