深入解析 Java Stream API：从 List 到 Map 的优雅转换！！！

🚀 深入解析 Java Stream API：从 List 到 Map 的优雅转换 🔧

大家好！👋 今天我们来聊聊 Java 8 中一个非常常见的操作：使用 Stream API 将 List 转换为 Map。🎉 具体来说，我们将深入分析以下代码片段：

Map<Integer, InviteCode> inviteCodeMap = inviteCodes.stream().collect(Collectors.toMap(InviteCode::getId, ic -> ic));

这段代码看似简单，但背后涉及了 Stream API、方法引用、Lambda 表达式以及 Collectors.toMap 的强大功能。💡 我们将从代码的背景开始，逐步拆解它的实现原理，探讨使用场景、优势和优化方法，最后通过一个实际案例展示它的应用。为了更直观地理解整个过程，我们还会插入一个 Mermaid 流程图！📊

准备好了吗？让我们开始吧！🚀

📖 背景：为什么需要将 List 转换为 Map？

在 Java 开发中，我们经常需要处理集合数据。例如，在一个邀请码系统中，我们有一个 List<InviteCode>，其中 InviteCode 是一个实体类，包含 id、inviteCode、inviteLevel 和 createdBy 等字段：

public class InviteCode {private Integer id;private String inviteCode;private Integer inviteLevel;private Integer createdBy;// Getters and Setterspublic Integer getId() {return id;}public String getInviteCode() {return inviteCode;}public Integer getInviteLevel() {return inviteLevel;}public Integer getCreatedBy() {return createdBy;}
}

假设我们有一个 List<InviteCode>，包含 adminId = 7 的所有邀请码记录：

idadmin_idcreated_byinvite_codeinvite_level
207NULL******0
217202631131
227207043581
237209828681
247NULL******0
25724******1
26725******2
277269914763

我们的目标是构建一个以 adminId 为根的邀请码层级树。为了高效地查找某个 id 对应的 InviteCode 对象，我们需要将 List<InviteCode> 转换为 Map<Integer, InviteCode>，其中：

  • 键（Key）：InviteCode 的 id（Integer 类型）。
  • 值（Value）：InviteCode 对象本身。

这就是以下代码的作用：

Map<Integer, InviteCode> inviteCodeMap = inviteCodes.stream().collect(Collectors.toMap(InviteCode::getId, ic -> ic));

🌟 代码拆解：一步步理解

让我们逐步拆解这段代码，弄清楚它是如何工作的！

1. inviteCodes.stream()

  • inviteCodes：是一个 List<InviteCode>，包含 adminId = 7 的 8 条记录（id = 20, 21, ..., 27）。
  • stream()：将 List<InviteCode> 转换为一个 Stream<InviteCode>。
    • Stream 是 Java 8 引入的流式 API，允许你以声明式的方式处理集合数据（例如映射、过滤、归约等）。

结果：inviteCodes.stream() 生成了一个 Stream<InviteCode>，包含 8 个 InviteCode 对象。

2. .collect(Collectors.toMap(...))

  • collect：是 Stream 的终止操作，用于将流中的元素收集到一个结果容器中（例如 List、Set 或 Map）。
  • Collectors.toMap：是一个收集器（Collector），专门用于将流中的元素收集到一个 Map 中。
Collectors.toMap 的方法签名
public static <T, K, U> Collector<T, ?, Map<K,U>> toMap(Function<? super T, ? extends K> keyMapper,Function<? super T, ? extends U> valueMapper
)
  • 参数：
    • keyMapper：一个函数，用于从流中的每个元素提取 Map 的键（Key）。
    • valueMapper：一个函数，用于从流中的每个元素提取 Map 的值（Value）。
  • 返回值：一个 Map<K, U>。

在我们的代码中：

  • T 是 InviteCode（流中的元素类型）。
  • K 是 Integer（键的类型）。
  • U 是 InviteCode（值的类型）。

3. InviteCode::getId

  • InviteCode::getId：这是一个方法引用（Method Reference），等价于 Lambda 表达式 ic -> ic.getId()。
  • 作用：从 InviteCode 对象中提取 id 字段，作为 Map 的键。
  • 类型：Function<InviteCode, Integer>，将 InviteCode 映射为 Integer。

