java - Reactor Flux 发布方法

Question

我需要 Reactor 项目中这两种方法的解释

docs-link

• 发布()

Prepare a ConnectableFlux which shares this Flux sequence and dispatches values to subscribers in a backpressure-aware manner.

ConnectableFlux<T> publish()

还有

• 发布(int预取)

Prepare a ConnectableFlux which shares this Flux sequence and dispatches values to subscribers in a backpressure-aware manner.

ConnectableFlux<T>  publish(int prefetch)

两者的大理石图是相同的。 int prefetch 参数的作用是什么？

我运行这些示例，结果是相同的

public static void publish() throws InterruptedException {
    Flux fl = Flux.just(1, 2, 3, 4, 5, 6)
            .delayElements(Duration.ofSeconds(1))
            .publish()
            .autoConnect();
    fl.subscribe(printing);
    Thread.sleep(4000);
    fl.subscribe(printing);
}

public static void publishWithPrefetch() throws InterruptedException {
    Flux fl = Flux.just(1, 2, 3, 4, 5, 6)
            .delayElements(Duration.ofSeconds(1))
            .publish(2)
            .autoConnect();
    fl.subscribe(printing);
    Thread.sleep(4000);
    fl.subscribe(printing);
}

Answer 1

您的两个文档链接都是同一目标。

预取允许您一次获得更多结果，从而在管理结果时允许某种缓冲。无论如何，最终你仍然会得到相同的结果；使用一种或另一种方法更多的是一个效率/性能问题。