使用Java Stream高效过滤嵌套列表数据并提取特定信息

使用Java Stream高效过滤嵌套列表数据并提取特定信息

本教程详细讲解如何利用java stream api高效处理嵌套数据结构。我们将以从产品图片列表中筛选出特定类型(如jpg)的图片url,并将其聚合为逗号分隔字符串为例,演示`filter`、`map`和`reduce`等核心操作的组合应用,旨在提升复杂数据处理的简洁性和可读性。

在现代软件开发中,我们经常需要处理复杂且嵌套的数据结构。例如,一个产品对象可能包含一个图片列表,而每张图片又可能包含多种格式类型。当我们需要从这样的结构中,根据某个深层嵌套的条件(例如,筛选出所有类型为JPG的图片URL)来提取并聚合信息时,传统的循环遍历方式往往会导致代码冗长、可读性差。Java 8引入的Stream API为这类问题提供了优雅且高效的解决方案。

场景描述与数据模型构建

假设我们有如下的产品数据结构,其中包含多个图片,每张图片有其URL和多种格式类型:

 product A :{    name: a    images: [      {           img1: 1           url: url1           type: [             {               format: jpg             }             {               format: png             }          ]      },      {           img2: 1           url: url2           type: [             {               format: mp4             }             {               format: png             }          ]      },      {           img3: 3           url: url3           type: [             {               format: jpg             }             {               format: mp4             }          ]      }    ]}

我们的目标是:从product A的所有images中,找出所有包含jpg格式的图片,并将其url以逗号分隔的形式返回。

为了在Java中表示上述数据,我们可以定义以下POJO(Plain Old Java Object)类:

立即学习“Java免费学习笔记(深入)”;

import java.net.URL;import java.util.List;import java.util.Objects;import java.util.stream.Collectors;import java.util.function.BinaryOperator;import java.util.function.Predicate;import java.util.Arrays;import java.util.Collection;// 产品类(在此示例中简化,只关注图片列表)class Product {    private String name;    private List images;    public Product(String name, List images) {        this.name = name;        this.images = images;    }    public String getName() {        return name;    }    public List getImages() {        return images;    }}// 图片类class Image {    private String id; // img1, img2, etc.    private URL url;    private List types;    public Image(String id, String url, List types) {        this.id = id;        try {            this.url = new URL(url);        } catch (Exception e) {            throw new RuntimeException(e);        }        this.types = types;    }    public String getId() {        return id;    }    public URL getUrl() {        return url;    }    public List getTypes() {        return types;    }}// 图片类型类class ImageType {    public enum Format {        JPG, PNG, MP4, GIF; // 定义支持的格式    }    private Format format;    public ImageType(Format format) {        this.format = format;    }    public Format getFormat() {        return format;    }    @Override    public boolean equals(Object o) {        if (this == o) return true;        if (o == null || getClass() != o.getClass()) return false;        ImageType imageType = (ImageType) o;        return format == imageType.format;    }    @Override    public int hashCode() {        return Objects.hash(format);    }}

使用Java Stream API进行过滤与聚合

Java Stream API提供了一系列链式操作,能够以声明式的方式处理集合数据。解决上述问题的核心步骤包括:过滤、映射和归约。

过滤(Filter): 筛选出符合特定条件的元素。在本例中,我们需要筛选出包含JPG格式的Image对象。映射(Map): 将过滤后的元素转换为我们需要的形式。这里是将Image对象映射为其URL字符串。归约(Reduce): 将所有映射后的结果聚合成一个单一的值。这里是将所有URL字符串用逗号连接起来。

下面是实现这一逻辑的Java Stream代码:

