是否最好在Mono的单个管道中多次使用平面图？

Question

作为开发团队的一部分，我们希望构建一个非阻塞应用程序，因为我们正在使用SpringReactor 3构建我们的应用程序。因此，在使用project reactor时，我有一系列问题：

>

在单个管道和单声道上使用多个平面地图是一个好的做法吗

@Getter
@Setter
public class Employee {
     private long empId;
     private String userName;
     private String password;

}
public class FlatMapExample{
public Mono<Emplyoee> doValidate(Emplyoee emp){

    Mono.just(emp).flatMap(this::validateEmpId)
          .flatMap(this::validateUserName)
          .flatMap(this::validatePassword);
}
private Mono<Emplyoee> validateEmpId(Emplyoee e){
 Mono.just(emp).flatMap(//here some check on empId)
}

private Mono<Emplyoee> validateUserName(Emplyoee e){
 Mono.just(emp).flatMap(//here some check userName calling another method which is performing some extra checks like the format of username/ null or empty userName)
}

private Mono<Emplyoee> validatePassword(Emplyoee e){
 Mono.just(emp).flatMap(//here some check to validate password by calling another method)
}

}

与map相比，flatMap的资源成本是否更高？




Answer 1

数据的验证是关键点，所以在我看来，最好同步这个过程。

此外，如果flatMap（this:：validateEmpId）将返回Mono。错误（smth）您的下一个验证器将无法执行，因此您将无法返回完整的错误消息。

本文作者在webflux（reactor）项目中使用了验证器，所以我相信在您的示例中，更好的方法是这样的：

public Mono<Emplyoee> doValidate(Emplyoee emp){
    /*validate */
    if(valid) {
        return Mono.just(emp);
    } else {
        return Mono.error(err);
    }
}

Answer 2

我认为您应该尝试简化验证api，例如：

public Mono<Void> doValidate(Emplyoee emp){
  return validateEmpId(emp.getId())
    .then(validateUserName(emp.getUserName()))
    .then(validatePassword(emp);
}
private Mono<Void> validateEmpId(long id){
  // here some check on empId

  // if check ok return Mono.empty()
  // else return Mono.error(new YourException(...))
}
private Mono<Void> validateUserName(String userName){
  ...
}
private Mono<Void> validatePassword(Emplyoee emp){
  ...
}

没有更多的Mono.just（emp）。