仅当 Mono 为空时如何执行操作，如果不为空则抛出错误

Question

我正在尝试将项目转换为使用 Spring WebFlux，但在使一些基本业务逻辑正常工作时遇到了问题。我有一个负责检索/保存记录的存储库层和一个负责应用程序业务规则的服务层。我想要做的（在服务层）是检查给定用户名的用户是否已经存在。如果是这样，我想回复一个错误。如果没有，我想允许插入发生。

我在存储库层调用了一个方法，该方法将通过用户名查找用户，如果未找到，它将返回一个空的 Mono。这按预期工作；但是，我尝试了 flatMap 和 (defaultIfEmpty 和 swithIfEmpty) 的各种组合，但无法编译/构建。

    public Mono<User> insertUser(User user) {
        return userRepository.findByUsername(user.username())
            .flatMap(__ -> Mono.error(new DuplicateResourceException("User already exists with username [" + user.username() + "]")))
            .switchIfEmpty(userRepository.insertUser(user));
    }

我得到的错误是 Mono<Object> cannot be converted to Mono<User>，所以 swithIfEmpty 似乎没有反映适当的类型，并且转换似乎也不起作用。

Answer 1

经过额外的测试，并考虑到其他开发人员的反馈，我找到了以下解决方案：

    public Mono<User> insertUser(User user) {
        return userRepository.findByUsername(user.username())
            .flatMap(__ -> Mono.error(new DuplicateResourceException("User already exists with username [" + user.username() + "]")))
            .switchIfEmpty(Mono.defer(() -> userRepository.insertUser(user)))
            .cast(User.class);
    }

正如 Thomas 所说，编译器感到困惑。我的假设是因为flatMap 返回一个带有错误的 Mono，而 switchIfEmpty 返回一个带有用户的 Mono，因此它恢复为带有 Object 的 Mono（因此额外的 .cast 运算符让它编译） .

另一个添加是在switchMap 中添加Mono.defer。否则，switchIfEmpty 总是在触发。

我仍然对其他建议/替代方案持开放态度（因为这似乎是一种相当普遍的需求/模式）。

Answer 2

您收到此编译器错误的原因如下。

flatmap 获取已完成的Mono 中的内容，并尝试将其转换为它可以推断的任何类型。 Mono.error 包含一个类型，该类型属于Object。

一种方法可能是将您的逻辑移动到平面图中。

// This is just example code using strings instead of repos
public Mono<String> insertUser(String user) {
    return Mono.just(user)
            // Here we map/convert instead based on logic
            .flatMap(__ -> {
                if (__.isEmpty())
                    return Mono.error(new IllegalArgumentException("User already exists with username [" + user + "]"));
                return Mono.just(user);
            }).switchIfEmpty(Mono.just(user));
}

switchIfEmpty 不适合做出合乎逻辑的决定，恕我直言。文档说明

如果此单声道已完成，则回退到备用单声道 没有数据

如果我们没有得到任何东西，这更像是对其他东西的后备，因此我们可以保持数据流继续进行。

你也可以

Mono.empty().doOnNext(o -> {
        throw new IllegalArgumentException("User already exists with username [" + o + "]");
    }).switchIfEmpty(Mono.just("hello")).subscribe(System.out::println);

Answer 3

我正在使用具有类型参数E 的抽象类，所以我不能使用.cast(E.class)。我们的解决方案是

private Mono<E> checkIfStatementExists(E statement) {
    return this.statementService.getByStatementRequestId(statement.getStatementRequestId())
            .flatMap(sr -> Mono.<E>error(new ValidationException("Statement already exists for this request!")))
            .switchIfEmpty(Mono.just(statement));
}

我想我需要在下周与我的同事讨论这件事。

编辑。我们和同事讨论过，更新的代码在上面。

Answer 4

遇到同样的问题，结果在下面做，

请注意：这不需要类型转换并且适用于两种情况，即

• 如果元素已存在于数据库中，则抛出错误。

• 插入元素，否则返回 Mono。

    public Mono<UserDTO> insertUser(User user) {
       return this.userRepository.findByUsername(user.getUsername())
               .flatMap(foundUser-> null != foundUser ? Mono
                       .error(new UserAlreadyExistsException(ExceptionsConstants.USER_ALREADY_EXISTS_EXCEPTION))
                       : Mono.just(user))
               .switchIfEmpty(this.userRepository.save(user))
               .map(userCreated -> copyUtils.createUserDTO(userCreated));
    }