public class ImageProcessor {    // 定义一个BinaryOperator,用于将字符串用逗号连接    static final BinaryOperator reducer = (a, b) -> a + "," + b;    // 定义一个Predicate,用于判断图片是否包含JPG格式    static final Predicate isJpg = (image) -> image.getTypes().stream()                                                            .anyMatch(type -> type.getFormat() == ImageType.Format.JPG);    /**     * 从图片集合中获取所有包含JPG格式的图片URL,并以逗号分隔。     *     * @param images 图片集合     * @return 逗号分隔的JPG图片URL字符串,如果没有匹配项则返回"No Match!"     */    public static String getJpgUrls(final Collection images) {        return images.stream()                     .filter(isJpg) // 步骤1: 过滤出包含JPG格式的图片                     .map(Image::getUrl) // 步骤2: 将Image对象映射为URL对象                     .map(URL::toString) // 步骤2: 将URL对象映射为URL字符串                     .reduce(reducer) // 步骤3: 将所有URL字符串用逗号连接                     .orElse("No Match!"); // 如果没有匹配项,则返回默认值    }    public static void main(String[] args) {        // 构造示例数据        List productAImages = Arrays.asList(            new Image("img1", "http://example.com/url1.jpg", Arrays.asList(new ImageType(ImageType.Format.JPG), new ImageType(ImageType.Format.PNG))),            new Image("img2", "http://example.com/url2.mp4", Arrays.asList(new ImageType(ImageType.Format.MP4), new ImageType(ImageType.Format.PNG))),            new Image("img3", "http://example.com/url3.jpg", Arrays.asList(new ImageType(ImageType.Format.JPG), new ImageType(ImageType.Format.MP4))),            new Image("img4", "http://example.com/url4.gif", Arrays.asList(new ImageType(ImageType.Format.GIF)))        );        Product productA = new Product("Product A", productAImages);        // 调用方法获取JPG图片URL        String jpgUrls = getJpgUrls(productA.getImages());        System.out.println("JPG URLs for Product A: " + jpgUrls); // 预期输出: http://example.com/url1.jpg,http://example.com/url3.jpg        // 测试没有匹配项的情况        List noJpgImages = Arrays.asList(            new Image("img5", "http://example.com/url5.png", Arrays.asList(new ImageType(ImageType.Format.PNG))),            new Image("img6", "http://example.com/url6.mp4", Arrays.asList(new ImageType(ImageType.Format.MP4)))        );        String noMatchUrls = getJpgUrls(noJpgImages);        System.out.println("JPG URLs for No JPG Images: " + noMatchUrls); // 预期输出: No Match!    }}

代码解析

reducer (BinaryOperator):这是一个函数式接口实例,定义了如何将两个字符串合并为一个字符串。在这里,它简单地将两个字符串用逗号连接起来。reduce操作需要一个这样的二元操作符来逐步聚合流中的元素。

isJpg (Predicate):这是一个函数式接口实例,定义了一个条件判断。它接收一个Image对象,然后:

image.getTypes().stream(): 获取当前Image对象的所有ImageType,并将其转换为一个流。.anyMatch(type -> type.getFormat() == ImageType.Format.JPG): 检查这个ImageType流中是否存在任何一个ImageType的format是JPG。如果存在,则返回true,表示该图片包含JPG格式。

getJpgUrls(final Collection images) 方法:

images.stream(): 将输入的Image集合转换为一个流,这是所有Stream操作的起点。.filter(isJpg): 应用isJpg这个Predicate来过滤流中的Image对象。只有那些isJpg返回true的Image对象才能进入下一步。.map(Image::getUrl): 这是一个方法引用,等同于image -> image.getUrl()。它将过滤后的每个Image对象转换为其对应的URL对象。.map(URL::toString): 再次使用map操作,将上一步得到的URL对象转换为其字符串表示。.reduce(reducer): 这是归约操作。它使用reducer(即逗号连接的逻辑)将流中的所有URL字符串合并成一个单一的字符串。reduce操作返回一个Optional,因为流可能为空。.orElse(“No Match!”): 处理Optional的结果。如果reduce操作返回的Optional中包含一个值(即找到了匹配的URL),则返回该值;否则(即流为空,没有找到任何JPG图片),则返回字符串”No Match!”。

注意事项与最佳实践

可读性: 使用Predicate和BinaryOperator等函数式接口的实例,可以提高代码的可读性和模块化。将复杂的逻辑封装在独立的函数式接口中,使主业务逻辑流更加清晰。效率: Stream API在内部进行了优化,可以并行处理(通过parallelStream()),但在小规模数据上,并行流的开销可能大于收益。对于本例的场景,顺序流通常足够高效。空值处理: reduce操作返回Optional,这是一种优雅处理可能为空结果的方式,避免了传统的null检查,增强了代码的健壮性。数据模型设计: 清晰、合理的数据模型是使用Stream API的前提。确保POJO类有适当的getter方法,以便Stream能够访问其属性。不可变性: 在可能的情况下,尽量使用不可变对象,这有助于简化并发编程和提高代码的安全性。本例中的Image和ImageType对象在创建后其内部状态是不可变的。

总结

通过Java Stream API,我们能够以声明式、链式和高度可读的方式处理复杂的嵌套数据过滤和聚合任务。filter、map和reduce是Stream API中最核心的三个操作,它们的组合应用能够解决绝大多数数据处理场景。掌握这些技术,将显著提升您处理集合数据的效率和代码质量。

以上就是使用Java Stream高效过滤嵌套列表数据并提取特定信息的详细内容,更多请关注创想鸟其它相关文章!

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容, 请发送邮件至 chuangxiangniao@163.com 举报,一经查实,本站将立刻删除。
发布者:程序猿,转转请注明出处:https://www.chuangxiangniao.com/p/5058.html

赞 (0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
使用Josson库查找JSON文件中跨对象的重复键值对
上一篇 2025年11月5日 11:54:52
Perplexity AI支持第十维分析 Perplexity AI高维物理工具
下一篇 2025年11月5日 11:55:04

相关推荐

  • 怎么用豆包AI帮我生成React组件 用AI快速构建高质量React组件的秘诀

    怎么用豆包AI帮我生成React组件 用AI快速构建高质量React组件的秘诀怎么用豆包AI帮我生成React组件 用AI快速构建高质量React组件的秘诀怎么用豆包AI帮我生成React组件 用AI快速构建高质量React组件的秘诀怎么用豆包AI帮我生成React组件 用AI快速构建高质量React组件的秘诀

    使用豆包ai生成react组件的关键在于明确需求、利用ai生成基础结构并手动优化。1. 明确需求,提供清晰指令,包括功能、props、状态管理及ui库偏好;2. 让ai生成组件结构和基础逻辑,如表单、列表渲染和简单交互;3. 审查代码质量,检查默认值、性能问题、组件命名和样式冲突,并根据需要进一步优…

    2026年9月26日 • 用户投稿
    200
  • Spring Security中自定义过滤器与JWT认证过滤器的执行顺序控制

    Spring Security中自定义过滤器与JWT认证过滤器的执行顺序控制Spring Security中自定义过滤器与JWT认证过滤器的执行顺序控制Spring Security中自定义过滤器与JWT认证过滤器的执行顺序控制Spring Security中自定义过滤器与JWT认证过滤器的执行顺序控制

    在Spring Security应用中,确保自定义过滤器(如多租户过滤器)在JWT认证/授权过滤器之前正确执行至关重要。本文将深入探讨如何通过@Order注解和SecurityFilterChain配置,精确控制自定义OncePerRequestFilter的执行顺序,使其优先于Spring Sec…

    2026年9月26日 • 用户投稿
    100
  • 如何优化debian readdir的性能

    如何优化debian readdir的性能如何优化debian readdir的性能如何优化debian readdir的性能如何优化debian readdir的性能

    在Debian系统中,readdir系统调用用于读取目录内容。如果其性能表现不佳,可尝试以下优化策略: 精简目录文件数量: 尽可能将大型目录拆分成多个小型目录,降低每次readdir调用处理的项目数量。 启用目录内容缓存: 构建缓存机制,定期或在目录内容变更时更新缓存,减少对readdir的频繁调用…

    2026年9月26日 • 用户投稿
    200
  • 抖音账号如何提升权重_抖音账号提升权重的关键步骤

    抖音账号如何提升权重_抖音账号提升权重的关键步骤抖音账号如何提升权重_抖音账号提升权重的关键步骤抖音账号如何提升权重_抖音账号提升权重的关键步骤抖音账号如何提升权重_抖音账号提升权重的关键步骤

    账号权重低影响抖音推荐,需通过强化垂直度、优化发布节奏、提升互动率、提高完播率及利用AI工具五步改善。一、明确内容领域并保持视觉统一,前五视频聚焦定位;二、每日发布间隔6小时以上,选7-9点、12-1点、6-8点高峰时段,每周更新至少5条;三、开头设问引导评论,结尾提示收藏,100%回复评论提升粘性…

    2026年9月26日 • 用户投稿
    200
  • 2025年真实动态视频生成AI工具排行榜前十名

    2025年最值得关注的动态视频生成AI工具包括RunwayML Gen-3、Pika Labs、Luma AI Dream Machine、Google Imagen Video、Meta Make-A-Video、Synthesia IO、D-ID、DeepMotion Animate 3D、Ho…

    2026年9月26日
    100
  • MySQL中正则表达式应用 REGEXP在复杂条件查询中的用法

    mysql 中 regexp 可用于模糊匹配不确定的字符串结构,比 like 更强大。1. 使用 | 匹配多个可能值,如 ‘apple|orange’ 表示“或”关系;2. 用 ^ 和 $ 分别匹配开头和结尾内容,如 ‘^user_’ 或 &#8216…

    2026年9月26日
    000
  • Java微服务分布式事务实战:TCC模式与Seata框架深度整合

    Java微服务分布式事务实战:TCC模式与Seata框架深度整合Java微服务分布式事务实战:TCC模式与Seata框架深度整合Java微服务分布式事务实战:TCC模式与Seata框架深度整合Java微服务分布式事务实战:TCC模式与Seata框架深度整合

    TCC模式结合Seata框架是微服务中实现分布式事务的可靠方案,通过Try-Confirm-Cancel机制将事务控制提升至业务层,Seata以@GlobalTransactional和@TwoPhaseBusinessAction注解简化事务协调,实现资源的预留、确认与回滚,解决数据一致性难题。 …

    2026年9月26日 • 用户投稿
    100
  • 豪鹏科技H1预计营收26.8亿元-28亿元,净利润同比预增228.03%–271.77%

    豪鹏科技H1预计营收26.8亿元-28亿元,净利润同比预增228.03%–271.77%豪鹏科技H1预计营收26.8亿元-28亿元,净利润同比预增228.03%–271.77%豪鹏科技H1预计营收26.8亿元-28亿元,净利润同比预增228.03%–271.77%豪鹏科技H1预计营收26.8亿元-28亿元,净利润同比预增228.03%–271.77%

    ☞☞☞AI 智能聊天, 问答助手, AI 智能搜索, 免费无限量使用 DeepSeek R1 模型☜☜☜ 7月8日,豪鹏科技披露了2025年上半年业绩预告。预计上半年实现营业收入268,000万元至280,000万元,同比增长15.72%至20.9%;归属于上市公司股东的净利润预计为9,000万元至…

    2026年9月26日 • 用户投稿
    100
  • Java加密输出长度限制的策略与实践

    Java加密输出长度限制的策略与实践Java加密输出长度限制的策略与实践Java加密输出长度限制的策略与实践Java加密输出长度限制的策略与实践

    本文探讨了在Java中将可变长度文本加密并严格限制输出长度在100字符以内的方法。由于加密本身并非压缩,且现代密码学算法会引入IV和认证标签等额外开销,直接加密难以满足短输出要求。教程将提供预加密优化(编码与压缩)、最小化密文表示开销、充分利用存储字符集以及分段传输等策略,以平衡安全性与长度限制。 …

    2026年9月26日 • 用户投稿
    000
  • Java加密输出长度限制:挑战与多维策略

    Java加密输出长度限制:挑战与多维策略Java加密输出长度限制:挑战与多维策略Java加密输出长度限制:挑战与多维策略Java加密输出长度限制:挑战与多维策略

    本文探讨了在Java中对文本进行加密并严格限制输出长度(例如100字符)的挑战。由于现代加密算法通常会增加而非压缩数据,文章将介绍如何通过优化编码、数据压缩、最小化加密开销、高效字符存储以及分段传输等多种策略来应对这一特殊需求,确保在满足长度限制的同时兼顾安全性。 在许多应用场景中,对数据进行加密是…

    2026年9月26日 • 用户投稿
    000
  • win8时间不准怎么同步_Win8时间同步教程

    win8时间不准怎么同步_Win8时间同步教程win8时间不准怎么同步_Win8时间同步教程win8时间不准怎么同步_Win8时间同步教程win8时间不准怎么同步_Win8时间同步教程

    1、启用自动时间同步:通过“Internet 时间”选项卡勾选同步并选择服务器,点击“立即更新”完成校准;2、手动调整时间:在“日期和时间”选项卡中修改具体数值;3、检查时区:选择对应地理区域的时区并设置夏令时。 如果您发现Windows 8系统的日期和时间显示不正确,这可能会导致程序运行异常、文件…

    2026年9月26日 • 用户投稿
    500
  • 如何配置Tomcat日志轮转

    如何配置Tomcat日志轮转如何配置Tomcat日志轮转如何配置Tomcat日志轮转如何配置Tomcat日志轮转

    本文介绍如何利用Linux系统自带的logrotate工具实现Tomcat日志的自动轮转。 步骤一:创建或修改logrotate配置文件 在/etc/logrotate.d/目录下,创建或修改名为tomcat的配置文件(或其他你选择的名称)。使用以下命令: sudo vim /etc/logrota…

    2026年9月26日 • 用户投稿
    000
  • windows激活失败错误0x8007007b怎么办_激活错误0x8007007b问题解决流程

    windows激活失败错误0x8007007b怎么办_激活错误0x8007007b问题解决流程windows激活失败错误0x8007007b怎么办_激活错误0x8007007b问题解决流程windows激活失败错误0x8007007b怎么办_激活错误0x8007007b问题解决流程windows激活失败错误0x8007007b怎么办_激活错误0x8007007b问题解决流程

    0x8007007b错误通常由系统时间不准、激活服务异常或注册表问题引起。首先检查并同步系统时间和时区,确保网络通畅;接着以管理员身份运行命令提示符,依次执行slmgr.vbs /upk、/ipk输入有效密钥和/ato尝试激活;若问题依旧,运行sfc /scannow修复系统文件,并在服务中确认“软…

    2026年9月26日 • 用户投稿
    1800
  • sublime有哪些必装的插件_sublime推荐必装插件清单

    sublime有哪些必装的插件_sublime推荐必装插件清单sublime有哪些必装的插件_sublime推荐必装插件清单sublime有哪些必装的插件_sublime推荐必装插件清单sublime有哪些必装的插件_sublime推荐必装插件清单

    Sublime Text通过插件可大幅提升效率,建议安装Package Control以方便管理插件;SideBarEnhancements增强侧边栏功能,支持文件快速操作;Emmet和代码片段插件提升前端开发速度,实现HTML/CSS/JS的高效编写;Git集成插件支持版本控制操作,GitGutt…

    2026年9月26日 • 用户投稿
    200
  • Java加密输出长度优化:应对API 100字符限制的策略与实践

    Java加密输出长度优化:应对API 100字符限制的策略与实践Java加密输出长度优化:应对API 100字符限制的策略与实践Java加密输出长度优化:应对API 100字符限制的策略与实践Java加密输出长度优化:应对API 100字符限制的策略与实践

    本文探讨在Java中实现文本加密时,如何应对输出密文长度不超过100字符的严格限制。我们将深入理解加密算法的本质,分析其非压缩特性及额外开销,并提供一系列实用的优化策略,包括前置数据压缩、最小化加密开销、高效密文表示以及协议层面的分段传输,旨在帮助开发者在满足安全需求的同时,符合特定的API长度约束…

    2026年9月26日 • 用户投稿
    000
  • 线性代数中的满射:它与“满秩”有何关系?

    线性代数中的满射:它与“满秩”有何关系?线性代数中的满射:它与“满秩”有何关系?线性代数中的满射:它与“满秩”有何关系?线性代数中的满射:它与“满秩”有何关系?

    满射与满秩的关系取决于矩阵维度:当行数m≤列数n时,满秩(rank=min(m,n)=m)等价于满射(rank=m);当m>n时,满秩(rank=n)无法满足满射(需rank=m),故不等价。 线性代数中,一个线性变换如果是“满射”,意味着它的像(输出空间)能够完全覆盖其协同域。而矩阵的“满秩…

    2026年9月26日 • 用户投稿
    100
  • Android应用中Activity间文件路径传递与PDF加载指南

    Android应用中Activity间文件路径传递与PDF加载指南Android应用中Activity间文件路径传递与PDF加载指南Android应用中Activity间文件路径传递与PDF加载指南Android应用中Activity间文件路径传递与PDF加载指南

    本文旨在解决Android应用中通过Intent在Activity间传递文件路径时常见的NullPointerException问题,尤其是在加载PDF文件场景。我们将深入分析导致此错误的原因,并提供两种安全有效的解决方案:使用getAbsolutePath()传递字符串路径,或利用Serializ…

    2026年9月26日 • 用户投稿
    1400
  • php数据库如何删除记录 php数据库DELETE操作的安全规范

    使用预处理语句可防止SQL注入,确保删除操作安全;应验证用户输入、检查ID合法性,避免直接拼接参数;通过权限校验确认数据归属,防止越权删除;建议采用软删除或二次确认机制,避免误删;DELETE必须包含WHERE条件,禁止无条件删除整表;结合事务与日志审计提升安全性。 在PHP中操作数据库删除记录时,…

    2026年9月26日
    000
  • 用AI工具搭建自动化内容生成系统的完整流程

    用AI工具搭建自动化内容生成系统的完整流程用AI工具搭建自动化内容生成系统的完整流程用AI工具搭建自动化内容生成系统的完整流程用AI工具搭建自动化内容生成系统的完整流程

    搭建自动化内容生成系统需选择合适ai工具并整合至高效流程。1.选择ai工具时应明确内容类型、评估功能、性能与价格,并测试试用版本;2.设计流程包括确定主题、生成初稿、人工润色、seo优化及发布推广;3.整合工具需技术连接各环节,测试优化并定期更新;4.注意版权问题,确保合法使用生成内容;5.从准确性…

    2026年9月26日 • 用户投稿
    000
  • 抖音短剧如何剪辑才能保证原创性?如何制作自己的原创视频?5大剪辑准则你了解吗?

    抖音短剧如何剪辑才能保证原创性?如何制作自己的原创视频?5大剪辑准则你了解吗?抖音短剧如何剪辑才能保证原创性?如何制作自己的原创视频?5大剪辑准则你了解吗?抖音短剧如何剪辑才能保证原创性?如何制作自己的原创视频?5大剪辑准则你了解吗?抖音短剧如何剪辑才能保证原创性?如何制作自己的原创视频?5大剪辑准则你了解吗?

    一、保障原创性的5大剪辑核心原则 1. 故事结构革新策略 具备原创价值的剧本必须满足以下三点: 构建新颖的世界观(如记忆移植、梦境共享)打破常规的情节推进方式(每集设置不少于一次关键反转)重构人物关系模型(突破常规情感与社会联结) 2. 拍摄素材溯源管理 在拍摄环节构建完整创作证据链: 启用摄像设备…

    2026年9月26日 • 用户投稿
    100

发表回复

登录后才能评论
关注微信