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,即使您对第二个（最里面的）DoonNext进行了（正确的）更改之后？

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

只需将doOnNext替换为FlatMap（并将您对最内部doOnNext的更改保留为SwitchIfEmpty)，即可使其成为Spring将订阅的反应链的一部分。