讲师中心 微信公众号

工具推荐

视频效率加速
Seko
Seko

AI短剧一键生成成片

剧云
剧云

中文短剧剧本制作平台

Laper
Laper

剧本策划到成片协作

立刻MV
立刻MV

低成本歌曲 MV、视频生成

Java Stream实战:高效处理对象列表去重,保留最新记录

落明君_4559

落明君_4559

发布时间:2025-08-05 13:40:12

|

645人浏览过

|

来源于php中文网

原创

Java Stream实战:高效处理对象列表去重,保留最新记录

本文详细介绍了如何利用Java Stream API高效处理包含重复ID的对象列表,并根据日期字段保留最新的记录。核心方法是运用Collectors.toMap的三参数重载,结合Function.identity()和BinaryOperator.maxBy(Comparator.comparing())作为合并函数,实现按ID去重并筛选出具有最新日期的对象,最终得到一个去重后的唯一对象列表。

核心问题:列表对象去重与筛选

在数据处理中,我们经常会遇到需要从列表中移除重复对象的情况。一个常见的场景是,列表中存在多个具有相同唯一标识(如id)的对象,但我们只希望保留其中一个,并且这个保留的对象需要满足特定的条件,例如拥有最新的时间戳。传统的方法可能涉及循环遍历和手动比较,但在java 8及更高版本中,通过stream api可以以更简洁、高效的方式实现这一目标。

假设我们有一个Student对象列表,每个Student对象包含一个id和startDatetime字段。我们的目标是:如果存在多个Student对象具有相同的id,则只保留startDatetime最新的那个对象。

首先,定义我们的Student类:

import java.time.LocalDateTime;
import java.util.Objects; // 导入Objects类用于hashCode和equals

class Student {
    private String id;
    private LocalDateTime startDatetime;

    public String getId() {
        return id;
    }

    public void setId(String id) {
        this.id = id;
    }

    public LocalDateTime getStartDatetime() {
        return startDatetime;
    }

    public void setStartDatetime(LocalDateTime startDatetime) {
        this.startDatetime = startDatetime;
    }

    public Student(String id, LocalDateTime startDatetime) {
        this.id = id;
        this.startDatetime = startDatetime;
    }

    @Override
    public String toString() {
        return "Student{id='" + id + "', startDatetime=" + startDatetime + "}";
    }

    // 建议重写equals和hashCode,尽管在此特定Stream操作中非必需,但良好的实践
    @Override
    public boolean equals(Object o) {
        if (this == o) return true;
        if (o == null || getClass() != o.getClass()) return false;
        Student student = (Student) o;
        return Objects.equals(id, student.id) && Objects.equals(startDatetime, student.startDatetime);
    }

    @Override
    public int hashCode() {
        return Objects.hash(id, startDatetime);
    }
}

Java Stream解决方案:Collectors.toMap的应用

解决此问题的关键在于利用Collectors.toMap()的强大功能,特别是其三参数重载版本。这个版本允许我们定义如何处理键冲突(即当两个或多个元素映射到同一个键时)。

Collectors.toMap(keyMapper, valueMapper, mergeFunction)的三个参数分别是:

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

  1. keyMapper: 一个函数,用于从流中的每个元素提取作为Map键的值。
  2. valueMapper: 一个函数,用于从流中的每个元素提取作为Map值的值。
  3. mergeFunction: 一个BinaryOperator,用于在发生键冲突时,决定如何合并两个冲突的值。

1. keyMapper:定义唯一键

在这个场景中,我们希望根据Student的id进行去重。因此,keyMapper将是Student::getId,它从每个Student对象中提取id作为Map的键。

2. valueMapper:保留原始对象

我们希望Map的值仍然是完整的Student对象。因此,valueMapper将是Function.identity(),它返回流中的元素本身。

AI舌诊面诊问诊医疗系统+诊疗商城系统源码
AI舌诊面诊问诊医疗系统+诊疗商城系统源码

AI 舌诊面诊问诊医疗系统 + 诊疗商城系统源码是一套结合 AI 辅助诊断与商品转化的健康类程序,基于浩创云、ThinkPHP(PHP)开发,支持微信服务号与 H5 端,适合做中医舌诊面诊问答、健康建议推送以及配套诊疗商品的运营。

下载

3. mergeFunction:解决冲突,保留最新记录

这是实现去重并保留最新记录的核心。当两个Student对象具有相同的id时,mergeFunction会被调用。我们需要在这个函数中比较这两个Student对象的startDatetime,并返回日期最新的那个。

