dubbo之参数验证

本文在这篇文章 基础上改造进行测试。

dubbo的参数验证基于JSR303规范就是定义了校验注解，错误信息如何提示等的规范，我们只需要使用规定的注解，并声明Filter就可以了。
源码。

    
    
    
        javax.validation
        validation-api
        2.0.1.Final
    
    
    
        org.hibernate.validator
        hibernate-validator
        6.0.18.Final
    
    
    
        org.glassfish
        javax.el
        3.0.1-b11
    

public class UserAddDTO implements Serializable {
    
    @NotEmpty(message = "昵称不能为空")
    @Length(min = 5, max = 16, message = "账号长度为 5-16 位")
    private String name;
    
    @NotNull(message = "性别不能为空")
    private Integer gender;

    // getter setter tostring
}

public interface UserRpcService {

    
    UserDTO get(@NotNull(message = "用户编号不能为空") Integer id)
            throws ConstraintViolationException;

    
    Integer add(UserAddDTO addDTO)
            throws ConstraintViolationException;
}

注意在方法中抛出ConstraintViolationException的原因是参数校验不通过时会抛出该异常，所以这里抛出提供给用户查看错误信息。

@Service
public class UserRpcServiceImpl implements UserRpcService {

    @Override
    public UserDTO get(Integer id) {
        
        UserDTO userDTO = new UserDTO();
        userDTO.setId(id);
        userDTO.setName("没有昵称：" + id);
        userDTO.setGender(id % 2 + 1);
        return userDTO;
    }

    @Override
    public Integer add(UserAddDTO addDTO) {
        return (int) (System.currentTimeMillis() / 1000); // 嘿嘿，随便返回一个 id
    }

}

增加了validation="true"开启服务提供者端的参数校验，如果是参数校验不通过则抛出ConstraintViolationException。

可以通过在application.yml中配置dubbo.provider.validation = true开启服务提供者所有service的参数校验。

通过validation="true"开启服务消费者的参数校验。

@Component
public class UserRpcServiceTest02 implements CommandLineRunner {

    private final Logger logger = LoggerFactory.getLogger(getClass());

    @Resource
    private UserRpcService userRpcService;

    @Override
    public void run(String... args) throws Exception {
        // 获得用户
        try {
            // 发起调用
            UserDTO user = userRpcService.get(null); // 故意传入空的编号，为了校验编号不通过
            logger.info("[run][发起一次 Dubbo RPC 请求，获得用户为({})]", user);
        } catch (Exception e) {
            logger.error("[run][获得用户发生异常，信息为:[{}]", e.getMessage());
        }

        // 添加用户
        try {
            // 创建 UserAddDTO
            UserAddDTO addDTO = new UserAddDTO();
            // 故意把名字打的特别长，为了校验名字不通过
            addDTO.setName("dongshidaddydongshidaddydongshidaddydongshidaddy");
            // 不传递性别，为了校验性别不通过
            addDTO.setGender(null);
            // 发起调用
            userRpcService.add(addDTO);
            logger.info("[run][发起一次 Dubbo RPC 请求，添加用户为({})]", addDTO);
        } catch (Exception e) {
            logger.error("[run][添加用户发生异常，信息为:[{}]", e.getMessage());
        }
    }

}

如下红框中是错误执行触发的异常信息，蓝色框是正常的调用：