本教程详细阐述了如何利用java 8 stream api将一个嵌套的`map
在现代Java应用开发中，数据转换是一个普遍需求，尤其是在处理来自不同源或需要适配特定API响应格式时。将复杂、嵌套的数据结构转换为更简洁、扁平的数据传输对象（DTO）列表，是优化数据处理流程和提高代码可读性的关键一环。本文将聚焦于一个具体的场景：如何使用Java 8的Stream API，将一个Map<String, List<Person>>结构的数据，转换为一个List<PersonDto>，并在此过程中处理异构类型字段和日期格式化。
为了更好地理解转换过程，我们首先定义涉及到的数据模型。
表示人员标签的枚举类型，例如 VALUE1, VALUE2, VALUE3。
public enum Value {
VALUE1, VALUE2, VALUE3
}这是原始数据结构中的核心实体，包含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 + '\'' +
'}';
}
}这是我们希望最终得到的目标对象，它扁平化了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来执行从Map<String, List<Person>>到List<PersonDto>的转换。
首先，我们准备一些示例数据，模拟原始的Map<String, List<Person>>结构。
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<String, List<Person>> 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<String, List<Person>>中获取所有的值，这些值是List<Person>对象。然后，将这些List<Person>集合转换为一个Stream<List<Person>>。
.flatMap(List::stream): flatMap操作是这里的关键。由于我们有一个Stream，其中每个元素本身又是一个List<Person>，我们需要将这些内部的List扁平化，生成一个单一的Stream<Person>。List::stream是一个方法引用，它将每个List<Person>转换为一个Stream<Person>，然后flatMap将这些独立的Stream合并成一个。
.map(person -> new PersonDto(...)): 现在我们有了一个Stream<Person>，可以对每个Person对象进行转换。map操作将每个Person实例映射到一个新的PersonDto实例。在这个过程中，我们执行以下操作：
.collect(Collectors.toList()): 最后，将转换后的PersonDto流收集到一个List<PersonDto>中。
将上述步骤整合到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<String, List<Person>> 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<PersonDto> resultDtos = persons.values().stream()
.flatMap(List::stream) // 扁平化 Stream<List<Person>> 为 Stream<Person>
.map(person -> new PersonDto(
person.getValue(),
person.getId(),
formatter.format(person.getDate()), // 格式化日期
person.getResult() // 异构Object字段
))
.collect(Collectors.toList()); // 收集为 List<PersonDto>
// 打印结果
resultDtos.forEach(System.out::println);
}
}运行上述代码，将得到以下输出（顺序可能因HashMap而异，但内容一致）：
PersonDto{value=VALUE1, id='p1', date='10-10-2000', result=10}
PersonDto{value=VALUE2, id='p1以上就是使用Java Stream API将复杂Map结构转换为扁平DTO列表的教程的详细内容，更多请关注php中文网其它相关文章！
每个人都需要一台速度更快、更稳定的 PC。随着时间的推移，垃圾文件、旧注册表数据和不必要的后台进程会占用资源并降低性能。幸运的是，许多工具可以让 Windows 保持平稳运行。
Copyright 2014-2025 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号
272
收藏
