
在数据处理中,我们经常会遇到需要从列表中移除重复对象的情况。一个常见的场景是,列表中存在多个具有相同唯一标识(如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);
}
}解决此问题的关键在于利用Collectors.toMap()的强大功能,特别是其三参数重载版本。这个版本允许我们定义如何处理键冲突(即当两个或多个元素映射到同一个键时)。
Collectors.toMap(keyMapper, valueMapper, mergeFunction)的三个参数分别是:
立即学习“Java免费学习笔记(深入)”;
在这个场景中,我们希望根据Student的id进行去重。因此,keyMapper将是Student::getId,它从每个Student对象中提取id作为Map的键。
我们希望Map的值仍然是完整的Student对象。因此,valueMapper将是Function.identity(),它返回流中的元素本身。
这是实现去重并保留最新记录的核心。当两个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 Stream API以声明式、高效且易于理解的方式解决列表对象的去重和筛选问题,极大地提升了代码质量和开发效率。
以上就是Java Stream实战:高效处理对象列表去重,保留最新记录的详细内容,更多请关注php中文网其它相关文章!
每个人都需要一台速度更快、更稳定的 PC。随着时间的推移,垃圾文件、旧注册表数据和不必要的后台进程会占用资源并降低性能。幸运的是,许多工具可以让 Windows 保持平稳运行。
Copyright 2014-2025 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号