Reactor通量发布方法

Question

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

文档链接

• 发布（）

准备一个可连接的通量，该通量共享该通量序列，并以背压感知的方式向订户发送值。

ConnectableFlux<T> publish()

和

• 发布（整型预取）

准备一个可连接的通量，该通量共享该通量序列，并以背压感知的方式向订户发送值。

ConnectableFlux<T>  publish(int prefetch)

大理石图对两者都是一样的。什么是int prefinch参数？

我运行了这些例子，结果是一样的

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

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

预取允许您一次获得更多结果，在管理结果时允许某种缓冲。不管怎样，最终你还是会得到同样的结果；使用一种或另一种方法更像是一个效率/性能问题。