大家好，又见面了，我是你们的朋友全栈君。
介绍 Java 8 groupingBy Collector
本文我们探讨下Java 8 groupingBy Collector，通过不同的示例进行详细讲解。
GroupingBy Collector
Java 8 Stream API 提供了声明方式处理流数据。static工厂方法Collectors.groupingBy() 和 Collectors.groupingByConcurrent() 实现类似SQL语句的“Group By”字句功能，实现根据一些属性进行分组并把结果存在Map实例。
重载groupingBy的几个方法：
static Collector>>
groupingBy(Function super T,? extends K> classifier)
提供后续收集器参数：
static Collector>
groupingBy(Function super T,? extends K> classifier,
Collector super T,A,D> downstream)
提供map 提供者和后续收集器参数：
static > Collector
groupingBy(Function super T,? extends K> classifier,
Supplier mapFactory, Collector super T,A,D> downstream)
下面通过示例详细看看每个方法的应用场景。
基础准备
为了演示groupingBy()，让我们定义BlogPost类(作为流使用)：
class BlogPost {
String title;
String author;
BlogPostType type;
int likes;
}
BlogPostType:
enum BlogPostType {
NEWS,
REVIEW,
GUIDE
}
定义一个BlogPost列表：
List posts = Arrays.asList( … );
同时也订一个Tuple类用于根据多个属性进行分组：
class Tuple {
BlogPostType type;
String author;
}
通过单个属性简单分组
首先从最简单的groupingBy 方法开始，使用一个分类函数作为参数。分类函数应用于流中的每个元素。函数的返回值用于map的key，映射至分组集合。根据post类型进行分组的代码：
Map> postsPerType = posts.stream()
.collect(groupingBy(BlogPost::getType));
根据复杂类型进行分组
Map> postsPerTypeAndAuthor = posts.stream()
.collect(groupingBy(post -> new Tuple(post.getType(), post.getAuthor())));
分组类型不限于标量或字符串类型。map的key可以是任何对象类型，只有我们确保实现必要的equals 和 hashcode 方法。下面根据组合类型进行分组：
Map> postsPerTypeAndAuthor = posts.stream()
.collect(groupingBy(post -> new Tuple(post.getType(), post.getAuthor())));
修改返回Map值类型
第二个重载groupingBy方法带另一个参数指定后续收集器，应用于第一个集合结果。当我们仅指定一个分类器函数，没有后续收集器，则返回toList()集合。如何后续收集器使用toSet()，则会获得Set集合，而不是List：
Map> postsPerType = posts.stream()
.collect(groupingBy(BlogPost::getType, toSet()));
根据多个字段进行分组
与应用后续收集器不同的是，可以指定第二个分类器对第一个分组结果再分组。对BlogPost类的List根据作者和类型进行分组代码如下：
Map> map = posts.stream()
.collect(groupingBy(BlogPost::getAuthor, groupingBy(BlogPost::getType)));
获取分组结果的平均值
通过使用后续收集器可以对分组函数的结果使用聚集函数。获取每种blog类型的平均数：
Map averageLikesPerType = posts.stream()
.collect(groupingBy(BlogPost::getType, averagingInt(BlogPost::getLikes)));
获取分组结果之和
计算每个分组之和：
Map likesPerType = posts.stream()
.collect(groupingBy(BlogPost::getType, summingInt(BlogPost::getLikes)));
获取分组结果的最大值和最小值
另外可以通过聚集函数获取最大数量的blog类型：
Map> maxLikesPerPostType = posts.stream()
.collect(groupingBy(BlogPost::getType,
maxBy(comparingInt(BlogPost::getLikes))));
类似的，我们能应用minBy后续收集器获得最小数量的分类。注意，maxBy和minBy 收集器考虑到应用它的集合可能是空的。这就是为什么map中的值类型是可选的。
获取属性分组结果的摘要信息
Collectors API提供了摘要收集器，用于需要同时获取数值属性的count,sum, minimum, maximum ,average 值。下面计算每种类型的摘要信息：
Map likeStatisticsPerType = posts.stream()
.collect(groupingBy(BlogPost::getType,
summarizingInt(BlogPost::getLikes)));
每个类型的IntSummaryStatistics 对象包括属性的 count, sum, average, min 和 max值。另外摘要对象也有double和long类型。
映射分组结果至不同类型
更复杂的聚集可以对分类结果应用后续映射收集器。下面获得每个类型的连接blog的标题。
Map postsPerType = posts.stream()
.collect(groupingBy(BlogPost::getType,
mapping(BlogPost::getTitle, joining(“, “, “Post titles: [“, “]”))));
上面代码实现映射每个BlogPost 实例至title，然后reduce 文章标题流至连接字符串。本例Map的值是字符串，而不是默认List类型。
修改返回 Map 类型
当使用groupingBy 收集器，我们不能确定返回Map的类型。如果我们想指定特定Map类型作为返回值，我们使用三个参数的groupingBy 方法，通过提供Map supplier函数，其允许我们改变Map的类型。
通过EnumMap supplier函数给goupingBy方法获取EnumMap：
EnumMap> postsPerType = posts.stream()
.collect(groupingBy(BlogPost::getType,
() -> new EnumMap<>(BlogPostType.class), toList()));
并发Grouping By Collector
类似于 groupingBy, 也有groupingByConcurrent 收集器，其利用多线程架构。其有三个重载方法，带有与groupingBy一样的参数。然而，groupingByConcurrent 收集器的返回值必须是ConcurrentHashMap 类或其子类。
实现并发分组的代码如下：
ConcurrentMap> postsPerType = posts.parallelStream()
.collect(groupingByConcurrent(BlogPost::getType));
如果你选择传递Map supplier函数给groupingByConcurrent 收集器，那么需要确保函数返回值也必须是ConcurrentHashMap 类或其子类。
总结
本文我们看了Java 8 中提供的几个groupingBy collector示例。groupingBy可以对流元素根据其属性进行分组，然后进一步收集、改变并收集至最终的容器中。
发布者：全栈程序员栈长，转载请注明出处：https://javaforall.cn/171310.html原文链接：https://javaforall.cn
