java - Spring Webflux - 是否可以启用/实现反应式推送(而不是拉)背压?
问题描述
是否可以为 a 添加反应性推送背压Publisher
?
从我所见,这是非常可行的Subscriber
:
背压是下游可以告诉上游发送更少的数据以防止其不堪重负。
我想做相反的事情——当特定下游无法跟上时,我想减慢甚至暂停上游。我想知道是否有一种很好的反应方式来做到这一点,比如实现自定义OverflowStrategy
?现有的策略似乎不适合我的情况。
我不能丢弃消息或错误,也不能使用缓冲策略,因为我最终会耗尽内存。
我可以想到一个自定义解决方案,其中我发出的对象被池化,以便我可以限制内存中的对象数量并在它们被消耗时释放它们,但这似乎不是一个反应性解决方案。
解决方案
推荐阅读
- c - 为什么会出现“从不兼容的类型 'void *' 分配给 'int *'”错误?
- reactjs - 在 ReactJS 中的兄弟姐妹之间共享状态(状态不在父级中)
- reactjs - react中的statement中的statement怎么做?
- testing - Postman 中的循环请求(使用 POST 请求)
- sql - 在列中将“the”更改为“The”
- python - 将无效的 url 重新路由回 django 中的主页
- java - 自动化测试用例适用于 appium 命令行工具,但不适用于桌面客户端
- oracle - 如果日期是 2 月 28 日,则 add_months 和 to_date 的组合出错
- kubernetes - GCR 在拉取 docker 图像时非常慢
- ffmpeg - Testcafe黄瓜记者视频录制