怎么对 Dubbo的业务异常进行统一封装
想定义一个 provider端的 filter，将业务异常封装之后返回 {"code": 500, "msg": "xxx"}给 consumer端。但是在网上找到的都是通过 spring aop的方式进行处理的。
下面是我自己的一个示例(不知道怎么封装成 result)：
@activate(group = {CommonConstants.PROVIDER}, order = -2) public class ExceptionFilter implements Filter { @OverRide public Result invoke(Invoker<?> invoker, Invocation invocation) throws RpcException { Result result = invoker.invoke(invocation); if (result.getException() instanceof BaseException) { // 判断抛出的异常是否为业务异常 BaseException exception = (BaseException) result.getException(); result = ??? } else if (result.getException() instanceof Exception) { result = ??? }
return result;
}
原提问者GitHub用户wcc1433
写回答
-
可以试试这个
@Activate(group = CommonConstants.PROVIDER) public class ResultConvertFilter implements Filter, BaseFilter.Listener { @Override public Result invoke(Invoker<?> invoker, Invocation invocation) throws RpcException { return invoker.invoke(invocation); }
@Override public void onResponse(Result appResponse, Invoker<?> invoker, Invocation invocation) { if (appResponse.hasException()) { // reset value appResponse.setValue(new Object()); appResponse.setException(null); } else { Object originValue = appResponse.getValue(); if (originValue instanceof Exception) { // reset value appResponse.setValue(new Object()); } } } @Override public void onError(Throwable t, Invoker<?> invoker, Invocation invocation) { // framework error, can be ignore }}
原回答者GitHub用户AlbumenJ
2023-05-12 10:36:09赞同 展开评论 打赏
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
阿里云拥有国内全面的云原生产品技术以及大规模的云原生应用实践，通过全面容器化、核心技术互联网化、应用 Serverless 化三大范式，助力制造业企业高效上云，实现系统稳定、应用敏捷智能。拥抱云原生，让创新无处不在。
