本教程详细阐述了如何利用java 8 stream api将一个嵌套的`map
在现代Java应用开发中，数据转换是一个普遍需求，尤其是在处理来自不同源或需要适配特定API响应格式时。将复杂、嵌套的数据结构转换为更简洁、扁平的数据传输对象（DTO）列表，是优化数据处理流程和提高代码可读性的关键一环。本文将聚焦于一个具体的场景：如何使用Java 8的Stream API，将一个Map
核心数据模型定义
为了更好地理解转换过程，我们首先定义涉及到的数据模型。
Value 枚举
表示人员标签的枚举类型，例如 VALUE1, VALUE2, VALUE3。
public enum Value {
VALUE1, VALUE2, VALUE3
}Person 实体类
这是原始数据结构中的核心实体，包含ID、标签（枚举）、一个异构的result字段（可以是整数、字符串或日期）、事件日期和消息。
立即学习“Java免费学习笔记（深入）”；
import java.time.LocalDate;
public class Person {
private String id;
private Value value; // 对应问题中的 'Tag'
private Object result; // 对应问题中的 'Value'，可为Int, String, Date
private LocalDate date; // 事件日期
private String message;
public Person(String id, Value value, Object result, LocalDate date, String message) {
this.id = id;
this.value = value;
this.result = result;
this.date = date;
this.message = message;
}
// Getters
public String getId() { return id; }
public Value getValue() { return value; }
public Object getResult() { return result; }
public LocalDate getDate() { return date; }
public String getMessage() { return message; }
@Override
public String toString() {
return "Person{" +
"id='" + id + '\'' +
", value=" + value +
", result=" + result +
", date=" + date +
", message='" + message + '\'' +
'}';
}
}PersonDto 数据传输对象
这是我们希望最终得到的目标对象，它扁平化了Person的部分字段，并对日期进行了格式化。
public class PersonDto {
private Value value; // 对应 Person 的 value (Tag)
private String id;
private String date; // 格式化后的日期字符串
private Object result; // 对应 Person 的 result (异构 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 +
'}';
}
}使用Java Stream API进行数据转换
现在，我们将展示如何使用Java Stream API来执行从Map
初始化数据
首先，我们准备一些示例数据，模拟原始的Map
import java.time.LocalDate;
import java.time.format.DateTimeFormatter;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;
public class DataTransformer {
static DateTimeFormatter formatter = DateTimeFormatter.ofPattern("dd-MM-yyyy");
public static void main(String[] args) {
Map> persons = new HashMap<>();
// 示例数据
persons.put("p1", Arrays.asList(
new Person("p1", Value.VALUE1, 10, LocalDate.of(2000, 10, 10), "Message1"),
new Person("p1", Value.VALUE2, "Text", LocalDate.of(2000, 10, 10), "Message2"),
new Person("p1", Value.VALUE3, LocalDate.of(2000, 11, 11), LocalDate.of(2000, 10, 10), "Message3")
));
persons.put("p2", Arrays.asList(
new Person("p2", Value.VALUE1, 20, LocalDate.of(2000, 10, 10), "Message4"),
new Person("p2", Value.VALUE2, "Text", LocalDate.of(2000, 10, 10), "Message5"),
new Person("p2", Value.VALUE3, LocalDate.of(2000, 11, 12), LocalDate.of(2000, 10, 10), "Message6")
));
// ... 转换逻辑将在这里实现
}
} 转换流程解析
转换的核心在于利用Stream API的链式操作：
persons.values().stream(): 首先，从Map
>中获取所有的值，这些值是List 对象。然后，将这些List 集合转换为一个Stream - >。
.flatMap(List::stream): flatMap操作是这里的关键。由于我们有一个Stream，其中每个元素本身又是一个List
，我们需要将这些内部的List扁平化，生成一个单一的Stream 。List::stream是一个方法引用，它将每个List 转换为一个Stream ，然后flatMap将这些独立的Stream合并成一个。 -
.map(person -> new PersonDto(...)): 现在我们有了一个Stream
，可以对每个Person对象进行转换。map操作将每个Person实例映射到一个新的PersonDto实例。在这个过程中，我们执行以下操作： - person.getValue(): 获取Person的枚举Value，直接映射到PersonDto的value字段。
- person.getId(): 获取Person的ID，直接映射到PersonDto的id字段。
- formatter.format(person.getDate()): 获取Person的LocalDate日期，并使用预定义的DateTimeFormatter将其格式化为字符串，映射到PersonDto的date字段。
- person.getResult(): 获取Person的异构Object类型结果，直接映射到PersonDto的result字段。
.collect(Collectors.toList()): 最后，将转换后的PersonDto流收集到一个List
中。
完整的转换代码示例
将上述步骤整合到main方法中：
import java.time.LocalDate;
import java.time.format.DateTimeFormatter;
import java.util.Arrays;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;
public class DataTransformer {
static DateTimeFormatter formatter = DateTimeFormatter.ofPattern("dd-MM-yyyy");
public static void main(String[] args) {
Map> persons = new HashMap<>();
// 示例数据
persons.put("p1", Arrays.asList(
new Person("p1", Value.VALUE1, 10, LocalDate.of(2000, 10, 10), "Message1"),
new Person("p1", Value.VALUE2, "Text", LocalDate.of(2000, 10, 10), "Message2"),
new Person("p1", Value.VALUE3, LocalDate.of(2000, 11, 11), LocalDate.of(2000, 10, 10), "Message3")
));
persons.put("p2", Arrays.asList(
new Person("p2", Value.VALUE1, 20, LocalDate.of(2000, 10, 10), "Message4"),
new Person("p2", Value.VALUE2, "Text", LocalDate.of(2000, 10, 10), "Message5"),
new Person("p2", Value.VALUE3, LocalDate.of(2000, 11, 12), LocalDate.of(2000, 10, 10), "Message6")
));
// 使用Stream API进行转换
List resultDtos = persons.values().stream()
.flatMap(List::stream) // 扁平化 Stream> 为 Stream
.map(person -> new PersonDto(
person.getValue(),
person.getId(),
formatter.format(person.getDate()), // 格式化日期
person.getResult() // 异构Object字段
))
.collect(Collectors.toList()); // 收集为 List
// 打印结果
resultDtos.forEach(System.out::println);
}
} 运行上述代码，将得到以下输出（顺序可能因HashMap而异，但内容一致）：
PersonDto{value=VALUE1, id='p1', date='10-10-2000', result=10}
PersonDto{value=VALUE2, id='p1 