示例：

  • 如果 InviteCode 对象的 id 是 20，InviteCode::getId 会返回 20。

4. ic -> ic

  • ic -> ic：这是一个 Lambda 表达式，表示一个简单的映射函数。
  • 作用：将 InviteCode 对象本身作为 Map 的值。
  • 类型：Function<InviteCode, InviteCode>，将 InviteCode 映射为它自己。

示例：

  • 如果 InviteCode 对象是 ic（id = 20），ic -> ic 直接返回这个 ic 对象。

5. 整体效果

  • Collectors.toMap(InviteCode::getId, ic -> ic)：
    • 对 Stream<InviteCode> 中的每个 InviteCode 对象：
      • 使用 InviteCode::getId 提取 id 作为键。
      • 使用 ic -> ic 提取整个 InviteCode 对象作为值。
    • 将所有键值对收集到一个 Map<Integer, InviteCode> 中。

结果：

  • inviteCodeMap 是一个 Map<Integer, InviteCode>，其中：
    • inviteCodeMap.get(20)：InviteCode(id=20, inviteCode="******", ...)。
    • inviteCodeMap.get(21)：InviteCode(id=21, inviteCode="263113", ...)。
    • …
    • inviteCodeMap.get(27)：InviteCode(id=27, inviteCode="991476", ...)。

📊 Mermaid 流程图：可视化转换过程

为了更直观地理解 List<InviteCode> 到 Map<Integer, InviteCode> 的转换过程，我们使用 Mermaid 流程图来展示：
Start: List<InviteCode>
inviteCodes
Stream<InviteCode>
inviteCodes.stream()
For each InviteCode in Stream
Extract Key:
InviteCode::getId
(e.g., id = 20)
Extract Value:
ic -> ic
(e.g., InviteCode object)
Key-Value Pair:
(20, InviteCode(id=20, ...))
Collect to Map<Integer, InviteCode>
Collectors.toMap()
End: Map<Integer, InviteCode>
inviteCodeMap
  • 流程说明：
    1. 从 List<InviteCode> 开始，转换为 Stream<InviteCode>。
    2. 对流中的每个 InviteCode 对象：
      • 使用 InviteCode::getId 提取键（id）。
      • 使用 ic -> ic 提取值（InviteCode 对象）。
    3. 将所有键值对收集到 Map<Integer, InviteCode> 中。

🌟 为什么需要 inviteCodeMap？

在邀请码系统中，我们的目标是构建一个以 adminId 为根的层级树。为了高效地查找某个 id 对应的 InviteCode 对象，我们需要将 List<InviteCode> 转换为 Map<Integer, InviteCode>。

1. 后续代码

// 找到所有根节点（createdBy = NULL）
List<InviteCode> roots = inviteCodes.stream().filter(ic -> ic.getCreatedBy() == null).collect(Collectors.toList());// 为每个根节点构建树形结构
List<InviteCodeTreeDTO> trees = new ArrayList<>();
for (InviteCode root : roots) {InviteCodeTreeDTO tree = buildTree(root, inviteCodeMap, new HashSet<>());trees.add(tree);
}

在 buildTree 方法中，需要根据 createdBy 查找子节点：

private InviteCodeTreeDTO buildTree(InviteCode root, Map<Integer, InviteCode> inviteCodeMap, Set<Integer> visited) {if (!visited.add(root.getId())) {throw new IllegalStateException("Detected a cycle in invite code hierarchy at ID: " + root.getId());}InviteCodeTreeDTO node = new InviteCodeTreeDTO();node.setId(root.getId());node.setInviteCode(root.getInviteCode());node.setInviteLevel(root.getInviteLevel());node.setChildren(new ArrayList<>());// 查找所有子节点（createdBy = root.id）List<InviteCode> children = inviteCodeMap.values().stream().filter(ic -> Objects.equals(ic.getCreatedBy(), root.getId())).collect(Collectors.toList());for (InviteCode child : children) {InviteCodeTreeDTO childNode = buildTree(child, inviteCodeMap, new HashSet<>(visited));node.getChildren().add(childNode);}return node;
}
  • 为什么用 Map？
    • 如果直接遍历 inviteCodes 查找子节点（createdBy = root.id），时间复杂度是 O(n)。
    • 使用 inviteCodeMap，可以通过 id 直接查找 InviteCode 对象，时间复杂度是 O(1)（尽管当前 children 查找仍需优化）。

