了解webflux中的背压

Question

我不熟悉反应式/网络流量，正在尝试理解网络流量中的背压。我有以下控制器。我们的应用程序接收一个JSON搜索请求，并用流量流进行响应。

@PostMapping(path = "/search",
            consumes = MediaType.APPLICATION_JSON_VALUE,
            produces = MediaType.APPLICATION_STREAM_JSON_VALUE)
public Flux<ResponseContainer> getItineraries(@RequestBody SearchRequest searchRequest){

        return searchService
              .convertToFlux(searchRequest)
              .map(<do some transformations>)
              .map(<WebClientRequestsDownstream>)
              .map(<aggregrate>);
    }

背压是应用于流的一个实例还是整个实例？i、 e.如果我有一个流，其中请求通过webflux控制器传入，那么在以前的请求中会减慢速度吗？会对将来的请求施加反向压力吗？或者只会因为基于当前活动请求的放缓而导致活动通量流的放缓而施加背压吗？

Answer 1

通量是一个发布者，通过向订阅者处理订阅连接到“请求”。每个订阅者都有自己的订阅，因此您可以将这种关系视为单个请求的具体化，而发布者更像是endpoint（如果我们简化并只考虑冷发布者，即为每个订阅者生成专用数据集的发布者）。

背压是由订阅者呼叫订阅请求驱动的，因此它在每个请求的级别上是分开的。