本教程旨在指导如何使用java 8 stream api重构传统java代码中涉及列表遍历、外部数据查询及元素更新与过滤的场景。我们将通过一个具体示例，展示如何将命令式循环转换为更具函数式风格的流操作，包括安全处理 `optional` 类型和高效执行列表元素移除，从而提升代码的简洁性和可读性。
传统代码中的常见问题与Java 8 Stream的引入
在日常开发中，我们经常会遇到需要遍历一个集合，根据集合中每个元素的属性去查询外部数据（如数据库），然后更新该元素的某个字段，最后可能还需要对集合进行过滤的场景。传统的Java做法通常涉及 for 循环和条件判断，这种命令式风格的代码在处理复杂逻辑时，可能会显得冗长且不易维护。
考虑以下一个典型的Java方法，它负责根据制造商ID和价格代码更新 ItemPriceCode 的制造商价格名称，并移除已标记为删除的价格代码。此示例中，manufacturerPriceCodesRepository 模拟了数据库访问层。
import java.util.List;
import java.util.Optional;
import static com.example.Constants.NOT_DELETED; // 假设常量定义
import static com.example.Constants.DELETED; // 假设常量定义
// 假设Item, ItemPriceCode, ManufacturerPriceCodes是POJO
// 假设manufacturerPriceCodesRepository是JPA Repository或类似的DAO
public class ItemService {
private ManufacturerPriceCodesRepository manufacturerPriceCodesRepository; // 依赖注入
// 构造函数或setter注入
public ItemService(ManufacturerPriceCodesRepository manufacturerPriceCodesRepository) {
this.manufacturerPriceCodesRepository = manufacturerPriceCodesRepository;
}
private Item getItemManufacturerPriceCodes(Item item) {
List<ItemPriceCode> itemPriceCodes = item.getItemPriceCodes();
// 遍历并更新ItemPriceCode
for (ItemPriceCode ipc : itemPriceCodes) {
Optional<ManufacturerPriceCodes> mpc = manufacturerPriceCodesRepository.findByManufacturerIDAndPriceCodeAndRecordDeleted(
item.getManufacturerID(), ipc.getPriceCode(), NOT_DELETED);
if (mpc.isPresent()) {
ipc.setManufacturerPriceCode(mpc.get().getName());
}
}
// 过滤并移除已删除的ItemPriceCode
itemPriceCodes.removeIf(ipc -> DELETED.equals(ipc.getRecordDeleted()));
return item;
}
}
// 假设的Repository接口和实体类定义
interface ManufacturerPriceCodesRepository {
Optional<ManufacturerPriceCodes> findByManufacturerIDAndPriceCodeAndRecordDeleted(
String manufacturerID, String priceCode, String recordDeleted);
}
class Item {
private String manufacturerID;
private List<ItemPriceCode> itemPriceCodes;
public String getManufacturerID() { return manufacturerID; }
public void setManufacturerID(String manufacturerID) { this.manufacturerID = manufacturerID; }
public List<ItemPriceCode> getItemPriceCodes() { return itemPriceCodes; }
public void setItemPriceCodes(List<ItemPriceCode> itemPriceCodes) { this.itemPriceCodes = itemPriceCodes; }
}
class ItemPriceCode {
private String priceCode;
private String manufacturerPriceCode; // 需要更新的字段
private String recordDeleted;
public String getPriceCode() { return priceCode; }
public void setPriceCode(String priceCode) { this.priceCode = priceCode; }
public String getManufacturerPriceCode() { return manufacturerPriceCode; }
public void setManufacturerPriceCode(String manufacturerPriceCode) { this.manufacturerPriceCode = manufacturerPriceCode; }
public String getRecordDeleted() { return recordDeleted; }
public void setRecordDeleted(String recordDeleted) { this.recordDeleted = recordDeleted; }
}
class ManufacturerPriceCodes {
private String name; // 需要获取的字段
public String getName() { return name; }
public void setName(String name) { this.name = name; }
}这段代码功能完整，但 for 循环部分显得有些传统。Java 8 引入的 Stream API 提供了一种更声明式、更简洁的方式来处理集合数据。
使用Java 8 Stream API重构
我们将分两步来重构上述方法：首先处理 ItemPriceCode 的更新逻辑，然后处理列表的过滤逻辑。
立即学习“Java免费学习笔记（深入）”；
1. 更新 ItemPriceCode 的制造商价格名称
原代码中使用 for 循环遍历 itemPriceCodes，并在循环内部执行数据库查询和条件更新。在Stream API中，对集合元素的原地修改通常通过 forEach 终端操作来实现。map 操作主要用于将流中的元素转换为另一种类型或创建一个新的元素，而不是修改现有元素。
在这里，我们希望修改 itemPriceCodes 列表中已存在的 ItemPriceCode 对象，因此 forEach 是更合适的选择。
// 获取ItemPriceCode列表
List<ItemPriceCode> itemPriceCodes = item.getItemPriceCodes();
itemPriceCodes.stream()
.forEach(ipc -> {
// 对于每个ItemPriceCode，执行数据库查询
Optional<ManufacturerPriceCodes> mpc = manufacturerPriceCodesRepository.findByManufacturerIDAndPriceCodeAndRecordDeleted(
item.getManufacturerID(), ipc.getPriceCode(), NOT_DELETED);
// 如果查询结果存在，则更新ItemPriceCode的字段
mpc.ifPresent(m -> ipc.setManufacturerPriceCode(m.getName()));
});解释：
- itemPriceCodes.stream(): 将列表转换为一个流。
- .forEach(ipc -> { ... }): 这是一个终端操作，它会对流中的每个元素执行提供的 Consumer 函数。在这里，我们利用它来执行带有副作用（修改 ipc 对象）的操作。
- mpc.ifPresent(m -> ipc.setManufacturerPriceCode(m.getName())): 这是处理 Optional 的推荐方式。它避免了显式的 if (mpc.isPresent()) { mpc.get()... } 结构，使代码更简洁、更安全，防止 NoSuchElementException。
2. 过滤已删除的 ItemPriceCode
原代码中已经使用了 List.removeIf() 方法，这本身就是Java 8引入的函数式风格方法，非常适合原地移除满足特定条件的元素。因此，这部分代码无需修改，它已经符合Java 8的风格。
itemPriceCodes.removeIf(ipc -> DELETED.equals(ipc.getRecordDeleted()));
如果需要创建一个新的列表而不是原地修改，可以使用 filter 和 collect：
// 如果需要返回一个新的列表，而不是修改原列表
List<ItemPriceCode> filteredItemPriceCodes = itemPriceCodes.stream()
.filter(ipc -> !DELETED.equals(ipc.getRecordDeleted()))
.collect(Collectors.toList());
// 然后可能需要 item.setItemPriceCodes(filteredItemPriceCodes);但在本例中，原始方法是修改 item 内部的列表，所以 removeIf 是更直接和高效的选择。
完整的重构方法
将上述两部分结合起来，重构后的 getItemManufacturerPriceCodes 方法如下：
import java.util.List;
import java.util.Optional;
import java.util.stream.Collectors; // 如果使用collect
import static com.example.Constants.NOT_DELETED;
import static com.example.Constants.DELETED;
public class ItemService {
private ManufacturerPriceCodesRepository manufacturerPriceCodesRepository;
public ItemService(ManufacturerPriceCodesRepository manufacturerPriceCodesRepository) {
this.manufacturerPriceCodesRepository = manufacturerPriceCodesRepository;
}
private Item getItemManufacturerPriceCodes(Item item) {
List<ItemPriceCode> itemPriceCodes = item.getItemPriceCodes();
// 步骤1: 更新ItemPriceCode的制造商价格名称
itemPriceCodes.stream()
.forEach(ipc -> {
Optional<ManufacturerPriceCodes> mpc = manufacturerPriceCodesRepository.findByManufacturerIDAndPriceCodeAndRecordDeleted(
item.getManufacturerID(), ipc.getPriceCode(), NOT_DELETED);
mpc.ifPresent(m -> ipc.setManufacturerPriceCode(m.getName()));
});
// 步骤2: 过滤已删除的ItemPriceCode
itemPriceCodes.removeIf(ipc -> DELETED.equals(ipc.getRecordDeleted()));
return item;
}
}注意事项与最佳实践
- Stream的副作用： 尽管 forEach 允许副作用（修改外部状态或流元素），但在使用Stream API时，通常鼓励无副作用的函数式编程风格。这意味着 map、filter 等中间
