首页 > 解决方案 > Spring Webflux - 是否可以启用/实现反应式推送(而不是拉)背压?

问题描述

是否可以为 a 添加反应性推送背压Publisher

从我所见,这是非常可行的Subscriber

背压是下游可以告诉上游发送更少的数据以防止其不堪重负。

我想做相反的事情——当特定下游无法跟上时,我想减慢甚至暂停上游。我想知道是否有一种很好的反应方式来做到这一点,比如实现自定义OverflowStrategy?现有的策略似乎不适合我的情况。

我不能丢弃消息或错误,也不能使用缓冲策略,因为我最终会耗尽内存。

我可以想到一个自定义解决方案,其中我发出的对象被池化,以便我可以限制内存中的对象数量并在它们被消耗时释放它们,但这似乎不是一个反应性解决方案。

标签: javaspring-webfluxproject-reactor

解决方案


推荐阅读