Java WebFlux中将List<String>转换为Mono<List<String>>的实现方法问询

基础实现方式 #

直接使用WebFlux核心API中的Mono.just()方法封装已有的List对象即可，这是最高效的实现方案，代码示例如下：

import reactor.core.publisher.Mono;
import java.util.ArrayList;
import java.util.List;

public class ListConvertDemo {
    public static void main(String[] args) {
        // 你已定义的List逻辑
        List<String> lstString = new ArrayList<>();
        lstString.add("Hello");
        lstString.add("How");
        lstString.add("are");
        lstString.add("you?");
        
        // 直接封装得到目标类型
        Mono<List<String>> monoList = Mono.just(lstString);
    }
}

响应式流场景适配 #

如果你是在响应式链路中从多个独立字符串元素聚合得到目标结果，可以使用Flux.collectList()方法实现，示例如下：

import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;
import java.util.List;

public class FluxAggDemo {
    public static void main(String[] args) {
        // 从多元素Flux流聚合得到Mono<List<String>>
        Mono<List<String>> monoList = Flux.just("Hello", "How", "are", "you?")
                .collectList();
    }
}

常见问题说明 #

你之前使用stream、map、flatMap只得到普通List的原因是：这些操作都是针对流内部元素做处理，没有做外层响应式类型封装。如果是在已有响应式链路中处理需要注意避免嵌套Mono问题：

// 错误写法：会生成嵌套的Mono<Mono<List<String>>>
Mono<Mono<List<String>>> wrongResult = someMono.map(data -> {
    List<String> list = new ArrayList<>();
    // 填充List的业务逻辑
    return list;
}).map(Mono::just);

// 正确写法：使用flatMap展开嵌套结构
Mono<List<String>> correctResult = someMono.map(data -> {
    List<String> list = new ArrayList<>();
    // 填充List的业务逻辑
    return list;
}).flatMap(Mono::just);

内容的提问来源于stack exchange，提问作者Palio