版本
spring boot： 3.4.1
dubbo：3.3.1
java17

官方文档

1，过滤器代码

import jakarta.validation.ValidationException;
import lombok.extern.slf4j.Slf4j;
import org.apache.dubbo.common.constants.CommonConstants;
import org.apache.dubbo.common.extension.Activate;
import org.apache.dubbo.rpc.*;
import org.springframework.validation.BindException;

/**
 * dubbo统一异常处理过滤器
 */
@Slf4j
@Activate(group = {CommonConstants.PROVIDER}, order = 1)
public class ExceptionFilter implements Filter, Filter.Listener {

    @Override
    public Result invoke(Invoker<?> invoker, Invocation invocation) throws RpcException {
        Result appResponse;
        try {
            appResponse = invoker.invoke(invocation);
        } catch (Throwable e) {
            appResponse = AsyncRpcResult.newDefaultAsyncResult(e, invocation);
            onResponse(appResponse, invoker, invocation);
        }

        return appResponse;
    }

    @Override
    public void onResponse(Result appResponse, Invoker<?> invoker, Invocation invocation) {
        Throwable exception = appResponse.getException();
        if (exception != null) {
            log.info("Dubbo统一异常处理过滤器");

            // 取得底层真实异常
            // 异步线程异常 是包装过的
            // 在dubbo自带ExceptionFilter 包装过某些异常
            while (exception != null) {
                if (exception.getCause() != null) {
                    exception = exception.getCause();
                } else {
                    break;
                }
            }

            appResponse.setException(null);

            if(exception instanceof ValidationException ve) {
                // 参数校验异常
                appResponse.setValue(GlobalExceptionHandler.getValidExceptionMsg(ve));
            } else if (exception instanceof BindException e) {
                // 参数校验异常
                appResponse.setValue(GlobalExceptionHandler.getBindExceptionMsg(e));
            } else if (exception instanceof BizException e) {
                // 业务自定义异常
                appResponse.setValue(e.getRpcResult());
            } else if (exception instanceof Exception e) {
                appResponse.setValue(GlobalExceptionHandler.exceptionHandler(e));
            }
        }
    }

    @Override
    public void onError(Throwable t, Invoker<?> invoker, Invocation invocation) {

    }
}

说明：

• 1，@Activate(group = {CommonConstants.PROVIDER}, order = 1) 这个一定要有，是激活该过滤器用的。配置文件里是加载。order 尽量小一点，越小的越靠前执行
• 2，业务逻辑不要写在invoke方法里，要写在onResponse方法里，因为onResponse是dubbo异步调用的回调方法
• 3，如果你想返回错误信息就appResponse.setException(null);appResponse.setValue(错误信息)
• 4，如果你想继续抛出异常就appResponse.setException(你的异常)

2，配置文件

dubbo:
  protocol:
    name: tri
    port: 10003
  provider:
    export: true
    filter:
      - "loginAuthFilter,exceptionFilter"
      #- "-exception"
    validation: true

  consumer:
    #关闭服务检查 如果依赖的服务挂了 不影响调用
    check: false
    timeout: 300
    # 负载均衡策略 默认random（加权随机） 修改成轮询
    loadbalance: roundrobin
    # 重试次数 根据服务provider端服务器数量决定 用于查询场景
    # 事务场景要设置为0
    retries: 0
    validation: true
    # 集群容错模式 立即失败 用于事务模式
    cluster: failfast

说明

• 1，filter配置，这里一定要写 - "loginAuthFilter,exceptionFilter" 说明我加载了两个自定义的过滤器

  - "-exception" 过滤器名前面带个【-】是关闭这个过滤器

• 2，dubbo自带的异常过滤器不要关掉，它会帮你做一些事情

3，org.apache.dubbo.rpc.Filter 文件

位置

src
 |-main
    |-java
        |-com
            |-xxx
                |-XxxFilter.java (实现Filter接口)
    |-resources
        |-META-INF
            |-dubbo
                |-org.apache.dubbo.rpc.Filter (纯文本文件，内容为：xxx=com.xxx.XxxFilter)

内容

loginAuthFilter=com.zx.frame.filter.LoginAuthFilter
exceptionFilter=com.zx.frame.filter.ExceptionFilter

至此，自定义过滤器完成

4，问题与注意点

• 不能在onResponse方法里打断点，一打断点就会出现死循环，不知道什么原因
  解决办法（虽然不知道为什么）
  是因为dubbo 在3.1.6 开始，开启一个序列化检查模式，这个检查模式认定EncodeException 为非法的序列化类，所以报错
  但为什么会死循环还没没有搞清楚。明明EncodeException 是dubbo自带的异常，也不是我定义的，不知道为什么就非法了。

具体请参照官方文档（有解决方案）：https://cn.dubbo.apache.org/zh-cn/overview/mannual/java-sdk/tasks/security/class-check/
和 https://cn.dubbo.apache.org/zh-cn/overview/mannual/java-sdk/reference-manual/serialization/serialization/

我采用的是比较极端的解决方案：关掉这个检查

dubbo.application.serialize-check-status=DISABLE

• validation 一点要provider端与consumer端都开启，可以提升性能减少麻烦