🚀 优势：为什么使用 Stream API？

1. 代码简洁

  • Stream API 提供了声明式的写法，比传统的 for 循环更简洁。
  • 传统写法可能需要手动遍历和填充 Map：
    Map<Integer, InviteCode> inviteCodeMap = new HashMap<>();
for (InviteCode ic : inviteCodes) {inviteCodeMap.put(ic.getId(), ic);
}
  • 使用 Stream API，代码更简洁优雅。

2. 功能强大

  • Stream API 支持链式操作，可以轻松添加过滤、映射等操作。
  • 例如，如果只想收集 inviteLevel > 0 的 InviteCode：
    Map<Integer, InviteCode> inviteCodeMap = inviteCodes.stream().filter(ic -> ic.getInviteLevel() > 0).collect(Collectors.toMap(InviteCode::getId, ic -> ic));

3. 并行处理

  • Stream API 支持并行处理（parallelStream()），在大规模数据下可以提高性能：
    Map<Integer, InviteCode> inviteCodeMap = inviteCodes.parallelStream().collect(Collectors.toMap(InviteCode::getId, ic -> ic));

🛠️ 优化建议

1. 更高效的子节点查找

当前 buildTree 方法中，查找子节点的方式可以通过 inviteCodeMap 进一步优化：

// 预先构建 createdBy 到子节点的映射
Map<Integer, List<InviteCode>> childrenMap = inviteCodes.stream().filter(ic -> ic.getCreatedBy() != null).collect(Collectors.groupingBy(InviteCode::getCreatedBy));// 修改 buildTree 方法
private InviteCodeTreeDTO buildTree(InviteCode root, Map<Integer, InviteCode> inviteCodeMap, Map<Integer, List<InviteCode>> childrenMap, Set<Integer> visited) {if (!visited.add(root.getId())) {throw new IllegalStateException("Detected a cycle in invite code hierarchy at ID: " + root.getId());}InviteCodeTreeDTO node = new InviteCodeTreeDTO();node.setId(root.getId());node.setInviteCode(root.getInviteCode());node.setInviteLevel(root.getInviteLevel());node.setChildren(new ArrayList<>());// 查找所有子节点（createdBy = root.id）List<InviteCode> children = childrenMap.getOrDefault(root.getId(), Collections.emptyList());for (InviteCode child : children) {InviteCodeTreeDTO childNode = buildTree(child, inviteCodeMap, childrenMap, new HashSet<>(visited));node.getChildren().add(childNode);}return node;
}
  • 效果：通过 childrenMap，可以以 O(1) 的时间复杂度找到某个 id 的所有子节点。

2. 处理键冲突

Collectors.toMap 默认情况下，如果有重复的键（id），会抛出 IllegalStateException: Duplicate key。在我们的场景中，id 是主键，应该不会有重复，但为了安全起见，可以指定合并策略：

