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

Question

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

我在存储库层调用一个方法，该方法将通过用户名查找用户，如果找不到，它将返回一个空的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




Answer 1

我使用的抽象类具有类型参数E，因此无法使用。铸造（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 2

出现此编译器错误的原因如下。

获取已完成的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));
}

\fs16\an2\b0\b0\b0\b0\b0\b0\b0\b0对于做出逻辑决策来说不是超级好。留档上写着

如果这个单声道在没有数据的情况下完成，回退到另一个单声道

如果我们没有得到任何东西，这更像是一种退回到其他地方的退路，所以我们可以继续数据流。

你也可以

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

Answer 3

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

    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);
    }

正如托马斯所说，编译器正在变得混乱。我的假设是因为flatMap返回一个带有错误的Mono，而switchIfEmpty返回一个带有用户的Mono，因此它会返回一个带有对象的Mono（因此需要额外的.cast操作符来编译它）。

另一个添加是添加Mono。延迟开关映射中的。否则，开关ifempty总是启动。

我仍然愿意接受其他建议/替代方案（因为这似乎是一个相当普遍的需求/模式）。