预取在项目Reactor中意味着什么？

Question

我使用项目反应器，并使用Flux.flatMapIterable。（我基本上有一个对象A的流；对于每个对象A，我将其平面化为对象B的流，并从中制作一个新的通量。）

我试图理解预取设置的作用。在我的例子中，每个对象A都可以潜在地转换为任意数量的对象B（在0到N之间；N很大）。

我只是想了解：

>

什么是prefetch？它只适用于初始请求吗？（即，如果我将其设置为1，如果项目Reactor发现1太小，它是否足够智能以增加请求大小？）

这与我在这里的情况有关吗？为了保守起见，我考虑将预取设置为1，因为单个a对象有可能被平面映射为大量B对象。

Answer 1

预取将影响发布者在其第一个请求中向反应器请求的项目数。它是一个上限，影响后续请求，当发出75%的预取量时，将触发后续请求，因此不会自动增加。

它通常用于以下场景：消费者请求大量数据，但数据源表现更好，或者可以使用较小的请求进行优化（例如数据库分页等）。

它是否与您的用例相关取决于您的出版商的特点。

来自配置背压1的[文档]

您可能还注意到，一些运算符具有接受名为prefetch的int输入参数的变体。这是另一类修改下游请求的运算符。这些通常是处理内部序列的运算符，从每个传入元素（如平面图）派生一个Publisher。

预取是一种调整对这些内部序列发出的初始请求的方法。如果未指定，这些运算符中的大多数都从需求32开始。

这些运营商通常还实施补充优化：一旦运营商看到25%的预取请求得到满足，它就会从上游重新请求25%。这是一种启发式优化，使这些操作员能够主动预测即将到来的请求。