当溢出策略为缓冲区时Webflux会下降

Question

kotlin prettyprint-override">fooRepository.findOne()
    .doOnNext { barRepository.save(bar).subscribe() }
    .flatMap { ... }

这篇文章说默认的溢出策略是缓冲区。

doOnNext内部的subscribe（）调用有不同的策略吗？

Answer 1

我可以假设您的订阅在持久性完成之前就结束了。

doonnext()旨在执行一些副作用行为，您不应该在这些行为中实现业务逻辑。因此，我相信存储库调用引发的异常或发生的任何事情都不会转换到主反应链中，所以您只是简单地失去了对内部内容的控制。

如果您需要确保业务逻辑操作已经完成并且不会丢失，那么最好在主流程中包含flatmap()运算符。