Java List Stream流操作实战教学，轻松分组、合并、筛选、拼接、拆分、替换，复制可用！

1、前言

今日无事，记录下常用的一些Stream流操作。

很多案例只是提供思路，活学活用！

废话不多说直接上干货！

2、实体类

设置几个常见属性；

@Data@AllArgsConstructor@NoArgsConstructorpublic class User implements Serializable {    private String userId;    private String userName;    private String areaCode;    private String areaName;    private Integer workDay;}

3、具体操作

1、提取某一属性作为List 常用于数据处理时抽取特定字段

  /*         *1、Stream 只取某一字段作为List sorted排序 distinct 去重         */        List<String> areaCodes = userList.stream().map(User::getAreaCode).sorted().distinct().collect(Collectors.toList());        System.out.println(areaCodes);        List<String> names = userList.stream().map(User::getUserName).distinct().collect(Collectors.toList());        System.out.println(names);

效果：

2、stream 替换某一字段属性 常用于更改特定值 

 /*        2、stream 替换某一字段属性  替换workDay         */        List<User> newUserList = userList.stream().map(a -> {            String xzqhdm = a.getAreaCode();            switch (xzqhdm) {                //雄安新区规划                case "130100":                    a.setWorkDay(20);                    break;                case "130200":                    a.setWorkDay(22);                    break;            }            return a;        }).collect(Collectors.toList());        newUserList.stream().forEach(a->{            System.out.println(a);        });

效果：

3、根据某字段排序

   /*             3、根据某字段排序逆序        */        List<User> reverseOrderCollect = userList.stream()                .sorted(Comparator.comparing(User::getUserId, Comparator.reverseOrder()))                .collect(Collectors.toList());        System.out.println("--排序逆序--");        reverseOrderCollect.stream().forEach(a->{            System.out.println(a);        });        List<User> sortCollect = userList.stream()                .sorted(Comparator.comparing(User::getUserId))                .collect(Collectors.toList());        System.out.println("--排序--");        sortCollect.stream().forEach(a->{            System.out.println(a);        });

效果：

4、筛选出符合条件数据 并取单一属性 常用与数据集筛选

  /*        4、筛选出符合条件数据 并取单一属性 （筛选areacode为130100 的数据湖）         */        List<User> user130100List = userList.stream().filter(a -> "130100".equals(a.getAreaCode())).collect(Collectors.toList());        System.out.println("--筛选出符合条件数据 并取单一属性--");        user130100List.stream().forEach(a->{            System.out.println(a);        });

效果：

5、根据某一字段是否包含字符分组 true、false 也可按照属性分组 常和6一起用处理数据

 /*        5、根据某一字段是否包含字符分组 true、false         */        Map<Boolean, List<User>> groupByMap = userList.stream().collect(Collectors.groupingBy(                a -> a.getUserName().contains("赵")        ));        System.out.println("--根据某一字段是否包含字符分组-");        System.out.println(groupByMap.get(true));        System.out.println(groupByMap.get(false));

效果：

6、分组后遍历map执行方法

   System.out.println("--根据某一字段是否包含字符分组-");        groupByMap.forEach((isZhao, list) ->                testZhao(isZhao, list)        );  private static void testZhao(Boolean isZhao, List<User> list){        if (isZhao){            list.stream().forEach(a->{                System.out.println("赵氏精英");            });        }else{            list.stream().forEach(a->{                System.out.println("非赵氏精英");            });        }    }

效果：

7、根据某一属性拼接逗号 常用于共有属性字段拼接

  /*        7、 根据某一字段拼接","         */        String allUserName = userList.stream()                .map(User::getUserName)                .collect(Collectors.joining(","));        System.out.println("--根据某一字段拼接\",\"--");        System.out.println(allUserName);

效果

8、根据某一字段分组

    /*        8、根据某一字段分组         */        Map<String, List<User>> groupingByMap = userList.stream()                .collect(Collectors.groupingBy(User::getAreaCode));        System.out.println("--根据某一字段分组--");        System.out.println(groupingByMap.get("130100"));        System.out.println(groupingByMap.get("130200"));

效果：

9、根据两个list集合某相同属性合并（赋值） 

   /*        9\根据某属性合并或替换两个list集合 (根据username 合并workday)         */        userList = userList.stream().map(m -> {            newUserList.stream().filter(m2 -> Objects.equals(m.getUserName(), m2.getUserName())).forEach(                    m2 -> {                        m.setWorkDay(m2.getWorkDay()+m.getWorkDay());                        m.setAreaCode(String.valueOf(m.getWorkDay()));                    });            return m;        }).collect(Collectors.toList());        System.out.println("--根据某属性合并两个list集合--");        userList.stream().forEach(a->{            System.out.println(a);        });

效果：

10、根据某属性去重

  System.out.println("--去重--");        userList.stream()                .filter(distinctByKey1(a->a.getWorkDay()))               .forEach(System.out::println); static <T> Predicate<T> distinctByKey1(Function<? super T, ?> keyExtractor) {        Map<Object, Boolean> seen = new ConcurrentHashMap<>();        return t -> seen.putIfAbsent(keyExtractor.apply(t), Boolean.TRUE) == null;    }

效果：

11、根据某字段拆分为有序List

        /*        11、根据某字段拆分为有序List         */      System.out.println("--拆分有序list--");         userList.stream()                //默认hashmap 无序，需要设置有序map                .collect(Collectors.groupingBy(User::getAreaCode, LinkedHashMap::new, Collectors.toList()))                .values().stream().collect(Collectors.toList()).forEach(System.out::println);

效果：

4、完整代码

 private static String[] NAME = new String[]{            "赵牛马", "钱牛马", "孙牛马", "李牛马", "周牛马"    };    public static void main(String[] args) {        List<String> nameList = Arrays.asList(NAME);        List<User> userList = new ArrayList<>();        User user;        for (int i = 0; i < 5; i++) {            user = new User();            user.setUserId(String.valueOf(i));            user.setUserName(nameList.get(i) + (i + 1) * 2);            if ((i & 1) == 0) {                user.setAreaCode("130200");                user.setAreaName("唐山");            } else {                user.setAreaCode("130100");                user.setAreaName("石家庄");            }            user.setWorkDay((i + 7) * (i + 1));            System.out.println(user);            userList.add(user);        }        /*         *1、Stream 只取某一字段作为List sorted排序         */        List<String> years = userList.stream().map(User::getAreaCode).sorted().distinct().collect(Collectors.toList());        System.out.println(years);        List<String> names = userList.stream().map(User::getUserName).distinct().collect(Collectors.toList());        System.out.println(names);        /*        2、stream 替换某一字段属性  替换workDay         */        List<User> newUserList = userList.stream().map(a -> {            String xzqhdm = a.getAreaCode();            switch (xzqhdm) {                //雄安新区规划                case "130100":                    a.setWorkDay(33);                    break;                case "130200":                    a.setWorkDay(12);                    break;            }            return a;        }).collect(Collectors.toList());        System.out.println("--替换某一字段属性 --");        newUserList.stream().forEach(a -> {            System.out.println(a);        });        /*             3、根据某字段排序逆序        */        List<User> reverseOrderCollect = userList.stream()                .sorted(Comparator.comparing(User::getUserId, Comparator.reverseOrder()))                .collect(Collectors.toList());        System.out.println("--排序逆序--");        reverseOrderCollect.stream().forEach(a -> {            System.out.println(a);        });        List<User> sortCollect = userList.stream()                .sorted(Comparator.comparing(User::getUserId))                .collect(Collectors.toList());        System.out.println("--排序--");        sortCollect.stream().forEach(a -> {            System.out.println(a);        });        /*        4、筛选出符合条件数据 并取单一属性 （筛选areacode为130100 的数据湖）         */        List<User> user130100List = userList.stream().filter(a -> "130100".equals(a.getAreaCode())).collect(Collectors.toList());        System.out.println("--筛选出符合条件数据 并取单一属性--");        user130100List.stream().forEach(a -> {            System.out.println(a);        });        /*        5、根据某一字段是否包含字符分组 true、false         */        Map<Boolean, List<User>> groupByMap = userList.stream().collect(Collectors.groupingBy(                a -> a.getUserName().contains("赵")        ));        System.out.println("--根据某一字段是否包含字符分组-");        System.out.println(groupByMap.get(true));        System.out.println(groupByMap.get(false));        /*         * 6、根据某一字段是否包含某字符串拆分并遍历         */        System.out.println("--根据某一字段是否包含字符分组-");        groupByMap.forEach((isZhao, list) ->                testZhao(isZhao, list)        );        /*        7、 根据某一字段拼接","         */        String allUserName = userList.stream()                .map(User::getUserName)                .collect(Collectors.joining(","));        System.out.println("--根据某一字段拼接\",\"--");        System.out.println(allUserName);        /*        8、根据某一字段分组         */        Map<String, List<User>> groupingByMap = userList.stream()                .collect(Collectors.groupingBy(User::getAreaCode));        System.out.println("--根据某一字段分组--");        System.out.println(groupingByMap.get("130100"));        System.out.println(groupingByMap.get("130200"));        /*        9\根据某属性合并或替换两个list集合 (根据username 合并workday)         */        userList = userList.stream().map(m -> {            newUserList.stream().filter(m2 -> Objects.equals(m.getUserName(), m2.getUserName())).forEach(                    m2 -> {                        m.setWorkDay(m2.getWorkDay() + m.getWorkDay());                        m.setAreaCode(String.valueOf(m.getWorkDay()));                    });            return m;        }).collect(Collectors.toList());        System.out.println("--根据某属性合并两个list集合--");        userList.stream().forEach(a -> {            System.out.println(a);        });        /*        10、去重         */        System.out.println("--去重--");        userList.stream()                .filter(distinctByKey1(a -> a.getWorkDay()))                .forEach(System.out::println);        /*        11、根据某字段拆分为有序List         */        System.out.println("--拆分有序list--");         userList.stream()                //默认hashmap 无序，需要设置有序map                .collect(Collectors.groupingBy(User::getAreaCode, LinkedHashMap::new, Collectors.toList()))                .values().stream().collect(Collectors.toList()).forEach(System.out::println);    }    private static void testZhao(Boolean isZhao, List<User> list) {        if (isZhao) {            list.stream().forEach(a -> {                System.out.println("赵氏精英");            });        } else {            list.stream().forEach(a -> {                System.out.println("非赵氏精英");            });        }    }    static <T> Predicate<T> distinctByKey1(Function<? super T, ?> keyExtractor) {        Map<Object, Boolean> seen = new ConcurrentHashMap<>();        return t -> seen.putIfAbsent(keyExtractor.apply(t), Boolean.TRUE) == null;    }