登录
首页 >  文章 >  java教程

JavaStreamMap转DTO列表教程

时间:2025-10-15 13:09:33 347浏览 收藏

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

使用Java Stream API将复杂Map结构转换为扁平DTO列表的教程

本教程详细阐述了如何利用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学习网公众号,给大家分享更多文章知识!

相关阅读
更多>
最新阅读
更多>
课程推荐
更多>