相关文章推荐
逆袭的蘑菇  ·  【java框架】SpringMVC(4) ...·  2 周前    · 
淡定的地瓜  ·  iOS 通信通知 ...·  1 周前    · 
想旅行的双杠  ·  单细胞 | ...·  5 月前    · 
深情的煎鸡蛋  ·  locale ...·  1 年前    · 
坚强的柿子  ·  08-05 ...·  1 年前    · 
卖萌的紫菜  ·  CSS ...·  1 年前    · 
首页 > 软件编程 > java > Java8 groupingBy分组使用

Java8 Stream之groupingBy分组使用解读

作者:Archie_java

这篇文章主要介绍了Java8 Stream之groupingBy分组使用,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教

Java8 Stream之groupingBy分组

本文主要讲解:Java 8 Stream之Collectors.groupingBy()分组示例

Collectors.groupingBy()分组之常见用法

功能代码:

* 使用java8 stream groupingBy操作,按城市分组list     public void groupingByCity() {         Map<String, List<Employee>> map = employees.stream().collect(Collectors.groupingBy(Employee::getCity));         map.forEach((k, v) -> {             System.out.println(k + " = " + v);

Collectors.groupingBy() 分组之统计每个分组的count

功能代码:

* 使用java8 stream groupingBy操作,按城市分组list统计count     public void groupingByCount() {         Map<String, Long> map = employees.stream()                 .collect(Collectors.groupingBy(Employee::getCity, Collectors.counting()));         map.forEach((k, v) -> {             System.out.println(k + " = " + v);

Collectors.groupingBy() 分组之统计分组平均值

功能代码:

* 使用java8 stream groupingBy操作,按城市分组list并计算分组年龄平均值     public void groupingByAverage() {         Map<String, Double> map = employees.stream()                 .collect(Collectors.groupingBy(Employee::getCity, Collectors.averagingInt(Employee::getAge)));         map.forEach((k, v) -> {             System.out.println(k + " = " + v);

Collectors.groupingBy() 分组之统计分组总值

功能代码:

* 使用java8 stream groupingBy操作,按城市分组list并计算分组销售总值     public void groupingBySum() {         Map<String, Long> map = employees.stream()                 .collect(Collectors.groupingBy(Employee::getCity, Collectors.summingLong(Employee::getAmount)));         map.forEach((k, v) -> {             System.out.println(k + " = " + v);         // 对Map按照分组销售总值逆序排序         Map<String, Long> sortedMap = new LinkedHashMap<>();         map.entrySet().stream().sorted(Map.Entry.<String, Long> comparingByValue().reversed())                 .forEachOrdered(e -> sortedMap.put(e.getKey(), e.getValue()));         sortedMap.forEach((k, v) -> {             System.out.println(k + " = " + v);

Collectors.groupingBy() 分组之Join分组List

功能代码:

* 使用java8 stream groupingBy操作,按城市分组list并通过join操作连接分组list中的对象的name 属性使用逗号分隔     public void groupingByString() {         Map<String, String> map = employees.stream().collect(Collectors.groupingBy(Employee::getCity,                 Collectors.mapping(Employee::getName, Collectors.joining(", ", "Names: [", "]"))));         map.forEach((k, v) -> {             System.out.println(k + " = " + v);

Collectors.groupingBy() 分组之转换分组结果List -> List

功能代码:

* 使用java8 stream groupingBy操作,按城市分组list,将List转化为name的List     public void groupingByList() {         Map<String, List<String>> map = employees.stream().collect(                 Collectors.groupingBy(Employee::getCity, Collectors.mapping(Employee::getName, Collectors.toList())));         map.forEach((k, v) -> {             System.out.println(k + " = " + v);             v.stream().forEach(item -> {                 System.out.println("item = " + item);

Collectors.groupingBy() 分组之转换分组结果List -> Set

功能代码:

* 使用java8 stream groupingBy操作,按城市分组list,将List转化为name的Set     public void groupingBySet() {         Map<String, Set<String>> map = employees.stream().collect(                 Collectors.groupingBy(Employee::getCity, Collectors.mapping(Employee::getName, Collectors.toSet())));         map.forEach((k, v) -> {             System.out.println(k + " = " + v);             v.stream().forEach(item -> {                 System.out.println("item = " + item);

Collectors.groupingBy() 分组之使用对象分组List

功能代码:

* 使用java8 stream groupingBy操作,通过Object对象的成员分组List     public void groupingByObject() {         Map<Manage, List<Employee>> map = employees.stream().collect(Collectors.groupingBy(item -> {             return new Manage(item.getName());         map.forEach((k, v) -> {             System.out.println(k + " = " + v);

Collectors.groupingBy() 分组之使用两个成员分组List

功能代码:

* 使用java8 stream groupingBy操作, 基于city 和name 实现多次分组     public void groupingBys() {         Map<String, Map<String, List<Employee>>> map = employees.stream()                 .collect(Collectors.groupingBy(Employee::getCity, Collectors.groupingBy(Employee::getName)));         map.forEach((k, v) -> {             System.out.println(k + " = " + v);             v.forEach((i, j) -> {                 System.out.println(i + " = " + j);

自定义Distinct对结果去重

* 使用java8 stream groupingBy操作, 基于Distinct 去重数据     public void groupingByDistinct() {         List<Employee> list = employees.stream().filter(distinctByKey(Employee :: getCity))                 .collect(Collectors.toList());;         list.stream().forEach(item->{             System.out.println("city = " + item.getCity());      * 自定义重复key 规则      * @param keyExtractor      * @return     private static <T> Predicate<T> distinctByKey(Function<? super T, ?> keyExtractor) {         Set<Object> seen = ConcurrentHashMap.newKeySet();         return t -> seen.add(keyExtractor.apply(t));

完整源代码:

package com.stream;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;
import java.util.Random;
import java.util.Set;
import java.util.concurrent.ConcurrentHashMap;
import java.util.function.Function;
import java.util.function.Predicate;
import java.util.stream.Collectors;
 * Java 8 Stream 之groupingBy 分组讲解
 * @author zzg
public class Java8GroupBy {
    List<Employee> employees = new ArrayList<Employee>();
     * 数据初始化
    public void init() {
        List<String> citys = Arrays.asList("湖南", "湖北", "江西", "广西 ");
        for (int i = 0; i < 10; i++) {
            Random random = new Random();
            Integer index = random.nextInt(4);
            Employee employee = new Employee(citys.get(index), "姓名" + i, (random.nextInt(4) * 10 - random.nextInt(4)),
                    (random.nextInt(4) * 1000 - random.nextInt(4)));
            employees.add(employee);
     * 使用java8 stream groupingBy操作,按城市分组list
    public void groupingByCity() {
        Map<String, List<Employee>> map = employees.stream().collect(Collectors.groupingBy(Employee::getCity));
        map.forEach((k, v) -> {
            System.out.println(k + " = " + v);
     * 使用java8 stream groupingBy操作,按城市分组list统计count
    public void groupingByCount() {
        Map<String, Long> map = employees.stream()
                .collect(Collectors.groupingBy(Employee::getCity, Collectors.counting()));
        map.forEach((k, v) -> {
            System.out.println(k + " = " + v);
     * 使用java8 stream groupingBy操作,按城市分组list并计算分组年龄平均值
    public void groupingByAverage() {
        Map<String, Double> map = employees.stream()
                .collect(Collectors.groupingBy(Employee::getCity, Collectors.averagingInt(Employee::getAge)));
        map.forEach((k, v) -> {
            System.out.println(k + " = " + v);
     * 使用java8 stream groupingBy操作,按城市分组list并计算分组销售总值
    public void groupingBySum() {
        Map<String, Long> map = employees.stream()
                .collect(Collectors.groupingBy(Employee::getCity, Collectors.summingLong(Employee::getAmount)));
        map.forEach((k, v) -> {
            System.out.println(k + " = " + v);
        // 对Map按照分组销售总值逆序排序
        Map<String, Long> sortedMap = new LinkedHashMap<>();
        map.entrySet().stream().sorted(Map.Entry.<String, Long> comparingByValue().reversed())
                .forEachOrdered(e -> sortedMap.put(e.getKey(), e.getValue()));
        sortedMap.forEach((k, v) -> {
            System.out.println(k + " = " + v);
     * 使用java8 stream groupingBy操作,按城市分组list并通过join操作连接分组list中的对象的name 属性使用逗号分隔
    public void groupingByString() {
        Map<String, String> map = employees.stream().collect(Collectors.groupingBy(Employee::getCity,
                Collectors.mapping(Employee::getName, Collectors.joining(", ", "Names: [", "]"))));
        map.forEach((k, v) -> {
            System.out.println(k + " = " + v);
     * 使用java8 stream groupingBy操作,按城市分组list,将List转化为name的List
    public void groupingByList() {
        Map<String, List<String>> map = employees.stream().collect(
                Collectors.groupingBy(Employee::getCity, Collectors.mapping(Employee::getName, Collectors.toList())));
        map.forEach((k, v) -> {
            System.out.println(k + " = " + v);
            v.stream().forEach(item -> {
                System.out.println("item = " + item);
     * 使用java8 stream groupingBy操作,按城市分组list,将List转化为name的Set
    public void groupingBySet() {
        Map<String, Set<String>> map = employees.stream().collect(
                Collectors.groupingBy(Employee::getCity, Collectors.mapping(Employee::getName, Collectors.toSet())));
        map.forEach((k, v) -> {
            System.out.println(k + " = " + v);
            v.stream().forEach(item -> {
                System.out.println("item = " + item);
     * 使用java8 stream groupingBy操作,通过Object对象的成员分组List
    public void groupingByObject() {
        Map<Manage, List<Employee>> map = employees.stream().collect(Collectors.groupingBy(item -> {
            return new Manage(item.getName());
        map.forEach((k, v) -> {
            System.out.println(k + " = " + v);
     * 使用java8 stream groupingBy操作, 基于city 和name 实现多次分组
    public void groupingBys() {
        Map<String, Map<String, List<Employee>>> map = employees.stream()
                .collect(Collectors.groupingBy(Employee::getCity, Collectors.groupingBy(Employee::getName)));
        map.forEach((k, v) -> {
            System.out.println(k + " = " + v);
            v.forEach((i, j) -> {
                System.out.println(i + " = " + j);
     * 使用java8 stream groupingBy操作, 基于Distinct 去重数据
    public void groupingByDistinct() {
        List<Employee> list = employees.stream().filter(distinctByKey(Employee :: getCity))
                .collect(Collectors.toList());;
        list.stream().forEach(item->{
            System.out.println("city = " + item.getCity());
     * 自定义重复key 规则
     * @param keyExtractor
     * @return
    private static <T> Predicate<T> distinctByKey(Function<? super T, ?> keyExtractor) {
        Set<Object> seen = ConcurrentHashMap.newKeySet();
        return t -> seen.add(keyExtractor.apply(t));
    public static void main(String[] args) {
        // TODO Auto-generated method stub
        Java8GroupBy instance = new Java8GroupBy();
        instance.init();
        instance.groupingByCity();
        instance.groupingByCount();
        instance.groupingByAverage();
        instance.groupingBySum();
        instance.groupingByString();
        instance.groupingByList();
        instance.groupingBySet();
        instance.groupingByObject();
        instance.groupingBys();
        instance.groupingByDistinct();
    class Employee {
        private String city;
        private String name;
        private Integer age;
        private Integer amount;
        public String getCity() {
            return city;
        public void setCity(String city) {
            this.city = city;
        public String getName() {
            return name;
        public void setName(String name) {
            this.name = name;
        public Integer getAge() {
            return age;
        public void setAge(Integer age) {
            this.age = age;
        public Integer getAmount() {
            return amount;
        public void setAmount(Integer amount) {
            this.amount = amount;
        public Employee(String city, String name, Integer age, Integer amount) {
            super();
            this.city = city;
            this.name = name;
            this.age = age;
            this.amount = amount;
        public Employee() {
            super();
    class Manage {
        private String name;
        public String getName() {
            return name;
        public void setName(String name) {
            this.name = name;
        public Manage(String name) {
            super();
            this.name = name;
        public Manage() {
            super();

以上为个人经验,希望能给大家一个参考,也希望大家多多支持脚本之家。

您可能感兴趣的文章:
  • maven多个仓库查询的优先级顺序案例讲解
    maven多个仓库查询的优先级顺序案例讲解
    2023-04-04
  • Java访问者模式实现优雅的对象结构处理
    Java访问者模式实现优雅的对象结构处理
    2023-04-04
  • 深入理解Java责任链模式实现灵活的请求处理流程
    深入理解Java责任链模式实现灵活的请求处理流程
    2023-04-04
  • Spring中使用事务嵌套时需要警惕的问题分享
    Spring中使用事务嵌套时需要警惕的问题分享
    2023-04-04
  • Java8 Stream之groupingBy分组使用解读
    Java8 Stream之groupingBy分组使用解读
    2023-04-04
  • Java命令设计模式优雅解耦命令和执行提高代码可维护性
    Java命令设计模式优雅解耦命令和执行提高代码可维护性
    2023-04-04
  • Java方法的返回值及注意事项小结
    Java方法的返回值及注意事项小结
    2023-04-04
  • Java中ResultSetMetaData 元数据的具体使用
    Java中ResultSetMetaData 元数据的具体使用
    2023-04-04
  • 美国设下计谋,用娘炮文化重塑日本,已影响至中国
    美国设下计谋,用娘炮文化重塑日本,已影响至中国
    2021-11-19
  • 时空伴随者是什么意思?时空伴随者介绍
    时空伴随者是什么意思?时空伴随者介绍
    2021-11-09
  • 工信部称网盘企业免费用户最低速率应满足基本下载需求,天翼云盘回应:坚决支持,始终
    工信部称网盘企业免费用户最低速率应满足基本下载需求,天翼云盘回应:坚决支持,始终
    2021-11-05
  • 2022年放假安排出炉:五一连休5天 2022年所有节日一览表
    2022年放假安排出炉:五一连休5天 2022年所有节日一览表
    2021-10-26
  • 电脑版 - 返回首页

    2006-2023 脚本之家 JB51.Net , All Rights Reserved.
    苏ICP备14036222号