如何在 java 中将 Mono<List> 对象转换为简单的 List 对象？

Question

我正在尝试使用 JAVA web-flux 创建一个 POST API。在此 API 中，我想创建一个字符串列表并进行数据库调用以获取 Mono<List> 作为响应，但是当我尝试使用 block() 将 Mono<List> 转换为简单列表对象时，我得到以下响应：

{
    "code": 500,
    "message": "block()/blockFirst()/blockLast() are blocking, which is not supported in thread reactor-http-nio-8"
}

如何将 Mono 对象转换为简单的 List 对象？

我正在使用以下代码：

List<String> paymentInstrumentIdList = paymentInstrumentRequest.getPaymentInstruments().stream().map(PaymentInstrumentData::getPaymentInstrumentId).collect(Collectors.toList());
Mono<List<PaymentInstrument>> paymentInstrumentList = paymentInstrumentRepository.getByPartitionKey(partitionKey.toString(), DocType.PAYMENT_INSTRUMENT, paymentInstrumentIdList);
return ResponseEntity.ok(responseMapper.getResponseAsClass(graphQlQueryController.queryPaymentInstrumentsByPaymentInstrumentId(baseHeaders, personId, membershipId, paymentInstrumentList.block()), Wallet.class, "Wallet"));

Answer 1

使用 webflux 应用程序的全部目的是你不能阻止

您正在寻找的是flatMap 函数。

return paymentInstrumentRepository.getByPartitionKey(
    partitionKey.toString(), 
    DocType.PAYMENT_INSTRUMENT, paymentInstrumentIdList)
    .flatmap(list -> {
        return return ServerResponse.ok().body(responseMapper.getResponseAsClass(
    graphQlQueryController.queryPaymentInstrumentsByPaymentInstrumentId(
        baseHeaders, 
        personId, 
        membershipId, 
        list);
    };

这是 webflux 的基础知识，我建议你阅读official reactor documentation getting started，以便了解基础知识和目的。

答案是写在手机上的，未经测试。

这里也是getting started tutorial