如何在Spring WebFlux中配置反压？

Question

public void test() throws InterruptedException {
    EmitterProcessor<String> processor = EmitterProcessor.create();

    new Thread(() -> {
        int i = 0;
        while(runThread) {
            try {
                Thread.sleep(100);
            } catch (InterruptedException ignored) {
            }
            processor.onNext("Value: " + i);
            i++;
        }
        processor.onComplete();
    }).start();

    processor
            .subscribe(makeSubscriber("FIRST - "), Throwable::printStackTrace);
}

private Consumer<String> makeSubscriber(String label) {
    return v -> {
        System.out.println(label + v);
        try {
            Thread.sleep(1000);
        } catch (InterruptedException ignored) {
        }
    };
}

谁能给我一个反压的具体例子？最好是在Spring WebFlux中，但我会选择任何反应性Java库。

Answer 1

您选择的subscribe方法变体的文档如下：

订阅将请求一个无界请求(long.max_value)。

也就是说，你自己关掉了反压。