
本文详细介绍了如何利用java stream api,在仅允许一次流消费的前提下,对自定义对象流中的字符串属性进行分组、计数,并根据计数结果进行降序排序,对于计数相同的项再按字母顺序升序排序,最终生成一个有序的字符串列表。文章通过具体代码示例,演示了`collectors.groupingby`、`collectors.counting`以及自定义`comparator`的组合应用,提供了一种高效且符合函数式编程范式的解决方案。
在处理数据流时,我们经常会遇到需要对数据进行分组、统计,并根据统计结果进行排序的场景。特别是在Java Stream API中,如果一个流只能被消费一次,这就要求我们设计一个单一的、连贯的操作链来完成所有任务。本教程将深入探讨如何高效地实现这一目标,即从一个自定义对象流中提取特定属性,根据其出现频率进行排序,并在频率相同的情况下进行二次排序。
假设我们有一个Stream<MyType>,其中MyType是一个自定义类,包含一个String类型的category属性:
public class MyType {
private String category;
// 其他属性、构造函数、getter/setter等
public MyType(String category) {
this.category = category;
}
public String getCategory() {
return category;
}
@Override
public String toString() {
return "MyType{category='" + category + "'}";
}
}我们的目标是生成一个List<String>,包含所有唯一的category值,并按照以下规则进行排序:
核心挑战在于,我们只能对输入的Stream<MyType>进行一次消费。
立即学习“Java免费学习笔记(深入)”;
例如,给定以下输入:
{
object1 :{category:"category1"},
object2 :{category:"categoryB"},
object3 :{category:"categoryA"},
object4 :{category:"category1"},
object5 :{category:"categoryB"},
object6 :{category:"category1"},
object7 :{category:"categoryA"}
}期望的输出是:
List = {category1, categoryA, categoryB}(因为category1出现3次,categoryA出现2次,categoryB出现2次。category1频率最高,categoryA和categoryB频率相同,但categoryA在字母顺序上先于categoryB。)
解决这个问题的关键在于两个步骤:
以下是实现上述逻辑的Java方法:
import java.util.Arrays;
import java.util.Comparator;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;
import java.util.stream.Stream;
public class CategorySorter {
// MyType 类定义(如上所示)
public static class MyType {
private String category;
public MyType(String category) {
this.category = category;
}
public String getCategory() {
return category;
}
@Override
public String toString() {
return "MyType{category='" + category + "'}";
}
}
/**
* 根据类别出现频率(降序)和类别名称(升序)对类别进行排序。
*
* @param stream 包含MyType对象的流,只能消费一次。
* @return 排序后的类别名称列表。
*/
public static List<String> getSortedCategories(Stream<MyType> stream) {
return stream
// 步骤1: 分组并计数
.collect(Collectors.groupingBy(
MyType::getCategory, // 按MyType对象的category属性分组
Collectors.counting() // 计算每个分组中的元素数量
)) // 结果是一个 Map<String, Long>,例如: {"category1": 3, "categoryB": 2, "categoryA": 2}
// 步骤2: 将Map的entrySet转换为流
.entrySet().stream()
// 步骤3: 对Map.Entry进行排序
.sorted(
// 主排序: 按值(计数)降序
Map.Entry.<String, Long>comparingByValue().reversed()
// 次排序: 如果值(计数)相同,则按键(类别名称)升序
.thenComparing(Map.Entry.comparingByKey())
)
// 步骤4: 提取排序后的键(类别名称)
.map(Map.Entry::getKey)
// 步骤5: 收集结果到列表中 (Java 16+ 的简洁写法,Java 8-15 可用 .collect(Collectors.toList()))
.toList();
}
public static void main(String[] args) {
// 示例输入数据
Stream<MyType> inputData = Arrays.asList(
new MyType("category1"),
new MyType("categoryB"),
new MyType("categoryA"),
new MyType("category1"),
new MyType("categoryB"),
new MyType("category1"),
new MyType("categoryA")
).stream();
// 调用方法获取排序后的类别列表
List<String> sortedCategories = getSortedCategories(inputData);
// 打印结果
System.out.println("排序后的类别列表: " + sortedCategories);
// 预期输出: 排序后的类别列表: [category1, categoryA, categoryB]
}
}stream.collect(Collectors.groupingBy(MyType::getCategory, Collectors.counting())):
.entrySet().stream():
.sorted(Map.Entry.<String, Long>comparingByValue().reversed().thenComparing(Map.Entry.comparingByKey())):
.map(Map.Entry::getKey):
.toList():
通过以上方法,我们能够优雅且高效地解决在Java Stream中,对数据进行复杂分组、计数和多级排序的问题,即使在面对单次流消费的约束时也能游刃有余。
以上就是Java Stream:基于聚合计数进行分组与排序的高效实践的详细内容,更多请关注php中文网其它相关文章!
每个人都需要一台速度更快、更稳定的 PC。随着时间的推移,垃圾文件、旧注册表数据和不必要的后台进程会占用资源并降低性能。幸运的是,许多工具可以让 Windows 保持平稳运行。
Copyright 2014-2025 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号