本教程详细阐述了如何利用Java Stream API，将传统的forEach循环及其伴随的副作用操作，重构为高效、声明式的数据流处理。通过将查询逻辑封装为无副作用的映射函数，并结合`map()`和`collect()`方法，实现对集合元素的转换与收集，从而提升代码的可读性、简洁性及可维护性。
1. 引言：从命令式到声明式
在Java编程中，我们经常需要遍历集合并对每个元素执行某些操作，然后将结果收集起来。传统的做法是使用增强型for循环或forEach方法，并在循环体内部执行逻辑，通常伴随着对外部变量或集合的修改。这种命令式编程风格虽然直观，但在处理复杂数据流时，可能导致代码冗长、可读性差，并容易引入副作用，使得程序难以理解和维护。
Java 8引入的Stream API提供了一种全新的、声明式的数据处理方式。它允许我们以函数式编程的风格，对集合数据进行过滤、映射、排序、聚合等操作，而无需显式地管理迭代过程。本教程将以一个具体的例子，演示如何将一个典型的forEach循环及其内部的查询逻辑，转换为简洁高效的Stream API操作。
2. 传统forEach循环的问题与挑战
考虑以下场景：我们有一个日期列表，需要对每个日期执行数据库查询，并将查询结果（Load对象）收集到一个新的列表中。
立即学习“Java免费学习笔记（深入）”；
原始的命令式实现可能如下所示：
// 假设 Dates 是一个 List<LocalDate>
// 假设 loads 是一个 ArrayList<Load>，用于收集结果
Dates.forEach(date -> {
executeQuery(date, loads); // 在forEach内部调用方法，并传递外部集合
});
private void executeQuery(LocalDate date, ArrayList<Load> loads){
MapSqlParameterSource source = new MapSqlParameterSource();
source.addValue("date", date.toString());
Load load = namedJdbcTemplate.queryForObject(Constants.SQL_QUERY, source,
new BeanPropertyRowMapper<>(Load.class));
loads.add(load); // 直接修改外部传入的 loads 集合
}这段代码的问题在于：
- 副作用（Side Effect）：executeQuery方法不仅执行查询，还直接修改了传入的loads集合。这种对外部状态的修改使得方法不再是“纯粹”的，增加了理解和测试的难度。
- 可读性：虽然forEach比传统for循环简洁，但其内部的副作用逻辑仍然不够直观，尤其是在方法链式调用更长的情况下。
- 扩展性：如果后续需要对loads进行进一步的转换或筛选，可能需要更多的循环或临时变量。
3. 使用Stream API重构：核心思路
Stream API的核心思想是处理数据流，并通过一系列中间操作（如map、filter）和终端操作（如collect、forEach）来构建数据处理管道。为了利用Stream API的优势，我们需要对现有代码进行一些重构，特别是消除副作用。
3.1 步骤一：方法重构——消除副作用
为了让executeQuery方法能够更好地与Stream API的map操作结合，我们需要将其改造为一个“纯函数”：给定相同的输入，总是返回相同的输出，并且不产生任何副作用。这意味着它不应该修改任何外部状态，而是直接返回它计算出的结果。
将executeQuery方法修改为返回Load对象：
/**
* 根据日期执行数据库查询并返回 Load 对象。
* 此方法是纯函数，不修改外部状态。
* @param date 查询日期
* @return 对应的 Load 对象
*/
private Load executeQuery(LocalDate date){
MapSqlParameterSource source = new MapSqlParameterSource();
source.addValue("date", date.toString());
// 直接返回查询结果，不再修改外部集合
return namedJdbcTemplate.queryForObject(Constants.SQL_QUERY, source,
new BeanPropertyRowMapper<>(Load.class));
}3.2 步骤二：构建Stream管道——映射与收集
现在executeQuery方法已经是一个纯函数，我们可以利用Stream API的map操作来将每个LocalDate对象转换为一个Load对象。
完整的Stream API实现如下：
// 假设 dates 是一个 List<LocalDate>，通过 getYourDates() 方法获取 List<LocalDate> dates = getYourDates(); // 使用 Stream API 将日期列表转换为 Load 列表 List<Load> loads = dates.stream() // 1. 获取日期的Stream .map(this::executeQuery) // 2. 对Stream中的每个日期应用 executeQuery 方法进行转换 .collect(Collectors.toList()); // 3. 将转换后的 Load 对象收集到一个新的 List 中
或者，如果日期列表是方法调用的结果，可以直接链式调用：
List<Load> loads = getYourDates().stream() .map(this::executeQuery) .collect(Collectors.toList());
代码解析：
- dates.stream(): 从dates列表中创建一个顺序流。这是所有Stream操作的起点。
- .map(this::executeQuery): 这是一个中间操作。map方法接收一个Function作为参数，它会将流中的每个元素（LocalDate）通过该函数进行转换，生成一个新的元素（Load），并返回一个新的流。this::executeQuery是方法引用，等同于date -> this.executeQuery(date)。
- .collect(Collectors.toList()): 这是一个终端操作。它会消费流中的所有元素，并将它们收集到一个新的List中。Collectors.toList()是一个预定义的收集器，用于将流元素收集到List。
4. Stream API的优势
通过上述重构，我们获得了以下优势：
- 代码简洁性与可读性：Stream管道以声明式的方式清晰地表达了“对每个日期执行查询并收集结果”的意图，避免了显式的循环控制和副作用。
- 避免副作用：executeQuery方法现在是纯函数，不修改外部状态，使得代码更易于理解、测试和维护。整个Stream管道是无副作用的。
- 易于并行化：Stream API天然支持并行流（parallelStream()）。在数据量大且操作独立的情况下，只需将stream()改为parallelStream()，即可利用多核处理器进行并行处理，而无需手动管理线程。
- 声明式编程风格：开发者关注的是“做什么”（what to do），而不是“如何做”（how to do），提高了代码的抽象层次。
- 链式操作：Stream API支持链式调用，可以方便地组合多个中间操作，形成复杂的数据处理流程。
5. 注意事项与最佳实践
- 选择合适的场景：Stream API并非万能。对于简单的遍历和打印操作，forEach可能更直观。但当涉及数据转换、过滤、聚合等复杂操作时，Stream API的优势更为明显。
- 性能考量：对于小型集合，Stream API的性能开销可能略高于传统循环（由于对象创建和函数调用）。但在处理大量数据时，其并行处理能力可以带来显著的性能提升。
- 异常处理：Stream的lambda表达式中不能直接抛出检查型异常。如果executeQuery可能抛出检查型异常，需要进行适当的封装，例如使用try-catch块，或者自定义一个能够处理检查型异常的函数式接口。
- 避免过度使用：不要为了使用Stream而强制将所有循环都转换为Stream。选择最能清晰表达意图的方式。
6. 总结
Java Stream API为现代Java开发带来了强大的数据处理能力。通过将命令式的forEach循环及其副作用操作重构为声明式的Stream管道，我们不仅能够编写出更简洁、可读性更强的代码，还能提高代码的纯度和可维护性，并为潜在的并行处理提供了便利。掌握Stream API是每个Java开发者提升技能的重要一步。
