首页 > Java > java教程 > 正文

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

霞舞
发布: 2025-10-27 13:23:14
原创
373人浏览过

使用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免费学习笔记(深入)”;

序列猴子开放平台
序列猴子开放平台

具有长序列、多模态、单模型、大数据等特点的超大规模语言模型

序列猴子开放平台 0
查看详情 序列猴子开放平台
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<Image> images;

    public Product(String name, List<Image> images) {
        this.name = name;
        this.images = images;
    }

    public String getName() {
        return name;
    }

    public List<Image> getImages() {
        return images;
    }
}

// 图片类
class Image {
    private String id; // img1, img2, etc.
    private URL url;
    private List<ImageType> types;

    public Image(String id, String url, List<ImageType> 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<ImageType> 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提供了一系列链式操作,能够以声明式的方式处理集合数据。解决上述问题的核心步骤包括:过滤、映射和归约。

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

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

public class ImageProcessor {

    // 定义一个BinaryOperator,用于将字符串用逗号连接
    static final BinaryOperator<String> reducer = (a, b) -> a + "," + b;

    // 定义一个Predicate,用于判断图片是否包含JPG格式
    static final Predicate<Image> 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<Image> 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<Image> 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<Image> 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!
    }
}
登录后复制

代码解析

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

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

    • image.getTypes().stream(): 获取当前Image对象的所有ImageType,并将其转换为一个流。
    • .anyMatch(type -> type.getFormat() == ImageType.Format.JPG): 检查这个ImageType流中是否存在任何一个ImageType的format是JPG。如果存在,则返回true,表示该图片包含JPG格式。
  3. getJpgUrls(final Collection<Image> 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<String>,因为流可能为空。
    • .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高效过滤嵌套列表数据并提取特定信息的详细内容,更多请关注php中文网其它相关文章!

最佳 Windows 性能的顶级免费优化软件
最佳 Windows 性能的顶级免费优化软件

每个人都需要一台速度更快、更稳定的 PC。随着时间的推移,垃圾文件、旧注册表数据和不必要的后台进程会占用资源并降低性能。幸运的是,许多工具可以让 Windows 保持平稳运行。

下载
来源:php中文网
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn
最新问题
开源免费商场系统广告
热门教程
更多>
最新下载
更多>
网站特效
网站源码
网站素材
前端模板
关于我们 免责申明 意见反馈 讲师合作 广告合作 最新更新 English
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送
PHP中文网APP
随时随地碎片化学习

Copyright 2014-2025 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号