import com.alibaba.fastjson2.JSON;
import org.apache.dubbo.common.constants.CommonConstants;
import org.apache.dubbo.common.extension.Activate;
import org.apache.dubbo.rpc.*;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

// 使用@Activate注解指定Filter生效場(chǎng)景
// order屬性控制執(zhí)行順序，值越小，優(yōu)先級(jí)越高
@Activate(group = {CommonConstants.CONSUMER, CommonConstants.PROVIDER}, order = 10001)
public class CustomFilter implements Filter {
    private Logger logger = LoggerFactory.getLogger(CustomFilter.class);
    @Override
    public Result invoke(Invoker<?> invoker, Invocation invocation) throws RpcException {
        logger.info("invoker invoked method {} {} {} {}",
                invocation.getMethodName(),
                JSON.toJSONString(invocation.getObjectAttachments()),
                invocation.getAttributes(),
                JSON.toJSONString(invocation.getArguments()));
        Result result = invoker.invoke(invocation);
        logger.info("invoker invoked result {}", JSON.toJSONString(result));
        return result;
    }
}

consumer=com.doudou.demo.filter.CustomFilter

 <!-- Bean Validation API -->
<dependency>
    <groupId>javax.validation</groupId>
    <artifactId>validation-api</artifactId>
    <version>2.0.1.Final</version>
</dependency>
<!-- Hibernate Validator實(shí)現(xiàn) -->
<dependency>
    <groupId>org.hibernate.validator</groupId>
    <artifactId>hibernate-validator</artifactId>
    <version>6.2.5.Final</version>
</dependency>
<dependency>
    <groupId>org.glassfish</groupId>
    <artifactId>jakarta.el</artifactId> <!-- 適配EL表達(dá)式 -->
    <version>5.0.0-M1</version>
</dependency>

@Setter
@Getter
public class UserDTO implements Serializable {
    @NotBlank(message = "用戶名不能為空")
    private String username;

    @Min(value = 18, message = "年齡必須大于18歲")
    private Integer age;

    @Email(message = "郵箱格式不合法")
    private String email;
}

public class BaseResult<T> {
    // 處理是否正確結(jié)束
    private boolean success;
    // 異常編碼
    private Integer errorCode;
    // 異常描述
    private String errorMsg;
    // dubbo接口返回的結(jié)果
    private T data;
}    

public interface UserService {
    BaseResult<String> registerUser(UserDTO userDTO);
}

@DubboService(validation = "true")
public class UserServiceImpl implements UserService {

    @Override
    public BaseResult<String> registerUser(UserDTO userDTO) {
        return BaseResult.success("用戶注冊(cè)成功：" + userDTO.getUsername());
    }
}

public class ParameterVerificationResultFilter implements Filter {
    private Logger logger = LoggerFactory.getLogger(ParameterVerificationResultFilter.class);

    @Override
    public Result invoke(Invoker<?> invoker, Invocation invocation) throws RpcException {
        Result result = invoker.invoke(invocation);
        // 處理出現(xiàn)異常
        if (result.hasException()) {
            Throwable exception = result.getException();
            // 是由參數(shù)校驗(yàn)失敗拋出的異常
            if (exception instanceof ConstraintViolationException) {
                List<String> errors = ((ConstraintViolationException) exception).getConstraintViolations().stream()
                        .map(v -> v.getPropertyPath() + ": " + v.getMessage())
                        .collect(Collectors.toList());
                logger.info("---------------2---------------");
                logger.error(errors.toString());
                logger.info("---------------3---------------");
                // 將錯(cuò)誤信息封裝到返回結(jié)果中
                return AsyncRpcResult.newDefaultAsyncResult(BaseResult.fail(400, errors.toString()), invocation);
            }
        }
        return result;
    }
}

# 參數(shù)校驗(yàn)過濾器
validation=org.apache.dubbo.validation.filter.ValidationFilter
# 校驗(yàn)結(jié)果處理過濾器
parameterVerification=com.doudou.filter.ParameterVerificationResultFilter

dubbo:
	provider:
		filter: validation,parameterVerification

@RestController
public class UserServiceController {
    @DubboReference(validation = "true")
    private UserService userService;

    @PostMapping("/test")
    public BaseResult<String> test(@RequestBody UserDTO userDTO) {
        return userService.registerUser(userDTO);
    }
}

@RestControllerAdvice
public class GlobalExceptionHandler {

    // 處理RpcException異常
    @ExceptionHandler(RpcException.class)
    public ResponseEntity<BaseResult> handleValidationException(RpcException rpcException) {
        return ResponseEntity.badRequest().body(BaseResult.fail(403, rpcException.getLocalizedMessage()));
    }
}

public Result invoke(Invoker<?> invoker, Invocation invocation) throws RpcException {
   // 判斷是否需要進(jìn)行參數(shù)驗(yàn)證
    if (needValidate(invoker.getUrl(), invocation.getMethodName())) {
        try {
            // 通過url中的validation屬性值獲取驗(yàn)證器
            Validator validator = validation.getValidator(invoker.getUrl());
            if (validator != null) {
                // 獲取到驗(yàn)證器時(shí)，進(jìn)行參數(shù)驗(yàn)證
                validator.validate(
                        invocation.getMethodName(), invocation.getParameterTypes(), invocation.getArguments());
            }
        } catch (RpcException e) {
            // RpcException 異常直接拋出
            throw e;
        } catch (Throwable t) {
            // 非RpcException，封裝到結(jié)果中返回
            return AsyncRpcResult.newDefaultAsyncResult(t, invocation);
        }
    }
    // 執(zhí)行下一個(gè)過濾器的處理
    return invoker.invoke(invocation);
}

 /**
  * 是否需要進(jìn)行參數(shù)驗(yàn)證
  */
 private boolean needValidate(URL url, String methodName) {
     return validation != null
             && !methodName.startsWith("$")
             && ConfigUtils.isNotEmpty(url.getMethodParameter(methodName, VALIDATION_KEY))
             && !"false".equalsIgnoreCase(url.getParameter(VALIDATION_KEY));
 }

@Override
public Validator getValidator(URL url) {
    // 使用url作為存儲(chǔ)驗(yàn)證器map集合的的key
    String key = url.toFullString();
    // 從容器中獲取驗(yàn)證器
    Validator validator = validators.get(key);
    // 判斷驗(yàn)證器是否已經(jīng)存在
    if (validator == null) {
        // 如果不存在，則創(chuàng)建
        validators.put(key, createValidator(url));
        validator = validators.get(key);
    }
    return validator;
}

@Activate(onClass = "javax.validation.Validation")
public class JValidation extends AbstractValidation {

    /**
     * Return new instance of {@link JValidator}
     * @param url Valid URL instance
     * @return Instance of JValidator
     */
    @Override
    protected Validator createValidator(URL url) {
        // 創(chuàng)建一個(gè)Dubbo框架默認(rèn)的校驗(yàn)器
        return new JValidator(url);
    }
}