news 2026/6/23 15:16:25

275. Java Stream API - flatMap 操作:展开一对多的关系,拉平你的流!

作者头像

张小明

前端开发工程师

1.2k 24
文章封面图
275. Java Stream API - flatMap 操作:展开一对多的关系,拉平你的流!

文章目录

  • 275. Java Stream API - flatMap 操作:展开一对多的关系,拉平你的流!
      • 🧠 背景:我们为什么需要 `flatMap`?
    • 🔁 用 `flatMap` 优雅替代嵌套循环
      • ✅ 定义模型结构
      • ✅ 初始化数据
      • 🚀 使用 `flatMap` 重写统计逻辑
    • 🔍 `flatMap` 是如何工作的?
      • 步骤 1️⃣:映射(map)
      • 步骤 2️⃣:展平(flat)
    • 📚 延伸案例:`Map` 结构的 `flatMap`
    • 🧠 小结:`flatMap` 用法口诀
    • 🧪 练习建议(课堂可选)
      • ❓ 问题:下面代码的输出是什么?

275. Java Stream API - flatMap 操作:展开一对多的关系,拉平你的流!


🧠 背景:我们为什么需要flatMap

假设我们有以下结构:

  • 每个Country拥有多个City
  • 每个City有一个人口数population

我们的目标是:统计所有城市的总人口数

最直接的写法当然是嵌套 for 循环

inttotalPopulation=0;for(Countrycountry:countries){for(Citycity:country.cities()){totalPopulation+=city.population();}}System.out.println("Total population = "+totalPopulation);

📌 输出:

Totalpopulation=24493

虽然有效,但Java 8之后我们有了更优雅的方式:使用流 +flatMap来处理一对多的关系


🔁 用flatMap优雅替代嵌套循环

✅ 定义模型结构

recordCity(Stringname,intpopulation){}recordCountry(Stringname,List<City>cities){}

✅ 初始化数据

CitynewYork=newCity("New York",8_258);CitylosAngeles=newCity("Los Angeles",3_821);Countryusa=newCountry("USA",List.of(newYork,losAngeles));Citylondon=newCity("London",8_866);Citymanchester=newCity("Manchester",568);Countryuk=newCountry("United Kingdom",List.of(london,manchester));Cityparis=newCity("Paris",2_103);Citymarseille=newCity("Marseille",877);Countryfrance=newCountry("France",List.of(paris,marseille));List<Country>countries=List.of(usa,uk,france);

🚀 使用flatMap重写统计逻辑

inttotalPopulation=countries.stream().flatMap(country->country.cities().stream())// 展开所有城市.mapToInt(City::population)// 提取人口.sum();// 累加总人口System.out.println("Total population = "+totalPopulation);

📌 输出:

Totalpopulation=24493

🔍flatMap是如何工作的?

flatMap是两个操作的组合:

步骤 1️⃣:映射(map)

country->country.cities().stream()

这一步将每个Country映射为它的城市流,得到的是一个Stream<Stream<City>>(流的流)。


步骤 2️⃣:展平(flat)

flatMap自动帮你把多个子流合并为一个连续的扁平流Stream<City>),这样你就可以对所有城市统一处理!

🎯 类比图示:

Stream<Country>---映射--->Stream<Stream<City>>|+--->展平(flatten)--->Stream<City>

📚 延伸案例:Map结构的flatMap

假设我们有一个Continent类型,它包含一个 Map:

recordContinent(Map<String,Country>countries){}

此时,如果你想从Continent中提取所有国家,可以这样写:

Function<Continent,Stream<Country>>continentToCountry=continent->continent.countries().values().stream();

再进一步,还可以这样嵌套flatMap

inttotal=continents.stream().flatMap(continent->continent.countries().values().stream()).flatMap(country->country.cities().stream()).mapToInt(City::population).sum();

🧠 小结:flatMap用法口诀

用法场景对应方法
一对一映射(每个元素 → 单个新值).map()
一对多映射(每个元素 → 多个新值).flatMap()
提取嵌套集合中的内容并扁平化.flatMap()
转换成基础类型流(int/long/double.mapToInt()

🧪 练习建议(课堂可选)

❓ 问题:下面代码的输出是什么?

List<String>words=List.of("java","stream","api");List<Character>chars=words.stream().flatMap(word->word.chars().mapToObj(c->(char)c)).toList();System.out.println(chars);

🎯 答案:

[j,a,v,a,s,t,r,e,a,m,a,p,i]
版权声明: 本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若内容造成侵权/违法违规/事实不符,请联系邮箱:809451989@qq.com进行投诉反馈,一经查实,立即删除!
网站建设 2026/6/23 2:29:59

【Open-AutoGLM部署极简指南】:3步完成企业级AI模型自动化部署

第一章&#xff1a;Open-AutoGLM部署的核心价值Open-AutoGLM 作为新一代开源自动化生成语言模型框架&#xff0c;其部署不仅提升了企业级 AI 应用的响应效率&#xff0c;还显著降低了大模型落地的技术门槛。通过模块化设计与轻量化接口&#xff0c;开发者能够快速集成自然语言理…

作者头像 李华
网站建设 2026/6/23 19:36:37

如何精准评估Open-AutoGLM表现?必须关注的3类动态性能指标

第一章&#xff1a;Open-AutoGLM 性能测试指标细化在对 Open-AutoGLM 模型进行性能评估时&#xff0c;需从多个维度定义可量化的测试指标&#xff0c;以确保评测结果具备科学性与可复现性。这些指标不仅反映模型的基础推理能力&#xff0c;还涵盖资源消耗、响应效率和稳定性等工…

作者头像 李华
网站建设 2026/6/23 7:17:26

高级特性 PK:延迟队列、死信队列,三大 MQ 各自怎么实现?

在消息中间件&#xff08;MQ&#xff09;的实际应用中&#xff0c;基础的“发送-接收”消息功能早已无法满足复杂业务场景的需求。延迟队列&#xff08;Delay Queue&#xff09;和死信队列&#xff08;Dead-Letter Queue&#xff0c;DLQ&#xff09;作为两大核心高级特性&#…

作者头像 李华
网站建设 2026/6/23 19:34:20

【故障响应提速300%】:Open-AutoGLM驱动的自动化错误归因体系构建

第一章&#xff1a;故障响应提速300%的行业挑战与破局路径在现代IT运维体系中&#xff0c;系统复杂度呈指数级增长&#xff0c;微服务架构、云原生环境和分布式部署使得故障定位与响应面临前所未有的挑战。传统依赖人工排查与经验驱动的响应机制已难以满足高可用性业务需求&…

作者头像 李华
网站建设 2026/6/23 19:35:35

吞吐量与延迟实测:Kafka/RocketMQ/RabbitMQ 性能差异到底有多大?

在分布式系统架构中&#xff0c;消息队列是实现异步通信、流量削峰、系统解耦的核心组件。而 Kafka、RocketMQ、RabbitMQ 作为当前主流的三款消息队列&#xff0c;其性能表现&#xff08;尤其是吞吐量与延迟&#xff09;直接决定了系统的承载能力和响应速度。 很多开发者在选型…

作者头像 李华