使用 Java Streams 实现高效数据处理-CSDN博客

本文链接：https://blog.csdn.net/codingexpert404/article/details/144875110

Java Streams 是 Java 8 引入的一项强大功能，专为简化集合操作、提升代码可读性以及优化数据处理效率而设计。本文将详细介绍 Streams 的基础概念、常用操作以及实际使用中的最佳实践。

什么是 Java Streams？

Java Streams 是一种用于处理数据序列的抽象，它允许开发者以声明式风格执行复杂的数据操作。与传统的集合操作不同，Streams 是惰性评估的，这意味着它们只在需要时计算数据，大幅减少不必要的性能开销。

核心特点包括：

声明式编程风格：通过流操作链实现功能，而无需手动编写繁琐的逻辑。
惰性计算：中间操作不会立即执行，只有在终止操作触发时才会处理。
并行化支持：通过 parallelStream()，轻松实现并行计算。

Streams 的基本组成

Streams 由三个部分组成：

数据源：可以是集合、数组、文件或其他 I/O 数据源。
中间操作：对数据进行转换或过滤，如 filter、map 等。
终止操作：触发流计算，如 collect、forEach 等。

核心操作详解

以下是 Streams 中常见操作的分类与用法。

1. 数据生成

可以通过以下几种方式创建 Stream：

import java.util.stream.Stream;
import java.util.Arrays;
import java.util.List;

public class StreamExample {
    public static void main(String[] args) {
        // 从集合创建
        List<String> list = Arrays.asList("Java", "Python", "C++");
        Stream<String> streamFromList = list.stream();

        // 从数组创建
        Stream<String> streamFromArray = Stream.of("A", "B", "C");

        // 无限流
        Stream<Integer> infiniteStream = Stream.iterate(0, n -> n + 1);
        infiniteStream.limit(5).forEach(System.out::println);
    }
}

2. 中间操作

中间操作是对流中数据的处理步骤，常见的操作包括：

filter：筛选符合条件的元素。
map：将每个元素映射为另一种形式。
flatMap：将嵌套结构展平成单一流。
sorted：对流中的数据排序。
distinct：去除重复数据。
peek：调试或观察每个元素。

示例代码：

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

public class IntermediateOperations {
    public static void main(String[] args) {
        List<String> names = Arrays.asList("Alice", "Bob", "Charlie", "Alice");

        List<String> result = names.stream()
            .filter(name -> name.length() > 3)
            .distinct()
            .sorted()
            .collect(Collectors.toList());

        System.out.println(result); // 输出: [Alice, Charlie]
    }
}

3. 终止操作

终止操作触发流的执行，包括：

collect：将流的结果收集为集合、列表或其他形式。
forEach：遍历流中的每个元素。
reduce：通过聚合函数生成单个结果。
count：计算流中的元素数量。

示例代码：

import java.util.Arrays;
import java.util.Optional;

public class TerminalOperations {
    public static void main(String[] args) {
        // 聚合操作
        Optional<Integer> sum = Arrays.asList(1, 2, 3, 4, 5).stream()
            .reduce(Integer::sum);

        sum.ifPresent(System.out::println); // 输出: 15
    }
}

使用 Streams 的最佳实践

避免修改源数据
Streams 的操作应尽量保证无副作用，避免修改原始数据。
善用惰性计算
将流的操作链优化为最少的步骤。例如，将过滤和映射合并，以减少不必要的操作。
并行流慎用
parallelStream() 虽然简单易用，但并不是所有场景都适合并行操作，特别是 I/O 密集型任务。
选择合适的终止操作
对于大规模数据处理，应优先选择 collect 而非 forEach，以便利用更高效的数据收集方式。

示例：从 CSV 文件中筛选数据

以下是一个使用 Streams 处理 CSV 文件的示例：

import java.io.IOException;
import java.nio.file.*;
import java.util.List;
import java.util.stream.Collectors;
import java.util.stream.Stream;

public class CSVProcessor {
    public static void main(String[] args) {
        try (Stream<String> lines = Files.lines(Paths.get("data.csv"))) {
            List<String> filteredLines = lines
                .skip(1) // 跳过表头
                .filter(line -> line.contains("keyword"))
                .collect(Collectors.toList());

            filteredLines.forEach(System.out::println);
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}