编程语言
首页 > 编程语言> > 【java8 Stream日常学习使用】

【java8 Stream日常学习使用】

作者:互联网

Stream学习 ——2022.05.31

简介

​ Java 8 是一个非常成功的版本,这个版本新增的Stream,配合同版本出现的Lambda ,给我们操作集合(Collection)提供了极大的便利。Stream流是JDK8新增的成员,允许以声明性方式处理数据集合,可以把Stream流看作是遍历数据集合的一个高级迭代器。Stream 是 Java8 中处理集合的关键抽象概念,,可以执行非常复杂的查找/筛选/过滤、排序、聚合和映射数据等操作。使用Stream API 对集合数据进行操作,就类似于使用 SQL 执行的数据库查询。也可以使用 Stream API 来并行执行操作。简而言之,Stream API 提供了一种高效且易于使用的处理数据的方式。

​ 但是要注意,虽然Stream api某种意义上可以代替sql,但是并不建议完全代替,因为当数据量过大或者访问压力 大的时候还是需要数据库这种专业的数据处理引擎去处理,stream api 只是让代码更简洁好看,所以我的建议是,对于操作数据量不大的集合需求可以用stream一试。

至于 lambda 表达式,也是代码简洁化的一种,可以和stream 一起学习:

常见的使用

​ 最常用创建的方式:通过 java.util.Collection.stream() 方法用集合创建流

测试用例:

Collectors.groupingBy 分组
 Map<String, List<Capcom>> collectMap = capList.stream().collect(Collectors.groupingBy(Capcom::getVersion));

PS:// Capcom::getVersion 即 capcom -> capcom.getVersion(),::也叫方法引用

​ 当然,不借助实体类直接拼接字段也可以:

排序stream().sorted()
 /**
         * 按照score进行排序
         * 1. 自定义升序
         * 2. 自定义降序
         * 3.多字段升序,score 升序,若相同则根据 c_num 继续判断
         */
        List<Capcom> ascOrder = new ArrayList();
        List<Capcom> descOrder = new ArrayList();
        List<Capcom> multOrder = new ArrayList();

        ascOrder = capList.stream().sorted(Comparator.comparing(Capcom::getScore)).collect(Collectors.toList());
        descOrder = capList.stream().sorted(Comparator.comparing(Capcom::getScore).reversed()).collect(Collectors.toList());
        multOrder = capList.stream().sorted(Comparator.comparing(Capcom::getScore).thenComparing(Capcom::getcNum)).collect(Collectors.toList());

MIN 和 MAX
// min 和 max,以max为例
List<Integer> list = Arrays.asList(3, 45, 675, 2, 5);
Optional<Integer> max = list.stream().max(Integer::compareTo);
// 自定义排序
Optional<Integer> max2 = list.stream().max(new Comparator<Integer>() {
    @Override
    public int compare(Integer o1, Integer o2) {
        return o1.compareTo(o2);
    }
});
System.out.println(max2);
//输出: Optional[675]
filter 筛选

条件筛选过滤;

reduce 规约

​ 规约,可将流缩减为一个值

       // reduce 规约,可将流缩减为一个值
        Optional<Long> reSum = capList.stream().map(Capcom::getCapId).reduce(Long::sum);
        Optional<Long> reMax = capList.stream().map(Capcom::getCapId).reduce(Long::max);

        Optional<BigDecimal> decimalSum = capList.stream().map(Capcom::getScore).reduce(BigDecimal::add);
        Optional<BigDecimal> decimalMax = capList.stream().map(Capcom::getScore).reduce(BigDecimal::max);
        System.out.println(" long sum: "+reSum + " long max :" + reMax + " decimal sum :" + decimalSum +" decimal max :" + decimalMax);
        // 输出:long sum: Optional[7028] long max :Optional[1007] decimal sum :Optional[600] decimal max :Optional[90]
toSet 和 toMap

数据汇总为Set或者Map;

        // toSet, toMap
        Set<String> numberSet = capList.stream().map(Capcom::getcNum).collect(Collectors.toSet());
        Map<String, Capcom> mapCollect = capList.stream().filter(x -> x.getCapId() < 1003).collect(Collectors.toMap(Capcom::getcNum, y -> y));
        System.out.println("编号合集 num Set:" +numberSet + "mapCollect :" + mapCollect);
        /**
         * 输出:
         * 编号合集 num Set:[0007, 0004, 0005, 0002, 0003, 0000, 0001]
         *        mapCollect :{0002=Capcom{capId=1002, cName='卡洛斯·奥利维拉', cNum='0002', version='1', score=83}, 
         *                    0001=Capcom{capId=1001, cName='吉尔.瓦伦蒂安', cNum='0001', version='1', score=87}}
         */

标签:Stream,stream,max,Capcom,日常,capList,Optional,java8
来源: https://www.cnblogs.com/dabuliu/p/16331311.html