验证输入并相应地执行操作

Question

我有两个过程需要在几个领域进行验证。

• 对于ProcessA类，我需要验证几个字段。基于这些字段，我将验证这个类。
• 对于ProcessB类，我需要验证不同的字段。如果这些字段有效，那么我将验证这个类。

我的两个进程都应该将GenericRecord传递给Validator类，现在取决于它是ProcessA还是ProcessB，我的Validator类应该验证这些字段。

• 对于ProcessA，我需要验证clientId、deviceId、payId。
• 对于ProcessB，我需要验证CrossId、maxId、minId。

我能够使其适用于ProcessA，但我不知道我的验证程序类对于ProcessB字段验证是什么样子的。混淆的是，当类在构造函数中接收到generirecord时，它如何决定需要验证ProcessA或ProcessB的字段。如果通过了ProcessA，则对ProcessA字段进行验证；如果通过了ProcessB，则对ProcessB字段进行验证。

过程A

try {
  GenericRecordDomainDataDecoder decoder = new GenericRecordDomainDataDecoder(config);
  while (true) {
    ConsumerRecords<byte[], byte[]> records = consumer.poll(1000);
    for (ConsumerRecord<byte[], byte[]> record : records) {
      GenericRecord payload = decoder.decode(record.value());
      String processName = "processA";
      // validation logic
      Validator validation = new Validator(payload);
      if(!validation.isValid())
          continue;

      // some other code
    }
  }
} catch (Exception ex) {
  // logging error
}

过程B

try {
  GenericRecordDomainDataDecoder decoder = new GenericRecordDomainDataDecoder(config);
  while (true) {
    ConsumerRecords<byte[], byte[]> records = consumer.poll(1000);
    for (ConsumerRecord<byte[], byte[]> record : records) {
      GenericRecord payload = decoder.decode(record.value());
      String processName = "processB";
      // validation logic
      Validator validation = new Validator(payload);
      if(!validation.isValid())
          continue;

      // some other code
    }
  }
} catch (Exception ex) {
  // logging error
}

下面是我的Validator类，它现在只适用于ProcessA验证。我添加了另一个构造函数，我知道它不起作用，但只是想显示我想为ProcessB做什么。然后我需要调用isValid方法来告诉我ProcessB的字段是否存在。

public class Validator {
  private String clientId, deviceId, payId;

  // for ProcessA
  public Validator(GenericRecord payload) {
    clientId = (String) DataUtils.parseRecord(payload, "clientId");
    deviceId = (String) DataUtils.parseRecord(payload, "deviceId");
    payId = (String) DataUtils.parseRecord(payload, "payId");
  }

  // for ProcessB, I know this doesn't work - just wanted to show the idea
  public Validator(GenericRecord payload) {
    crossId = (String) DataUtils.parseRecord(payload, "crossId");
    maxId = (String) DataUtils.parseRecord(payload, "maxId");
    minId = (String) DataUtils.parseRecord(payload, "minId");
  }

  // this is what I am calling for ProcessA
  public boolean isValid() {
    return isValidClientIdDeviceId() && isValidPayId();
  }

  private boolean isValidPayId() {
    if (payId == null) {
      logger.log("invalid payId.");
      return false;
    }
    return true;
  }

  private boolean isValidClientIdDeviceId() {
    if (clientId == null && deviceId == null) {
      logger.log("invalid clientId and deviceId.");
      return false;
    }
    return true;
  }

  // getters
}

我可以将另一个参数processName传递给Validator类，它是一个字符串。我们可以用它来实现相应的字段验证吗。

Answer 1

如果您有少数类型的Process类，我向您提出的第一个解决方案是可以接受的。

您可以有一个空的构造函数，并且在构造函数之后调用的进程可以有一个init方法。

只需保留默认构造函数（不需要声明）：

  public Validator() {   
  }

  // for ProcessA
  public initProcessA(GenericRecord payload) {
    clientId = (String) DataUtils.parseRecord(payload, "clientId");
    deviceId = (String) DataUtils.parseRecord(payload, "deviceId");
    payId = (String) DataUtils.parseRecord(payload, "payId");
  }

  // for ProcessB, 
  public void initProcessB(GenericRecord payload) {
    crossId = (String) DataUtils.parseRecord(payload, "crossId");
    maxId = (String) DataUtils.parseRecord(payload, "maxId");
    minId = (String) DataUtils.parseRecord(payload, "minId");
  }

在流程A中：

   Validator validation = new Validator();
   validation.initProcessA(payload);  

在流程B中：

   Validator validation = new Validator();
   validation.initProcessB(payload);

第一种解决方案有其局限性<如果您有依赖于流程类的验证特定性，更好的解决方案是为每个流程使用不同的验证器类来分解规则，因为它更易于维护。

例如，您可以：

public abstract class Validator<T extends Process>{

   ...
   // common and abstract methods    
   ...
   public abstract boolean isValid();
}

过程A的验证器A：

public class ValidatorA extends Validator<ProcessA>{
   ...
        public ValidatorA(GenericRecord payload){
           clientId = (String) DataUtils.parseRecord(payload, "clientId");
           deviceId = (String) DataUtils.parseRecord(payload, "deviceId");
           payId = (String) DataUtils.parseRecord(payload, "payId");
        }

       public  boolean isValid(){
           // validation rules specific to ProcessA
       }
    ...

}

流程B的验证器B：

public class ValidatorB extends Validator<ProcessB>{
   ...
      public ValidatorB(GenericRecord payload) {
         crossId = (String) DataUtils.parseRecord(payload, "crossId");
         maxId = (String) DataUtils.parseRecord(payload, "maxId");
         minId = (String) DataUtils.parseRecord(payload, "minId");
      }

      public  boolean isValid(){
          // validation rules specific to ProcessB
      }

   ...
}