Map<Integer, InviteCode> inviteCodeMap = inviteCodes.stream().collect(Collectors.toMap(InviteCode::getId,ic -> ic,(existing, replacement) -> existing // 如果有重复的 id，保留第一个));
  • 效果：如果 id 重复，保留第一个 InviteCode 对象。

📝 完整代码：实际应用

以下是完整的 InviteCodeService 实现，展示了如何使用 inviteCodeMap 构建层级树：

public class InviteCodeService {private final InviteCodeRepository inviteCodeRepository;public InviteCodeService(InviteCodeRepository inviteCodeRepository) {this.inviteCodeRepository = inviteCodeRepository;}public AdminInviteCodeTreeDTO getAdminInviteCodeTree(Integer adminId) {List<InviteCode> inviteCodes = inviteCodeRepository.findByAdminId(adminId);if (inviteCodes.isEmpty()) {AdminInviteCodeTreeDTO result = new AdminInviteCodeTreeDTO();result.setAdminId(adminId);result.setChildren(Collections.emptyList());return result;}// 将 List<InviteCode> 转换为 Map<Integer, InviteCode>Map<Integer, InviteCode> inviteCodeMap = inviteCodes.stream().collect(Collectors.toMap(InviteCode::getId, ic -> ic));// 预构建 createdBy 到子节点的映射Map<Integer, List<InviteCode>> childrenMap = inviteCodes.stream().filter(ic -> ic.getCreatedBy() != null).collect(Collectors.groupingBy(InviteCode::getCreatedBy));// 找到所有根节点（createdBy = NULL）List<InviteCode> roots = inviteCodes.stream().filter(ic -> ic.getCreatedBy() == null).collect(Collectors.toList());// 为每个根节点构建树形结构List<InviteCodeTreeDTO> trees = new ArrayList<>();for (InviteCode root : roots) {InviteCodeTreeDTO tree = buildTree(root, inviteCodeMap, childrenMap, new HashSet<>());trees.add(tree);}AdminInviteCodeTreeDTO result = new AdminInviteCodeTreeDTO();result.setAdminId(adminId);result.setChildren(trees);return result;}private InviteCodeTreeDTO buildTree(InviteCode root, Map<Integer, InviteCode> inviteCodeMap, Map<Integer, List<InviteCode>> childrenMap, Set<Integer> visited) {if (!visited.add(root.getId())) {throw new IllegalStateException("Detected a cycle in invite code hierarchy at ID: " + root.getId());}InviteCodeTreeDTO node = new InviteCodeTreeDTO();node.setId(root.getId());node.setInviteCode(root.getInviteCode());node.setInviteLevel(root.getInviteLevel());node.setChildren(new ArrayList<>());List<InviteCode> children = childrenMap.getOrDefault(root.getId(), Collections.emptyList());for (InviteCode child : children) {InviteCodeTreeDTO childNode = buildTree(child, inviteCodeMap, childrenMap, new HashSet<>(visited));node.getChildren().add(childNode);}return node;}
}

🎉 总结

通过 Stream API 和 Collectors.toMap，我们可以轻松地将 List<InviteCode> 转换为 Map<Integer, InviteCode>，为后续的层级树构建提供了高效的数据结构。💻

  • 核心代码：inviteCodes.stream().collect(Collectors.toMap(InviteCode::getId, ic -> ic)) 将列表转换为映射。
  • 优势：代码简洁、功能强大、支持并行处理。
  • 优化：通过 childrenMap 提高子节点查找效率，处理键冲突。

希望这篇博客对你理解 Stream API 和 Collectors.toMap 有所帮助！💬 如果你有其他问题，欢迎留言讨论！🚀

📚 参考：Java 官方文档、Collectors 源码。点赞和分享哦！😊

在这里插入图片描述

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/898630.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

配置银河麒麟V10高级服务器操作系统安装vmware tools。在您的计算机上尚未找到用于此虚拟机的 VMwareTools。安装将无法继续。

配置银河麒麟V10高级服务器操作系统安装vmware tools。在您的计算机上尚未找到用于此虚拟机的 VMwareTools。安装将无法继续。

配置银河麒麟V10高级服务器操作系统安装vmware tools 下载VMwareTools安装包 通过网盘分享的文件&#xff1a;VMwareTools-10.3.25-20206839.tar.gz 链接: https://pan.baidu.com/s/1EgMcqbIEur4iyHu2l0v_gQ?pwdrc8m 提取码: rc8m 通过工具上传到指定目录&#xff0c;然后切换…
阅读更多...
突破 HTML 学习瓶颈：表格、列表与表单的学习进度（一）

突破 HTML 学习瓶颈：表格、列表与表单的学习进度（一）

HTML 学习之困&#xff0c;如何破局&#xff1f; 作为一名热衷于网页开发的博主&#xff0c;在 HTML 的学习道路上&#xff0c;我可谓是 “过关斩将”&#xff0c;但也遇到过不少 “硬茬”。起初&#xff0c;当我满心欢喜地以为掌握了基本的 HTML 标签&#xff0c;就能轻松搭建…
阅读更多...
理一理Mysql日期

理一理Mysql日期

在 MySQL 数据库中&#xff0c;关于日期和时间的类型主要有以下几种&#xff1a; 1. **DATE**: 仅存储日期部分&#xff0c;格式为 YYYY-MM-DD&#xff0c;例如 2023-10-31。 2. **TIME**: 仅存储时间部分&#xff0c;格式为 HH:MM:SS&#xff0c;例如 14:30:00。 3. **DATE…
阅读更多...
CEF 多进程模式时，注入函数，获得交互信息

CEF 多进程模式时，注入函数，获得交互信息

CEF 控制台添加一函数，枚举 注册的供前端使用的CPP交互函数有哪些-CSDN博客 上篇文章，是在模拟环境，单进程中设置的，这篇文章，将其改到正常多进程环境中设置。 对应于工程中的 CEF_RENDER项目 一、多进程模式中，改写 修改步骤 1、注入函数 client_app_render.cpp 在…
阅读更多...
C++ 介绍STL底层一些数据结构

C++ 介绍STL底层一些数据结构

c 标准模板库中&#xff0c;set和map的底层实现通常基于红黑树&#xff0c;然们都是平衡二叉搜索树(Balanceed Binary Serach Tree&#xff09;的一种,这种结构保证了 插入&#xff0c;删除&#xff0c;查找的时间复杂度为O(log n)比普通二叉搜索树更高效。 set set<T>…
阅读更多...
在 Kubernetes（k8s）部署过程中常见的问题

在 Kubernetes（k8s）部署过程中常见的问题

在 Kubernetes（k8s）部署过程中，常见的问题主要包括以下几类，以下是具体示例及简要说明： 1. 资源配额不足（Resource Quota） 现象：Pod 处于 Pending 状态，事件日志显示 Insufficient CPU/Memory。 原因： 节点（Node）资源不足，无法满足 Pod 的 requests 或 limits。 命…
阅读更多...
Android Window浮窗UI组件使用JetPack

Android Window浮窗UI组件使用JetPack

目前接手的一个业务&#xff0c;应用不是用Activity/Fragment作为界面组件&#xff0c;而是用Window浮窗的形式显示&#xff0c;并且浮窗有很多种类型&#xff0c;每一种类型对应一类业务。那么怎么使用Jatpack的相关特性来设计架构并提高开发效率呢&#xff1f;分下面几个模块…
阅读更多...
基于WebRtc,GB28181,Rtsp/Rtmp,SIP,JT1078,H265/WEB融合视频会议接入方案

基于WebRtc,GB28181,Rtsp/Rtmp,SIP,JT1078,H265/WEB融合视频会议接入方案

智能融合视频会议系统方案—多协议、多场景、全兼容的一站式视频协作平台 OvMeet,LiveMeet针对用户​核心痛点实现功能与用户价值 &#xff0c;Web平台实现MCU多协议&#xff0c;H265/H264等不同编码监控&#xff0c;直播&#xff0c;会议&#xff0c;调度资源统一融合在一套界…
阅读更多...
深入浅出理解LLM PPO：基于verl框架的实现解析之一

深入浅出理解LLM PPO：基于verl框架的实现解析之一

1. 写在前面 强化学习（Reinforcement Learning，RL）在大型语言模型（Large Language Model，LLM）的训练中扮演着越来越重要的角色。特别是近端策略优化（Proximal Policy Optimization，PPO）算法，已成为对齐LLM与人类偏好的主流方法之一。本文将基于verl框架（很多复刻De…
阅读更多...
卷积神经网络 - 汇聚层

卷积神经网络 - 汇聚层

卷积神经网络一般由卷积层、汇聚层和全连接层构成&#xff0c;本文我们来学习汇聚层。 汇聚层(Pooling Layer)也叫子采样层(Subsampling Layer)&#xff0c;其作用是进 行特征选择&#xff0c;降低特征数量&#xff0c;从而减少参数数量。 卷积层虽然可以显著减少网络中连接的…
阅读更多...
vue使用element-ui自定义样式思路分享【实操】

vue使用element-ui自定义样式思路分享【实操】

前言 在使用第三方组件时&#xff0c;有时候组件提供的默认样式不满足我们的实际需求&#xff0c;需要对默认样式进行调整&#xff0c;这就需要用到样式穿透。本篇文章以vue3使用element-ui的Tabs组件&#xff0c;对Tabs组件的添加按钮样式进行客制化为例。 确定需要修改的组…
阅读更多...
【工具分享】vscode+deepseek的接入与使用

【工具分享】vscode+deepseek的接入与使用

目录 第一章 前言 第二章 获取Deepseek APIKEY 2.1 登录与充值 2.2 创建API key 第三章 vscode接入deepseek并使用 3.1 vscode接入deepseek 3.2 vscode使用deepseek 第一章 前言 deepseek刚出来时有一段时间余额无法充值&#xff0c;导致小编没法给大家发完整的流程&…
阅读更多...
【蓝桥杯速成】| 9.回溯升级

【蓝桥杯速成】| 9.回溯升级

题目一&#xff1a;组合综合 问题描述 39. 组合总和 - 力扣&#xff08;LeetCode&#xff09; 给你一个 无重复元素 的整数数组 candidates 和一个目标整数 target &#xff0c;找出 candidates 中可以使数字和为目标数 target 的 所有 不同组合 &#xff0c;并以列表形式返…
阅读更多...
【C++进阶】深入探索类型转换

【C++进阶】深入探索类型转换

目录 一、C语言中的类型转换 1.1 隐式类型转换 1.2. 显式类型转换 1.3.C语言类型转换的局限性 二、C 类型转换四剑客 2.1 static_cast&#xff1a;静态类型转换&#xff08;编译期检查&#xff09; 2.2 dynamic_cast&#xff1a;动态类型转换&#xff08;运行时检查&…
阅读更多...
代码随想录_动态规划

代码随想录_动态规划

代码随想录 动态规划 509.斐波那契数 509. 斐波那契数 斐波那契数 &#xff08;通常用 F(n) 表示&#xff09;形成的序列称为 斐波那契数列 。该数列由 0 和 1 开始&#xff0c;后面的每一项数字都是前面两项数字的和。也就是&#xff1a; F(0) 0&#xff0c;F(1) 1 F(n…
阅读更多...
计算机基础：编码03，根据十进制数，求其原码

计算机基础：编码03，根据十进制数，求其原码

专栏导航 本节文章分别属于《Win32 学习笔记》和《MFC 学习笔记》两个专栏&#xff0c;故划分为两个专栏导航。读者可以自行选择前往哪个专栏。 &#xff08;一&#xff09;WIn32 专栏导航 上一篇&#xff1a;计算机基础&#xff1a;编码02&#xff0c;有符号数编码&#xf…
阅读更多...
设计模式(创建型)-单例模式

设计模式(创建型)-单例模式

摘要 在软件开发的世界里&#xff0c;设计模式是开发者们智慧的结晶&#xff0c;它们为解决常见问题提供了经过验证的通用方案。单例模式作为一种基础且常用的设计模式&#xff0c;在许多场景中发挥着关键作用。本文将深入探讨单例模式的定义、实现方式、应用场景以及可…
阅读更多...
基于FPGA频率、幅度、相位可调的任意函数发生器（DDS）实现

基于FPGA频率、幅度、相位可调的任意函数发生器（DDS）实现

基于FPGA实现频率、幅度、相位可调的DDS 1 摘要 直接数字合成器（ DDS ） 是一种通过生成数字形式的时变信号并进行数模转换来产生模拟波形（通常为正弦波）的方法，它通过数字方式直接合成信号，而不是通过模拟信号生成技术。DDS主要被应用于信号生成、通信系统中的本振、函…
阅读更多...
本地JAR批量传私服

本地JAR批量传私服

在有网络隔离的环境下&#xff0c;Maven项目如果没有搭建私服就得把用到的通用组件通过U盘在每个组员间拷贝来拷贝去。非常的麻烦跟低效。搭建私服&#xff0c;如果通用组件很多的时候手工一个一个上传更是非常的麻烦跟低效&#xff1b; 我就遇上这问题&#xff0c;跟A公司合作…
阅读更多...
【ROS实战】02-ROS架构介绍

【ROS实战】02-ROS架构介绍

1. 简介 你是否曾有过这样的疑问&#xff1a;我按照文档安装了ROS&#xff0c;依照要求写了一些示例节点&#xff08;node&#xff09;、消息&#xff08;msg&#xff09;和话题&#xff08;topic&#xff09;&#xff0c;但觉得过程既麻烦又繁琐。也许你开始怀疑&#xff1a;…
阅读更多...
最新文章

Copyright @ 2022~2023