Java Stream flatMap 怎样处理空集合

Java Stream flatMap 遇到真正的空集合时，无需特殊补位：空集合转成的流没有元素，展开后自然不贡献内容。要额外处理的是 null 子集合、子集合内的 null 元素，以及最外层集合本身为 null。这三种情况不等于“空集合”，也不能共用一个含糊的兜底。

先确定空值不能掩盖的业务错误

以批量汇总文档标签为例，有的文档没有标签，这属于正常空集合；有的接口把可选标签字段返回为 null，可能允许按无标签处理；如果整批读取失败却拿到 null，则不应悄悄返回空结果，让调用方误以为读取成功。本文约定：外层批次必须存在，子集合缺省视为没有标签，标签元素 null 则忽略。若你的接口契约更严格，就应在适配入口拒绝缺省数据。

这不是给 flatMap 添加安全开关，而是先限制数据解释的权限：展开函数可以合并已有集合，但不应自行决定远程失败等同于无数据。下面只处理内存中的集合，使用 Java 8 可用的写法；不会访问数据库、网络或文件，也不包含隐藏重试。

用纯集合示例理解空集合展开

import java.util.ArrayList;
import java.util.Arrays;
import java.util.Collections;
import java.util.List;
import java.util.stream.Collectors;

public class EmptyGroupExample {
    static List flattenPresentGroups() {
        List> groups = Arrays.asList(
                Arrays.asList("文档", "归档"),
                Collections.emptyList(),
                Collections.singletonList("搜索")); // 空组仍然是合法输入

        return groups.stream()
                .flatMap(List::stream) // 每组提供自己的元素，不保留空组占位
                .collect(Collectors.toCollection(ArrayList::new));
    }
}

按这些输入推导，合并列表应包含“文档、归档、搜索”，中间不插入空字符串或 null。这里说明的是预期语义，并非本机运行结果。若下游仍需要知道哪个文档没有标签，就不应该只保留一张扁平列表：展开会丢失组边界，应该同时保留文档标识或原始分组。

图中的外层集合拥有普通子集合和空子集合；它们都可映射为子流。flatMap 合并的是这些子流的元素，不是把每个子集合当成一个结果元素。

在映射边界统一 null 子集合策略

如果 groups 中可能有 null，List::stream 会尝试在 null 引用上调用方法。异常发生在 mapper 取流的过程中；“flatMap 对 mapper 返回的 null 流按空流处理”的规则，并不会替你捕获这个异常。可读性更好的选择是显式返回 Stream.empty()，把子集合的缺省策略写在一个位置。

import java.util.ArrayList;
import java.util.List;
import java.util.Objects;
import java.util.stream.Collectors;
import java.util.stream.Stream;

public final class TagGroups {
    private TagGroups() {} // 工具类不保存共享状态

    public static List flattenOptionalGroups(List> groups) {
        Objects.requireNonNull(groups, "外层批次不能为 null"); // 不把读取失败当成空批次
        return groups.stream()
                .flatMap(TagGroups::optionalGroupStream)
                .filter(Objects::nonNull) // 子集合中的 null 元素单独处理
                .collect(Collectors.toCollection(ArrayList::new));
    }

    private static Stream optionalGroupStream(List group) {
        return group == null ? Stream.empty() : group.stream(); // 只容忍可选子集合缺省
    }
}

两处处理不能混淆：mapper 处理 null 子集合，展开后的 filter 处理 null 标签。过滤放在展开之前只能去掉组引用，不能清理组内元素。这里选择 ArrayList 收集器，是为了明确结果需要可修改的列表；是否去重、裁剪空白和限制长度，是另外的业务规则，不能从“合并标签”四个字推断出来。

如果标签字段按协议必须存在，把 optionalGroupStream 中的宽容分支换成明确的参数拒绝，并在接口适配层标记错误来源。不要 catch 所有 RuntimeException 后统一返回空流，否则数据结构错误也会被伪装成成功。生产接入时应只选定一套策略，不要让不同调用方猜测同一个 null 的含义。

分开展开与权限过滤职责

展开不是权限过滤。文档是否属于当前租户、当前用户能否读取它，应由取数和授权逻辑确定；null 处理既不能扩大读取范围，也不能用“没有标签”掩盖授权失败。本文函数应接收已获准处理的数据，不在 mapper 中临时查权限或远程补查字段。

可以把责任拆成输入适配器、展开函数和授权取数层。输入适配器负责 null 策略，展开函数只组合元素，授权取数层决定哪些数据能被传入。这样更容易定位“没有标签”究竟是合法业务状态、数据缺省还是取数失败，而不是在长链式表达式中加入越来越多副作用。

记录汇总信息并列出接入检查

需要观测时，建议在批次边界记录输入文档数、缺省标签组数以及最终标签数，不输出原始标签内容。完整的数据质量统计不要依赖 peek：流可能短路，某些中间操作也可能被优化；如果必须统计所有输入，应在明确的边界遍历中完成，再建立新的流。也不要为了统计先消费一条 Stream，再尝试第二次复用它。

接入前还应约定输入集合在处理期间不被其他代码修改。这里不承诺并行化收益；先保持无共享副作用的顺序处理，避免为了合并少量标签增加并发复杂度。表中都是调用方可采用的行为清单，未执行测试或性能测量。

空子集合必须提前 filter 掉吗？

为了语义正确不必。正常空集合产生空流即可。是否增加判断应根据明确需求，而不是认为 flatMap 无法处理零元素。

返回 null 流和抛空指针异常是一回事吗？

不是。前者是 mapper 正常返回的特殊结果；后者是 mapper 没有正常完成。显式空流更能表达“此组合法地没有元素”。

需要为没有标签的文档补一个空字符串吗？

只有下游协议确实要求时才补。更稳妥的是保留文档与标签的结构关系，避免空字符串同时表示“缺省”“真实空内容”和“读取失败”。

官方参考：Stream 的 flatMap 与流使用约定；Objects 的空值工具方法；Collectors 集合收集器。