Java 8 Stream API：复杂数据处理案例

原创小咪咪 2024-09-15 09:45 82阅读 0赞

Java 8 Stream API 提供了一种高效且简洁的方式来处理大量数据，包括排序、过滤、组合等。以下是一些复杂数据处理的案例：

1. **用户分组统计**：
   假设我们有一个用户列表，每个用户都有一个国家属性。我们可以使用 Stream API 来按国家对用户进行分组并统计。

```java
List<User> users = ... // 用户列表
Map<String, Integer> userCountsByCountry = users.stream()
    .collect(Collectors.groupingBy(User::getCountry)));

userCountsByCountry.forEach((country, count)) -> {
    System.out.println("Country: " + country + ", Count: " + count);
});
```

2. **数据清洗**：
   在实际应用中，数据往往需要进行预处理才能满足需求。例如，我们可以用 Stream API 来移除列表中的重复项。

```java
List<String> list = ... // 原始列表
list = list.stream().collect(Collectors.uniqueList()));

System.out.println("Cleaned List: " + list);
```

3. **文件读写**：
   使用 Stream API 可以简化文件的读写操作。例如，我们可以遍历一个文件的所有行并处理它们。

```java
import java.io.File;
import java.util.stream.Collectors;

public class FileReadWrite {
    public static void main(String[] args) {
        // 读取文件
        File file = new File("input.txt");
        String content = fileLines(file);

System.out.println("Input Content: " + content);

// 处理内容并写入新文件
        List<String> processedContent = content.stream()
                .map(line -> processLine(line))) // 过滤并处理行
                .collect(Collectors.toList()));

File outputFile = new File("output.txt");
        try (java.io.Writer writer = java.util.stream.StreamSupport.getWriter(outputFile))) {
            writer.write(processedContent.stream().collect(Collectors.joining("\n")))));
        }

System.out.println("Output Content: " + processedContent));
    }

private static String fileLines(File file) throws Exception {
        StringBuilder contentBuilder = new StringBuilder();
        try (java.io.BufferedReader reader = java.io.BufferedReader.newBufferedReader(file));) {
            String line;
            while ((line = reader.readLine()) != null)) {
                contentBuilder.append(line).append("\n");
            }
        }
        return contentBuilder.toString();
    }

private static List<String> processLine(String line) {
        // 这里只是一个示例，实际的处理逻辑会根据需求来编写
        return line.replace("old", "new")).toUpperCase();
    }
}
```

这些案例展示了 Java 8 Stream API 在复杂数据处理中的灵活性和效率。