了解spring WebFlux/Reactiveendpoint

Question

我试图弄清楚spring的反应性终点，这让我感到困惑。

// in a @RestController
@GetMapping("/someendpoint")
fun someEndpoint(): ResponseEntity<Mono<Map<String, Any>>> {
    return ResponseEntity(Mono.zip(
        Mono.fromRunnable<List<SomeItem>> { someApiCall() },
        Mono.fromRunnable<List<SomeOtherItem>> { someOtherApiCall() },
    ).map { tuple ->
        val someItems = tuple.t1
        val someOtherItems = tuple.t2
        mapOf(
            "someItems" to someItems,
            "someOtherItems" to someOtherItems
        )
    }, HttpStatus.OK)
}

我有一个endpoint，它返回一个映射的Mono，这个想法只是呈现一些任意的JSON。

作为请求的一部分，我做了一个mono.zip（mono.fromrunnable{...}），在这里我调用API获取数据。

在zip之后，我对结果执行一个.Map操作，并最终返回我希望看到呈现的地图。

当我到达endpoint时，不会呈现任何JSON，但会调用zip中的运行文件，并且响应时间会考虑到这些API调用。zip后面的.map从不调用。我可能只是不理解这里的一些简单的东西--比如.Map不是订阅的？

这里发生了什么？使用WebFlux/Reactor处理这种情况的通常方法是什么？

Answer 1

正如Rene在评论中提到的，我的错误是使用了Mono.FromRunnable{}而不是Mono.FromSupplier{}