dubbo接口入?yún)⑿ｒ灧绞?validation)

更新時間：2026年02月06日 15:17:40 作者：C_Knight

本文詳細介紹了如何在Maven項目中配置Dubbo服務(wù)的全局Filter,使用com.alibaba.dubbo.rpc.Filter攔截器進行參數(shù)校驗,具體步驟包括接口入?yún)⑴渲?、服?wù)端遠程參數(shù)校驗和消費者本地參數(shù)校驗,確保數(shù)據(jù)傳輸和處理過程中的參數(shù)正確性和安全性

maven依賴

   <dependency>
     <groupId>javax.validation</groupId>
     <artifactId>validation-api</artifactId>
   </dependency>
   <dependency>
     <groupId>org.hibernate.validator</groupId>
     <artifactId>hibernate-validator</artifactId>
   </dependency>

接口入?yún)?/h2>

@Data
public class UpdateBizLimitReqDTO {
    private static final long serialVersionUID = 3217106310804365294L;
    @NotNull(
        message = "UpdateBizLimitReqDTO.ticket not null"
    )
    private String ticket;
    @NotNull(
        message = "UpdateBizLimitReqDTO.bizId not null"
    )
    private Long bizId;
    @NotNull(
        message = "UpdateBizLimitReqDTO.source not null"
    )
    private Integer source;
    @NotNull(
        message = "UpdateBizLimitReqDTO.limitItemList not null"
    )
}

配置全局Filter

配置com.alibaba.dubbo.rpc.Filter文件

exceptionResolver=com.*.*.MPExceptionReslover

攔截器代碼實現(xiàn)。

/**
 * 統(tǒng)一異常處理，如果存在沒有catch住的異常，統(tǒng)一在此處封裝成默認未知錯誤
 */
@Slf4j
@Activate(
        group = {"provider", "consumer"}
)
public class MPExceptionReslover implements Filter {
    @Override
    public Result invoke(Invoker<?> invoker, Invocation invocation) {
         try{
             Object [] args = invocation.getArguments();
             if(args != null && args.length != 0){
                 for (int i = 0; i < args.length; i++) {
                     if(args[i] == null){
                         throw new BizValidatorException("請求參數(shù)不能為空");
                     }
                     RequestValidator validator = ValidatorFactory.getValidator(args[i].getClass());
                     if(validator != null){
                         validator.doValidate(args[i]);
                     }
                 }
             }
             Result result = invoker.invoke(invocation);
             Throwable exception = result.getException();
             if (exception != null) {
                 return wrapException(result.getException());
             } else {
                 return result;
             }
         }catch (Exception e){
             return wrapException(e);
         }
    }

    private RpcResult wrapException(Throwable exception) {
        if(exception instanceof BizException){
            BizException bizException = (BizException) exception;
            return new RpcResult(soaResponse(bizException.getErrorCode(), bizException.getErrorMsg()));
        }else if(exception instanceof RpcException){
            //入?yún)⑿ｒ?
            RpcException rpcException = (RpcException)exception;
            if(rpcException.getCause() instanceof ConstraintViolationException){
                ConstraintViolationException violationException = (ConstraintViolationException)rpcException.getCause();
                Set<ConstraintViolation<?>> errReason = violationException.getConstraintViolations();
                for (ConstraintViolation<?> item : errReason) {
                    return new RpcResult(soaResponse(PromotionErrorCode.FAIL_PARAM_NULL.getErrorCode(), item.getMessageTemplate()));
                }
            }
        }
        return new RpcResult(soaResponse("999999", exception.getMessage()));
    }

    /**
     * 構(gòu)建SoaResponse對象
     */
    private SoaResponse<Void, Void> soaResponse(String returnCode, String errorMsg) {
        SoaResponse<Void, Void> soaResponse = new SoaResponse<>();
        soaResponse.setResponseVo(null);
        soaResponse.setErrT(null);
        soaResponse.setReturnCode(returnCode);
        soaResponse.setReturnMsg(errorMsg);
        soaResponse.setProcessResult(Boolean.FALSE);
        return soaResponse;
    }
}

dubbo開啟入?yún)⑿ｒ?/h2>