JavaStreamMap转DTO列表教程

本篇文章给大家分享《Java Stream扁平化Map转DTO列表教程》，覆盖了文章的常见基础知识，其实一个语言的全部知识点一篇文章是不可能说完的，但希望通过这些问题，让读者对自己的掌握程度有一定的认识(B 数)，从而弥补自己的不足，更好的掌握它。

本教程详细阐述了如何利用Java 8 Stream API将一个嵌套的`Map>`数据结构高效地转换为一个扁平的`List`。文章涵盖了数据模型的定义、Stream操作（如`flatMap`和`map`）的运用，以及如何处理异构类型字段和日期格式化，旨在提供一个清晰、专业的实践指南。

在现代Java应用开发中，数据转换是一个普遍需求，尤其是在处理来自不同源或需要适配特定API响应格式时。将复杂、嵌套的数据结构转换为更简洁、扁平的数据传输对象（DTO）列表，是优化数据处理流程和提高代码可读性的关键一环。本文将聚焦于一个具体的场景：如何使用Java 8的Stream API，将一个Map>结构的数据，转换为一个List，并在此过程中处理异构类型字段和日期格式化。

核心数据模型定义

为了更好地理解转换过程，我们首先定义涉及到的数据模型。

Value 枚举

表示人员标签的枚举类型，例如 VALUE1, VALUE2, VALUE3。

public enum Value {
    VALUE1, VALUE2, VALUE3
}

Person 实体类

这是原始数据结构中的核心实体，包含ID、标签（枚举）、一个异构的result字段（可以是整数、字符串或日期）、事件日期和消息。

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>到List的转换。

初始化数据

首先，我们准备一些示例数据，模拟原始的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<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的链式操作：

1. persons.values().stream(): 首先，从Map>中获取所有的值，这些值是List对象。然后，将这些List集合转换为一个Stream>。

2. .flatMap(List::stream): flatMap操作是这里的关键。由于我们有一个Stream，其中每个元素本身又是一个List，我们需要将这些内部的List扁平化，生成一个单一的Stream。List::stream是一个方法引用，它将每个List转换为一个Stream，然后flatMap将这些独立的Stream合并成一个。

3. .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字段。

4. .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<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

好了，本文到此结束，带大家了解了《JavaStreamMap转DTO列表教程》，希望本文对你有所帮助！关注golang学习网公众号，给大家分享更多文章知识！