我们可以使用BinaryOperator.maxBy()结合Comparator.comparing()来构建这个合并函数。BinaryOperator.maxBy(Comparator)会返回一个BinaryOperator,它在两个输入之间选择“更大”的那个,这里的“更大”由提供的Comparator定义。

对于我们的需求,Comparator将基于Student::getStartDatetime进行比较: Comparator.comparing(Student::getStartDatetime)

因此,完整的mergeFunction将是: BinaryOperator.maxBy(Comparator.comparing(Student::getStartDatetime))

当发生键冲突时,此函数会比较两个具有相同id的Student对象,并选择startDatetime更大的(即更新的)那个作为Map中该id对应的值。

示例代码

以下是完整的示例代码,演示了如何使用Java Stream实现上述逻辑:

import java.time.LocalDateTime;
import java.util.ArrayList;
import java.util.Comparator;
import java.util.List;
import java.util.function.Function;
import java.util.function.BinaryOperator;
import java.util.stream.Collectors;

public class StudentProcessor {

    public static void main(String[] args) {
        // 示例数据
        List<Student> students = new ArrayList<>() {{
            add(new Student("1", LocalDateTime.now())); // 最新时间
            add(new Student("1", LocalDateTime.of(2000, 2, 1, 1, 1))); // 较旧时间
            add(new Student("1", LocalDateTime.of(1990, 2, 1, 1, 1))); // 最旧时间
            add(new Student("2", LocalDateTime.of(1990, 2, 1, 1, 1))); // 唯一ID
            add(new Student("3", LocalDateTime.of(2023, 1, 1, 1, 1))); // 唯一ID
            add(new Student("3", LocalDateTime.of(2022, 1, 1, 1, 1))); // 较旧时间
        }};

        System.out.println("原始学生列表:");
        students.forEach(System.out::println);
        System.out.println("\n---");

        // 使用Stream进行去重和筛选
        List<Student> uniqueStudents = students.stream()
            .collect(Collectors.toMap(
                Student::getId, // keyMapper: 以id作为键
                Function.identity(), // valueMapper: 以Student对象本身作为值
                BinaryOperator.maxBy(Comparator.comparing(Student::getStartDatetime)) // mergeFunction: 冲突时保留startDatetime最新的
            ))
            .values() // 获取Map中所有的值(即去重后的Student对象)
            .stream() // 将Map的值再次转换为Stream
            .sorted(Comparator.comparing(Student::getStartDatetime)) // 可选:根据startDatetime排序
            .toList(); // 将Stream收集为List (Java 16+) 或 Collectors.toList() (Java 8-15)

        System.out.println("去重并保留最新记录后的学生列表 (按日期排序):");
        uniqueStudents.forEach(System.out::println);
    }
}

运行结果示例:

原始学生列表:
Student{id='1', startDatetime=2023-10-27T10:30:00.123456}
Student{id='1', startDatetime=2000-02-01T01:01}
Student{id='1', startDatetime=1990-02-01T01:01}
Student{id='2', startDatetime=1990-02-01T01:01}
Student{id='3', startDatetime=2023-01-01T01:01}
Student{id='3', startDatetime=2022-01-01T01:01}

---
去重并保留最新记录后的学生列表 (按日期排序):
Student{id='2', startDatetime=1990-02-01T01:01}
Student{id='1', startDatetime=2023-10-27T10:30:00.123456} // 注意:实际运行时的LocalDateTime.now()会有毫秒级差异
Student{id='3', startDatetime=2023-01-01T01:01}

(请注意,LocalDateTime.now()的输出会根据实际运行时间而变化,上述示例输出中的时间戳是假设值。)

注意事项与扩展

  • Java版本兼容性: 示例代码中使用了.toList()方法,这是Java 16及更高版本提供的便捷方法。如果您的项目使用的是Java 8到Java 15,您需要使用collect(Collectors.toList())来替代。
  • 保留最旧记录: 如果您的需求是保留具有最旧startDatetime的记录,只需将BinaryOperator.maxBy替换为BinaryOperator.minBy即可: BinaryOperator.minBy(Comparator.comparing(Student::getStartDatetime))
  • 最终结果的排序: 在将Map的值转换回List后,我们额外添加了.sorted(Comparator.comparing(Student::getStartDatetime))来对最终结果进行排序。这一步是可选的,取决于您是否需要一个特定顺序的输出列表。如果不进行排序,元素的顺序将取决于Map的迭代顺序(通常是插入顺序或HashMap的内部哈希顺序)。
  • 性能考量: Collectors.toMap在内部会构建一个Map。对于非常大的数据集,这会带来一定的内存和CPU开销。然而,对于大多数常见场景,这种Stream方式的性能是完全可接受的,并且其代码的简洁性和可读性优势显著。
  • 自定义合并逻辑: mergeFunction的灵活性非常高。除了maxBy和minBy,您还可以提供一个自定义的lambda表达式来处理更复杂的合并逻辑,例如,如果日期相同,则根据另一个字段进行选择。

