当flux从spring web Controller返回时会发生什么？

Question

我对反应性API比较陌生，很好奇当我们从web控制器返回流量时，幕后发生了什么。

根据spring-web文档

反应性返回值的处理如下：

与使用DeferreDreSult类似，适用于单值promise。例子包括单（反应器）或单（RxJava）。

@GetMapping("/async-deferredresult")
public DeferredResult<List<String>> handleReqDefResult(Model model) {
    LOGGER.info("Received async-deferredresult request");
    DeferredResult<List<String>> output = new DeferredResult<>();

    ForkJoinPool.commonPool().submit(() -> {
        LOGGER.info("Processing in separate thread");
        List<String> list = new ArrayList<>();
        for (int i = 0; i < 10000   ; i++) {
            list.add(String.valueOf(i));
        }
        output.setResult(list);
    });

    LOGGER.info("servlet thread freed");
    return output;
}


@GetMapping(value = "/async-flux",produces = MediaType.APPLICATION_JSON_VALUE)
public Flux<String> handleReqDefResult1(Model model) {
    LOGGER.info("Received async-deferredresult request");
    List<String> list = new ArrayList<>();
    list.stream();
    for (int i = 0; i < 10000   ; i++) {
        list.add(String.valueOf(i));
    }
    return Flux.fromIterable(list);
}

因此，例外是两个API的行为应该与多值流（Flux）的行为应该与返回deferredresult的行为相似。
但是在返回延迟结果的API中，整个列表在浏览器上一次性打印，在API中，流量被返回顺序打印的数字（一个接一个）。
当我从控制器返回流量时，到底发生了什么？

Answer 1

当我们从服务endpoint返回流量时，可能会发生许多事情。但是我假设您想知道当从这个endpoint的客户端观察到Flux作为事件流时会发生什么。

场景一：通过添加'application/JSON'作为endpoint的内容类型，Spring将与客户机通信以期待JSON主体。

@GetMapping(value = "/async-flux", produces = MediaType.APPLICATION_JSON_VALUE)
public Flux<String> handleReqDefResult1(Model model) {
    List<String> list = new ArrayList<>();
    for (int i = 0; i < 10000; i++) {
        list.add(String.valueOf(i));
    }
    return Flux.fromIterable(list);
}

因此，您看不到反应性API的真正价值。

@GetMapping(value = "/async-flux",produces = MediaType.APPLICATION_STREAM_JSON_VALUE)
public Flux<String> handleReqDefResult1(Model model) {
    List<String> list = new ArrayList<>();
    for (int i = 0; i < 10000   ; i++) {
        list.add(String.valueOf(i));
    }
    return Flux.fromIterable(list)
            // we have 1 sec delay to demonstrate the difference of behaviour. 
            .delayElements(Duration.ofSeconds(1));
}

这一次，我们可以看到reactive api endpoint的真正价值，在那里，当数据可用时，它能够将结果交付给它的客户机。

您可以在https://medium.com/@senanayake.kalpa/building-reactive-rest-apis-in-java-part-1-CD2C34AF55C6 https://medium.com/@senanayake.kalpa/building-reactive-rest-apis-in-java-part-2-BD270D4CDF3F找到关于如何构建反应性REST API的更多细节