以反应方式一次发送一个对象列表

Posted 2023-02-27

【中文标题】以反应方式一次发送一个对象列表

【英文标题】：Send a list of objects one at time in reactive way

【发布时间】：2021-12-05 16:13:38

【问题描述】：

我正在通过一个带有对象的休息控制器方法接收请求，然后我将其传递给服务层中的方法。

此请求中的对象包含如下列表：

public class BalanceAlertServiceRequestData extends AlertServiceRequestData 
    
   private List<BalanceAlertAttribute> balanceAlertList;

不像我在其他方法中所做的那样，在 Mono 中一次发送整个列表，在这种情况下，需要一次发送一个列表项。

代码注释中有问题的方法如下：

public Mono<AlertServiceResponse> sendBalanceAlertDataToPrepaid(BalanceAlertServiceRequest cartasRequest) 
    return Mono.just(cartasRequest.getBalanceAlertServiceRequestData().getBalanceAlertList())
        // what goes here to read off each element, transform it, and then send it of as a single element in a Mono?
        // Would it be something like "doOnEach(mapBalanceAlertServiceRequestToBalanceChangeAlertResponse)?"
        .flatMap(prepaidClient::sendBalanceAlertData)
        .thenReturn(cartaResponse(cartasRequest.getServiceRequestId()));

【问题讨论】：

你是如何获取cartasRequest.getBalanceAlertServiceRequestData().getBalanceAlertList()中的数据的，你使用R2DBC吗？

它通过 Rest 控制器传入 JSON 请求数据，因此 Jackson 正在反序列化这些数据并填充列表。

【参考方案1】：

这样做的预期方法是实际使用fromIterable 方法并提供您的List：

 return Flux.fromIterable(cartasRequest.getBalanceAlertServiceRequestData().getBalanceAlertList())
                .flatMap(prepaidClient::sendBalanceAlertData)
// convert to Mono again

【讨论】：

非常感谢您！不过，我现在还有一些问题......那么这会返回 BalanceAlertAttribute 的 Mono 吗？如果我正确阅读文档，这将返回 Flux?还是返回一个带有单个元素的 Flux？

Flux.fromIterable 创建 Flux 的 BalanceAlertAttribute。将为Flux 的每个项目调用sendBalanceAlertData 方法。

啊好吧，太棒了！谢谢你的澄清！ :)