Spring Webflux：非Java客户端的背压

Question

是否有任何方法可以对非Java订阅服务器（例如，一些JS库）使用背压？

对于此发布者

Flux.range(1, 100)

此订阅者：

public class SystemOutBackpressureSubscriber<T> extends BaseSubscriber<T> {

    private int delay;

    public SystemOutBackpressureSubscriber(int delay) {
        this.delay = delay;
    }

    public void hookOnSubscribe(Subscription subscription) {
        request(1);
    }

    public void hookOnNext(T value) {
        System.out.println(value);
        if(delay != 0) {
            try {
                Thread.sleep(delay);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        request(1);
    }
}

如果延迟==0一次打印所有数字，但如果延迟！=0在打印每个数字之前都会暂停。除了JS之外，还有什么方法可以做到这一点吗？在我查看的所有Internet示例中，JS客户端只能监听事件流。如果Rest控制器返回生产者，如Flux.range（1,100），是否可以改变客户端上事件的频率？

Answer 1

不，因为HTTP协议不支持应用程序背压。您可能会对RSocket感兴趣，它是一种在协议级别支持背压的应用程序协议，以及许多其他功能。