本文深入探讨如何利用Java 8 Stream API，将包含复杂嵌套结构的`Map
在现代软件开发中，数据转换是常见的任务之一。我们经常需要将从数据库、API或文件系统获取的原始数据结构，转换为更适合业务逻辑处理或前端展示的数据传输对象（DTO）。Java 8引入的Stream API为这种集合数据的转换提供了强大而富有表达力的工具。本教程将引导您完成一个具体的场景：将一个嵌套的Map
数据模型定义
为了清晰地演示转换过程，我们首先定义原始数据模型Person和目标数据模型PersonDto，以及一个辅助枚举Value。
1. Value 枚举
Value枚举用于表示Person对象中的特定标签或分类。
立即学习“Java免费学习笔记（深入）”；
import java.time.LocalDate;
import java.time.format.DateTimeFormatter;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Objects;
import java.util.stream.Collectors;
public enum Value {
VALUE1,
VALUE2,
VALUE3
}2. 原始数据结构：Person类
Person类代表我们的原始数据记录，它包含一个动态类型的value字段（可以是整数、字符串或日期）以及一个LocalDate类型的日期字段。
public class Person {
private String id;
private Value tag; // 使用Value枚举表示标签
private Object value; // 动态类型，可以是Integer, String, LocalDate
private LocalDate date; // 存储为LocalDate
private String message;
public Person(String id, Value tag, Object value, LocalDate date, String message) {
this.id = id;
this.tag = tag;
this.value = value;
this.date = date;
this.message = message;
}
// Getters
public String getId() { return id; }
public Value getTag() { return tag; }
public Object getValue() { return value; }
public LocalDate getDate() { return date; }
public String getMessage() { return message; }
@Override
public String toString() {
return "Person{" +
"id='" + id + '\'' +
", tag=" + tag +
", value=" + value +
", date=" + date +
", message='" + message + '\'' +
'}';
}
}3. 目标数据结构：PersonDto类
PersonDto是我们的目标数据传输对象。它将Person中的tag字段映射到自己的value字段（枚举类型），将Person中的动态value字段映射到自己的result字段（Object类型），并将LocalDate格式化为String。
public class PersonDto {
private Value value; // 对应Person的tag
private String id;
private String date; // 格式化后的日期字符串
private Object result; // 对应Person的动态value
public PersonDto(Value value, String id, String date, Object result) {
this.value = value;
this.id = id;
this.date = date;
this.result = result;
}
// Getters
public Value getValue() { return value; }
public String getId() { return id; }
public String getDate() { return date; }
public Object getResult() { return result; }
@Override
public String toString() {
return "PersonDto{" +
"value=" + value +
", id='" + id + '\'' +
", date='" + date + '\'' +
", result=" + result +
'}';
}
}4. 日期格式化工具
DateTimeFormatter用于将LocalDate对象格式化为指定的字符串。
public class DateUtil {
public static final DateTimeFormatter FORMATTER = DateTimeFormatter.ofPattern("dd-MM-yyyy");
}核心转换逻辑：使用Java Stream API
现在，我们来演示如何利用Java Stream API将Map
1. 准备示例数据
首先，我们创建一些示例Person对象，并将它们组织成Map
public class StreamTransformation {
public static void main(String[] args) {
Map> personsData = new HashMap<>();
LocalDate date2000_10_10 = LocalDate.of(2000, 10, 10);
LocalDate date2000_11_11 = LocalDate.of(2000, 11, 11);
LocalDate date2000_12_11 = LocalDate.of(2000, 12, 11);
// Person for p1
personsData.computeIfAbsent("p1", k -> new ArrayList<>()).add(
new Person("p1", Value.VALUE1, 10, date2000_10_10, "Message p1_v1"));
personsData.computeIfAbsent("p1", k -> new ArrayList<>()).add(
new Person("p1", Value.VALUE2, "Text", date2000_10_10, "Message p1_v2"));
personsData.computeIfAbsent("p1", k -> new ArrayList<>()).add(
new Person("p1", Value.VALUE3, date2000_11_11, date2000_10_10, "Message p1_v3"));
// Person for p2
personsData.computeIfAbsent("p2", k -> new ArrayList<>()).add(
new Person("p2", Value.VALUE1, 20, date2000_10_10, "Message p2_v1"));
personsData.computeIfAbsent("p2", k -> new ArrayList<>()).add(
new Person("p2", Value.VALUE2, "Text", date2000_10_10, "Message p2_v2"));
personsData.computeIfAbsent("p2", k -> new ArrayList<>()).add(
new Person("p2", Value.VALUE3, date2000_12_11, date2000_10_10, "Message p2_v3"));
System.out.println("原始数据 (Map>):");
personsData.forEach((key, value) -> {
System.out.println("ID: " + key);
value.forEach(System.out::println);
});
// ... Stream 转换代码将在此处添加
}
} 2. Stream操作步骤详解
转换的核心在于链式调用Stream API的几个关键方法：
-
personsData.values().stream():
- personsData.values()：获取Map中所有List
的集合视图。 - .stream()：将这个集合转换为一个Stream
- >。此时，Stream中的每个元素都是一个List
。
- personsData.values()：获取Map中所有List
-
.flatMap(List::stream):
- flatMap操作用于将一个Stream中的每个元素（这里是List
）转换为另一个Stream（这里是Person对象的Stream），然后将所有这些生成的Stream扁平化为一个单一的Stream。 - List::stream是一个方法引用，它将每个List
转换为一个Stream 。 - 经过flatMap后，我们得到了一个Stream
，其中包含了所有Person对象，无论它们最初属于哪个内部列表。
- flatMap操作用于将一个Stream中的每个元素（这里是List
-
.map(person -> new PersonDto(...)):
- map操作用于对Stream中的每个元素执行一对一的转换，生成一个新的Stream。
- 在这里，我们为每个Person对象创建一个新的PersonDto实例。
-
字段映射关系：
- PersonDto的value字段（Value枚举类型）通过person.getTag()获取。
- PersonDto的id字段（String类型）通过person.getId()获取。
- PersonDto的date字段（String类型）通过DateUtil.FORMATTER.format(person.getDate())将LocalDate格式化为字符串。
- PersonDto的result字段（Object类型）通过person.getValue()获取，它保留了原始Person对象中动态value的类型。
-
.collect(Collectors.toList()):
- collect是一个终端操作，它将Stream中的所有元素收集到一个集合中。
- Collectors.toList()是预定义的收集器，它将Stream中的所有PersonDto对象收集到一个List
中。
3. 完整代码示例
将上述步骤整合到main方法中：
import java.time.LocalDate;
import java.time.format.DateTimeFormatter;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Objects;
import java.util.stream.Collectors;
// 假设 Value, Person, PersonDto, DateUtil 类已定义如上
public class StreamTransformation {
public static void main(String[] args) {
Map> personsData = new HashMap<>();
LocalDate date2000_10_10 = LocalDate.of(2000, 10, 10);
LocalDate date2000_11_11 = LocalDate.of(2000, 11, 11);
LocalDate date2000_12_11 = LocalDate.of(2000, 12, 11);
// Person for p1
personsData.computeIfAbsent("p1", k -> new ArrayList<>()).add(
new Person("p1", Value.VALUE1, 10, date2000_10_10, "Message p1_v1"));
personsData.computeIfAbsent("p1", k -> new ArrayList<>()).add(
new Person("p1", Value.VALUE2, "Text", date200 
