Java Stream API实现复杂Map数据到扁平DTO列表的转换-java教程-PHP中文网

Java Stream API实现复杂Map数据到扁平DTO列表的转换

碧海醫心

发布： 2025-10-13 09:15:37

原创

826人浏览过

java stream api实现复杂map数据到扁平dto列表的转换

本文深入探讨如何利用Java 8 Stream API，将包含复杂嵌套结构的`Map>`数据转换为扁平化的`List`。教程将详细讲解`flatMap`、`map`等核心操作，并演示如何处理数据类型转换（如日期格式化）和动态类型字段（`Object`），以构建结构清晰、易于消费的数据模型。

在现代软件开发中，数据转换是常见的任务之一。我们经常需要将从数据库、API或文件系统获取的原始数据结构，转换为更适合业务逻辑处理或前端展示的数据传输对象（DTO）。Java 8引入的Stream API为这种集合数据的转换提供了强大而富有表达力的工具。本教程将引导您完成一个具体的场景：将一个嵌套的Map<String, List<Person>>结构扁平化并映射为List<PersonDto>，同时处理日期格式化和动态类型字段。

数据模型定义

为了清晰地演示转换过程，我们首先定义原始数据模型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<String, List<Person>>转换为List<PersonDto>。

序列猴子开放平台

具有长序列、多模态、单模型、大数据等特点的超大规模语言模型

查看详情

1. 准备示例数据

首先，我们创建一些示例Person对象，并将它们组织成Map<String, List<Person>>的结构。

public class StreamTransformation {

    public static void main(String[] args) {
        Map<String, List<Person>> 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<String, List<Person>>):");
        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<Person>的集合视图。
- .stream()：将这个集合转换为一个Stream<List<Person>>。此时，Stream中的每个元素都是一个List<Person>。
.flatMap(List::stream):
- flatMap操作用于将一个Stream中的每个元素（这里是List<Person>）转换为另一个Stream（这里是Person对象的Stream），然后将所有这些生成的Stream扁平化为一个单一的Stream。
- List::stream是一个方法引用，它将每个List<Person>转换为一个Stream<Person>。
- 经过flatMap后，我们得到了一个Stream<Person>，其中包含了所有Person对象，无论它们最初属于哪个内部列表。
.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<PersonDto>中。

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<String, List<Person>> 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

登录后复制

以上就是Java Stream API实现复杂Map数据到扁平DTO列表的转换的详细内容，更多请关注php中文网其它相关文章！