Stream实践总结

文章目录

foreach
- 使用 forEach操作集合每个元素对象
- - 操作集合元素，方法体只有一行代码
  - 操作集合元素，有方法体
filter
- 统计集合中符合特定条件的数量
max和min
- 获取 String 集合中最长的元素
- 获取 Integer 集合中的最大值
- 对象类型的比较
map/flatMap
- 英文字符串数组的元素全部改为大写
- flatMap将两个字符数组合并成一个新的字符数组
reduce
- reduce进行求和、求乘积的方式
统计(count/averaging)
分组(partitioningBy/groupingBy)
- 根据员工的level进行分组
接合(joining)
- 将员工列表的姓名使用特定符号拼接成字符串
排序(sorted)
- 根据工资倒序排列

foreach

使用 forEach操作集合每个元素对象

dataVoList.stream().forEach();可以简化为dataVoList.forEach

操作集合元素，方法体只有一行代码

        List<DataVo> dataVoList = DataVo.dataVoList;//forEach操作dataVoList.forEach(p-> p.setDesc("描述信息"));//打印输出dataVoList.forEach(System.out::println);

操作集合元素，有方法体

        List<DataVo> dataVoList = DataVo.dataVoList;//forEach操作dataVoList.forEach(p->{p.setDesc("描述信息");p.setCreateTime(new Date());});//打印输出dataVoList.forEach(System.out::println);

filter

统计集合中符合特定条件的数量

