使用WebClient Spring WebFlux的多个请求

Question

我试图使用WebClient并行地发出请求，但我不知道如何执行，因为无论我做什么，代码都不会等待请求完成。如果我只执行一个请求（注释片段），一切正常。有人能帮我吗？

@RequestMapping(method = [RequestMethod.POST], path = ["/upload/{batchId}"])
fun uploadFile(@RequestPart("file") file: Mono<FilePart>,
                       @PathVariable("batchId") batchId:String,
                       @RequestHeader("FILE-SIZE") fileSize:Int): Mono<ServiceResponse> {
    val webClient = WebClient.create(commandEndpoint)
    // return webClient.put().uri(seriesPath).retrieve().bodyToMono(String::class.java).map { ServiceResponse(it,0) }
    return file.map{it.transferTo(Paths.get(storagePath,"excel"))}
        .map{excelWorkbookToMetadata(WorkbookFactory.create(Paths.get(storagePath,"excel").toFile()))}
        .flatMapMany{Flux.fromIterable(it)}
        .flatMap {
            it.transactionId = batchId
            when (it) {
                is SeriesMetadata -> webClient.put().uri(seriesPath,it.id)
                    .body(BodyInserters.fromObject(it))
                    .retrieve()
                    .onStatus({ it == HttpStatus.BAD_REQUEST },{
                        println("ERROR")
                        Mono.error(RuntimeException("blah")) }).toMono()
                else -> Mono.error(NotImplementedError(""))
            }

        }
        .collectList()
        .map {ServiceResponse(batchId, it.size*2) }
}

Answer 1

看起来，collectList（）过滤掉在响应主体为空的情况下返回的空单声道。解决方案基本上是使用mono.DefaultifEmpty（）方法，或者将retrieve（）更改为exchange()，后者总是返回一些东西。至少这帮了我。