doOnNext() 不会被称为 Spring Webflux

Question

我是响应式编程和 Spring Webflux 的新手 我有一个从 Redis 获取某个键的方法，如果该键为 null 或不等于指定的字符串，我想抛出异常，但不会调用嵌套的 donOnNext 方法，并且在异常必须触发时customerRepository.save(customer) 会被触发被抛出并打破链条。有人可以向我解释一下在我的情况下反应器 API 的行为方式吗？

这是我的方法：

@Override
public Mono<RegistrationVerificationResDTO> verifyCustomerAndGenerateToken(Mono<VerifyOtpReqDTO> verifyOtpReqDTO) {
    return verifyOtpReqDTO
            .doOnNext(verifyDTO -> reactiveRedisOperations
                    .opsForValue()
                    .get(RedisDictionary.OTP_KEY + verifyDTO.getPhoneNumber())
                    .filter(otp -> otp.equalsIgnoreCase(verifyDTO.getOtp()))
                    .switchIfEmpty(Mono.error(ForbiddenException::new)))
            .map(verifyDTO -> customerRepository.findById(verifyDTO.getId())
                    .orElseThrow(() -> new NotFoundException("Customer not found")))
            .doOnNext(customer -> {
                customer.setVerified(true);
                customerRepository.save(customer);
            })
            .map(customer -> new RegistrationVerificationResDTO().setAccessToken("accessToken")
                    .setRefreshToken("refreshToken")
                    .setCustomer(customer));
}

更新： 我意识到如果我们在 doOnNext 方法中创建另一个发布者，因为 spring 只是订阅了最外部的发布者，内部的发布者不会被触发我已经更新了我的代码，但它仍然不起作用。

Answer 1

我猜你说这个“不起作用”是因为你无法观察到数据库中保存的customer，即使在你对第二个（最里面的）@ 进行了（正确）更改之后987654322@?

第三个doOnNext 是有问题的：customerRepository.save(customer) 是一个 NO-OP，假设 customerRepository 是一个反应式存储库，因为（懒惰的）Mono 既没有附加到主序列也没有订阅。

只需将 doOnNext 替换为 flatMap（并将对最里面的 doOnNext 的更改也保留为 switchIfEmpty），使其成为 Spring 将订阅的响应链的一部分。