计算 Integer 集合中大于 6 的元素的个数

  /**** 统计集合中符合特定条件的数量* 1：过滤条件* 2：完成统计计数**/@Testpublic  void test6(){//计算 Integer 集合中大于 6 的元素的个数。List<Integer> list = Arrays.asList(7, 6, 4, 8, 2, 11, 9);long count = list.stream().filter(p -> p > 6).count();System.out.println(count);}

max和min

获取 String 集合中最长的元素

  /*** 获取 String 集合中最长的元素*/@Testpublic void test3() {List<String> list = Arrays.asList("111", "222", "333", "4234224324", "5435435");Optional<String> max = list.stream().max(Comparator.comparing(String::length));System.out.println(max);}

获取 Integer 集合中的最大值

    /*** 获取 Integer 集合中的最大值**/@Testpublic  void test4(){List<Integer> list = Arrays.asList(2, 22,3443,666,111,-2);Optional<Integer> max = list.stream().max(Comparator.comparingInt(Integer::intValue));System.out.println(max);}

对象类型的比较

    /*** 对象类型的比较* 【示例】* 1：首先根据工资进行比较，返回最高的那个* 2：如果工资相同，在根据职级比较，俩个条件都是返回最高那个**/@Testpublic  void test5(){List<Emp> empList=new ArrayList<>(3);empList.add(new Emp("张三",6500d,3));empList.add(new Emp("李斯特",7200d,1));empList.add(new Emp("李四",6000d,3));empList.add(new Emp("王五",7200d,3));//多个条件可以使用thenComparingXXX并列使用Optional<Emp> max = empList.stream().max(Comparator.comparingDouble(Emp::getSalary).thenComparingDouble(Emp::getLevel));System.out.println(max);}@Data@AllArgsConstructorclass  Emp{String name;Double salary;int level;}

map/flatMap

映射，可以将一个流的元素按照一定的映射规则映射到另一个流中。分为 map 和 flatMap：
map：接收一个函数作为参数，该函数会被应用到每个元素上，并将其映射成一个新的元素。

英文字符串数组的元素全部改为大写

    /*** 将字符串集合中的字符转换为大写字符*/@Testpublic  void test7(){List<String> list = Arrays.asList("aaa", "bbb", "rrer", "ewew", "sdsds");List<String> collect = list.stream().map(String::toUpperCase).collect(Collectors.toList());System.out.println(collect);}

flatMap将两个字符数组合并成一个新的字符数组

flatMap：接收一个函数作为参数，将流中的每个值都换成另一个流，然后把所有流连接成一个流。

    @Testpublic  void test8(){List<String> list = Arrays.asList("a,b,c,d", "1,2,3,4");List<String> listNew = list.stream().flatMap(s -> {// 将每个元素转换成一个streamString[] split = s.split(",");return Arrays.stream(split);}).collect(Collectors.toList());System.out.println(listNew);}

reduce

归约(reduce)
归约，也称缩减，顾名思义，是把一个流缩减成一个值，能实现对集合求和、求乘积和求最值操作。

reduce进行求和、求乘积的方式

    /*** reduce进行求和、求乘积的方式*/@Testpublic  void test9(){List<Integer> list = Arrays.asList(1, 3, 5, 7, 9, 15);// 求和方式1Optional<Integer> sum = list.stream().reduce((x, y) -> x + y);// 求和方式2Optional<Integer> sum2 = list.stream().reduce(Integer::sum);// 求和方式Integer sum3 = list.stream().reduce(0, Integer::sum);// 求乘积Optional<Integer> product = list.stream().reduce((x, y) -> x * y);// 求最大值方式1Optional<Integer> max = list.stream().reduce((x, y) -> x > y ? x : y);// 求最大值写法2Integer max2 = list.stream().reduce(1, Integer::max);}

统计(count/averaging)

Collectors 提供了一系列用于数据统计的静态方法：

计数：count
平均值：averagingInt、averagingLong、averagingDouble
最值：maxBy、minBy
求和：summingInt、summingLong、summingDouble
统计以上所有：summarizingInt、summarizingLong、summarizingDouble

    @Testpublic  void test10(){List<Emp> empList=new ArrayList<>(3);empList.add(new Emp("张三",6500d,3));empList.add(new Emp("李斯特",7200d,1));empList.add(new Emp("李四",6000d,3));empList.add(new Emp("王五",7200d,3));// 求总数long count1 = empList.stream().collect(Collectors.counting());//简写long count2 = empList.stream().count();// 求平均工资 Double average = empList.stream().collect(Collectors.averagingDouble(Emp::getSalary)); // 求最高工资 Optional<Double> max = empList.stream().map(Emp::getSalary).collect(Collectors.maxBy(Double::compare));// 求工资之和 Double sum1 = empList.stream().collect(Collectors.summingDouble(Emp::getSalary)); //简写Double sum2 = empList.stream().mapToDouble(Emp::getSalary).sum(); // 一次性统计所有信息DoubleSummaryStatistics collect = empList.stream().collect(Collectors.summarizingDouble(Emp::getSalary));}

分组(partitioningBy/groupingBy)

分区：将 stream 按条件分为两个 Map，比如员工按薪资是否高于 8000 分为两部分。

分组：将集合分为多个 Map，比如员工按性别分组。有单级分组和多级分组。

根据员工的level进行分组

    /*** 分组(partitioningBy/groupingBy)* 根据员工的level进行分组*/@Testpublic  void test11(){List<Emp> empList=new ArrayList<>(3);empList.add(new Emp("张三",6500d,3));empList.add(new Emp("李斯特",7200d,1));empList.add(new Emp("李四",6000d,1));empList.add(new Emp("王五",7200d,3));Map<Integer, List<Emp>> collect = empList.stream().collect(Collectors.groupingBy(Emp::getLevel));for (Map.Entry<Integer, List<Emp>> integerListEntry : collect.entrySet()) {System.out.println(integerListEntry);}}

接合(joining)

joining 可以将 stream 中的元素用特定的连接符（没有的话，则直接连接）连接成一个字符串。

将员工列表的姓名使用特定符号拼接成字符串

    /*** 接合(joining)* 将员工列表的姓名使用特定符号拼接成字符串*/@Testpublic  void test12(){List<Emp> empList=new ArrayList<>(3);empList.add(new Emp("张三",6500d,3));empList.add(new Emp("李斯特",7200d,1));empList.add(new Emp("李四",6000d,1));empList.add(new Emp("王五",7200d,3));String collect = empList.stream().map(p -> p.getName()).collect(Collectors.joining(","));System.out.println(collect);}

排序(sorted)

sorted，中间操作。有两种排序：

sorted()：自然排序，流中元素需实现 Comparable 接口
sorted(Comparator com)：Comparator 排序器自定义排序

根据工资倒序排列

    @Testpublic  void test12(){List<Emp> empList=new ArrayList<>(3);empList.add(new Emp("张三",6500d,3));empList.add(new Emp("李斯特",7300d,1));empList.add(new Emp("李四",6000d,1));empList.add(new Emp("王五",7200d,3));//根据工资倒序排列List<Emp> collect = empList.stream().sorted((o1, o2) -> {//逆序只需要Double.compare翻转顺序即可return Double.compare(o2.getSalary(), o1.getSalary());}).collect(Collectors.toList());System.out.println(collect);}