通过这种方式,我们可以利用Java Stream API以声明式、高效且易于理解的方式解决列表对象的去重和筛选问题,极大地提升了代码质量和开发效率。

热门AI工具

更多
火山引擎

火山引擎是一款面向企业的云计算与AI服务平台。

函子Zion

一款支持AI搭建、可视化编辑和多端发布的全栈无代码开发平台。

讯飞智作

讯飞智作是一款AI视频创作工具,AI文本配音工具,数字人课程、营销视频制作。

讯飞绘文

讯飞绘文是一款由科大讯飞推出的一站式 AIGC 内容运营平台。

DeepSeek

DeepSeek是一款面向对话、写作、编程和推理场景的AI大模型工具。

豆包大模型

豆包大模型是一款由字节跳动推出的企业级大语言模型服务平台。

WorkBuddy

一款AI办公效率工具,主要用于腾讯云推出的AI原生桌面智能体工作台,适合需要提升相关任务效率的用户。

SoundView
SoundView Hot

SoundView是一款面向跨境电商的视频翻译、配音和本地化 AI 创作平台。

UP简历
UP简历 Hot

一款AI办公效率工具,主要用于基于AI技术的免费在线简历制作工具,适合需要提升相关任务效率的用户。

相关专题

更多
lambda表达式
lambda表达式

Lambda表达式是一种匿名函数的简洁表示方式,它可以在需要函数作为参数的地方使用,并提供了一种更简洁、更灵活的编码方式,其语法为“lambda 参数列表: 表达式”,参数列表是函数的参数,可以包含一个或多个参数,用逗号分隔,表达式是函数的执行体,用于定义函数的具体操作。本专题为大家提供lambda表达式相关的文章、下载、课程内容,供大家免费下载体验。

1171

2023.09.15

python lambda函数
python lambda函数

本专题整合了python lambda函数用法详解,阅读专题下面的文章了解更多详细内容。

345

2025.11.08

Python lambda详解
Python lambda详解

本专题整合了Python lambda函数相关教程,阅读下面的文章了解更多详细内容。

674

2026.01.05

C++ Lambda 表达式与函数式编程
C++ Lambda 表达式与函数式编程

深入讲解 C++ Lambda 表达式与函数式编程范式,涵盖 Lambda 基础语法与返回值推导、值捕获与引用捕获的区别与陷阱、初始化捕获(C++14 广义捕获)、泛型 Lambda(auto 参数)、mutable 关键字修改捕获变量、std::function 类型擦除与函数包装、std::bind 参数绑定(及其被 Lambda 替代的趋势)、Lambda 在 STL 算法(sort/transform/for_each/remo

869

2026.05.06

Java 函数式接口与 Lambda 进阶技巧
Java 函数式接口与 Lambda 进阶技巧

在 Java Stream 基础之上进一步深入函数式编程,涵盖 @FunctionalInterface 注解与自定义函数式接口设计、四种方法引用(静态/实例/对象/构造器)的使用场景、Lambda 中的 effectively final 变量捕获规则、函数组合(andThen/compose)与柯里化技巧、Comparator 链式比较器构建、CompletableFuture 异步函数式编排、Reactor / RxJava 响应

468

2026.05.08

golang map内存释放
golang map内存释放

本专题整合了golang map内存相关教程,阅读专题下面的文章了解更多相关内容。

750

2025.09.05

golang map相关教程
golang map相关教程

本专题整合了golang map相关教程,阅读专题下面的文章了解更多详细内容。

343

2025.11.16

golang map原理
golang map原理

本专题整合了golang map相关内容,阅读专题下面的文章了解更多详细内容。

553

2025.11.17

Go-Zero API开发使用教程
Go-Zero API开发使用教程

本专题聚焦Go-Zero的API开发,拆解.api描述文件的语法结构、路由与分组定义、参数绑定与校验规则,说明统一响应体、JWT鉴权、跨域与接口文档生成的落地方式,并给出网关聚合与接口测试的实践建议。

100

2026.11.12

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn