在project reactor中有没有可能有一个对多个订阅者有独立背压支持的热发布者？

Question

我的情况如下:

我有一个生成随机数据的生成器。生成的数据应由多个订户接收。由于生成的数据是随机的，我不能使用冷发布者，因为在冷发布者的情况下，有几个订阅者会收到不同的数据。因此，我需要一个热门出版商，但我不确定在热门出版商的情况下，如何从我的订阅者发出有界的请求。我的一个订阅者任务是CPU绑定的，而另一个任务是IO绑定的，所以第二个任务很可能会慢。在以下情况下，热门发布者的行为有点令人困惑：

1. CPU 密集型订阅者发出无限制的请求
2. IO 绑定订阅者发出有界请求，例如一次 100 个项目

在冷发布者的情况下，显然每个订阅者可以独立于其他订阅者控制背压，因此请描述在热发布者和多个订阅者的情况下背压如何工作，因为在我的情况下，CPU绑定订阅者接收数据的速率将是IO绑定订阅者的速率，这似乎不是最佳的，因为一个订阅者依赖于其他订阅者。

Answer 1

我会说这取决于热门出版商，但您可能会期望它最多会遵循（编辑：最低）需求。

编辑:这完全取决于热门出版商，没有通用规则。

但从概念上讲，它们在不同的订户之间“共享”数据，因此为了不压倒其中一个订户，它们必须跟踪单个订户的请求并相应地将无关数据排队，或者对其源执行一个与订户之间的最低请求相匹配的请求Flux#publish（）（从某种程度上讲，flu#share（））执行后面的操作。