spring Webflux中的背压

Question

我对spring Webflux和整个反应性的想法很陌生。我有一些关于spring Webflux如何基于其反应发布器（Flux/Mono）处理请求的问题。以一个简单的控制器为例：

@PostMapping("/planets")
public Mono<Void> createNewPlanets(Flux<Planet> planetFlux) {

    return planetService
                       .insert(planetFlux.limitRate(10))
                       .then();
}

我理解limitRate（）充当下游请求的限制器。我的问题是，这种背压机制仅仅是根据我的参数（planetFlux）的单个请求而起作用的。WebFlux（或reactive programming）是否解决了请求负载过大的问题？这意味着我将如何针对多个并发请求优化上述代码？

我的第二个问题是，假设我应用了一些背压机制，那么planetFlux的剩余元素到底存储在哪里？再拿上面的代码来说，如果我在planetFlux中有100个元素，当我的下游处理它时，剩下的90个存储在哪里？是否存储在队列中？

如果你有的话，我很乐意读一些参考资料。希望我的问题足够清楚。

Answer 1

WebFlux（或reactive programming）是否解决了请求负载过大的问题？这意味着我将如何针对多个并发请求优化上述代码

Webflux的核心是针对重负载请求而设计的，它从“每个请求一个线程”的思想转变为实现基于事件的链，其中线程只在发出的事件期间工作。

如文件所述：

大体上有两种方法可以提高程序的性能：

>

并行化：使用更多的线程和更多的硬件资源。

在如何使用现有资源方面寻求更高的效率。

而反应性程序则试图实现第二个要点。

你的一小段代码没有什么要优化的，所以我真的不明白你到底想要优化什么，插入？

有人订阅了你的服务并发布了一堆行星。然后将插入速率限制为10，这样insert方法将获得一个通量，该通量将发出10个批量以插入到您正在插入的任何内容中。所以我不太明白你的问题。

你的第二个问题：

行星通量的剩余元素到底储存在哪里

如果您查看源代码，您可以看到以下内容。

在flux中，单个项作为直接向上的值存储在类FluxJust .class 中。而多个值则存储在FluxArray .class 中,作为一个简单的数组。