如何用Java Streams API实现消息起始校验与过滤的函数式编程

当然可以用Streams API实现这个需求，核心思路是先校验首行是否符合要求，再对后续行进行过滤拼接。下面提供两种简洁的实现方式：

方式一：先收集为List再判断处理 #

这种方式可读性强，适合大多数场景：

String inputMessage = "message from arunmantics.com\nX-Header: test\nHello World\nX-Another: val\nFinal Line";

String processed = Arrays.stream(inputMessage.split(System.lineSeparator()))
    .collect(Collectors.collectingAndThen(
        Collectors.toList(),
        lines -> {
            // 校验首行是否符合要求
            if (lines.isEmpty() || !lines.get(0).startsWith("message from arunmantics.com")) {
                return ""; // 不符合条件时返回空，也可根据需求返回原消息
            }
            // 处理后续行：跳过首行，过滤X-开头的行，拼接剩余内容
            return lines.stream()
                .skip(1)
                .filter(line -> !line.startsWith("X-"))
                .collect(Collectors.joining(System.lineSeparator()));
        }
    ));

System.out.println(processed);
// 输出：
// Hello World
// Final Line

方式二：结合迭代器与Stream #

如果不想提前收集所有行，可以先用迭代器校验首行，再将剩余元素转回Stream处理：

String inputMessage = "message from arunmantics.com\nX-Header: test\nHello World\nX-Another: val\nFinal Line";

Stream<String> lineStream = Arrays.stream(inputMessage.split(System.lineSeparator()));
Iterator<String> lineIterator = lineStream.iterator();

String processed;
if (!lineIterator.hasNext() || !lineIterator.next().startsWith("message from arunmantics.com")) {
    processed = "";
} else {
    // 将剩余迭代器元素转为Stream继续处理
    processed = StreamSupport.stream(
            Spliterators.spliteratorUnknownSize(lineIterator, Spliterator.ORDERED),
            false
        )
        .filter(line -> !line.startsWith("X-"))
        .collect(Collectors.joining(System.lineSeparator()));
}

System.out.println(processed);
// 输出同上

为什么直接用findFirst无法满足需求？ #

findFirst()仅用于获取流中的第一个元素并终止流，但你的需求是先校验首行，再处理后续所有元素，这需要对整个流进行分阶段处理，而非只取首行。上面两种方式都很好地解决了这个问题，同时保持了函数式编程的风格。

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