感受lambda之美，推荐收藏，需要时查阅

小郝不负流年
小郝不负流年   + 关注
2021-03-29 23:28:44   阅读90   评论0

作者：9龙

来源：juejin.cn/post/6844903849753329678

一、引言 

java8最大的特性就是引入Lambda表达式，即函数式编程，可以将行为进行传递。总结就是：使用不可变值与函数，函数对不可变值进行处理，映射成另一个值。

二、java重要的函数式接口 

1、什么是函数式接口

函数接口是只有一个抽象方法的接口，用作 Lambda 表达式的类型。使用@FunctionalInterface注解修饰的类，编译器会检测该类是否只有一个抽象方法或接口，否则，会报错。可以有多个默认方法，静态方法。

1.1 java8自带的常用函数式接口。
函数接口抽象方法功能参数返回类型示例
Predicatetest(T t)判断真假Tboolean9龙的身高大于185cm吗？
Consumeraccept(T t)消费消息Tvoid输出一个值
FunctionR apply(T t)将T映射为R（转换功能）TR获得student对象的名字
SupplierT get()生产消息NoneT工厂方法
UnaryOperatorT apply(T t)一元操作TT逻辑非（!）
BinaryOperatorapply(T t, U u)二元操作(T，T)(T)求两个数的乘积（*）
public class Test {
    public static void main(String[] args) {
        Predicate predicate = x -> x > 185;
        Student student = new Student("9龙", 23, 175);
        System.out.println(
            "9龙的身高高于185吗？：" + predicate.test(student.getStature()));

        Consumer consumer = System.out::println;
        consumer.accept("命运由我不由天");

        Function function = Student::getName;
        String name = function.apply(student);
        System.out.println(name);

        Supplier supplier = 
            () -> Integer.valueOf(BigDecimal.TEN.toString());
        System.out.println(supplier.get());

        UnaryOperator unaryOperator = uglily -> !uglily;
        Boolean apply2 = unaryOperator.apply(true);
        System.out.println(apply2);

        BinaryOperator operator = (x, y) -> x * y;
        Integer integer = operator.apply(2, 3);
        System.out.println(integer);

        test(() -> "我是一个演示的函数式接口");
    }

    /**
     * 演示自定义函数式接口使用
     *
     * @param worker
     */
    public static void test(Worker worker) {
        String work = worker.work();
        System.out.println(work);
    }

    public interface Worker {
        String work();
    }
}
//9龙的身高高于185吗？：false
//命运由我不由天
//9龙
//10
//false
//6
//我是一个演示的函数式接口
复制代码

以上演示了lambda接口的使用及自定义一个函数式接口并使用。下面，我们看看java8将函数式接口封装到流中如何高效的帮助我们处理集合。

注意：Student::getName例子中这种编写lambda表达式的方式称为方法引用。格式为ClassNmae::methodName。是不是很神奇，java8就是这么迷人。

示例：本篇所有示例都基于以下三个类。OutstandingClass：班级；Student：学生；SpecialityEnum：特长。


1.2 惰性求值与及早求值

惰性求值：只描述Stream，操作的结果也是Stream，这样的操作称为惰性求值。惰性求值可以像建造者模式一样链式使用，最后再使用及早求值得到最终结果。

及早求值：得到最终的结果而不是Stream，这样的操作称为及早求值。

2、常用的流

2.1 collect(Collectors.toList())

将流转换为list。还有toSet()，toMap()等。及早求值。

public class TestCase {
    public static void main(String[] args) {
        List studentList = Stream.of(new Student("路飞", 22, 175),
                new Student("红发", 40, 180),
                new Student("白胡子", 50, 185)).collect(Collectors.toList());
        System.out.println(studentList);
    }
}
//输出结果
//[Student{name='路飞', age=22, stature=175, specialities=null}, 
//Student{name='红发', age=40, stature=180, specialities=null}, 
//Student{name='白胡子', age=50, stature=185, specialities=null}]
复制代码
2.2 filter

顾名思义，起过滤筛选的作用。内部就是Predicate接口。惰性求值。


比如我们筛选出出身高小于180的同学。

public class TestCase {
    public static void main(String[] args) {
        List students = new ArrayList<>(3);
        students.add(new Student("路飞", 22, 175));
        students.add(new Student("红发", 40, 180));
        students.add(new Student("白胡子", 50, 185));

        List list = students.stream()
            .filter(stu -> stu.getStature() < 180)
            .collect(Collectors.toList());
        System.out.println(list);
    }
}
//输出结果
//[Student{name='路飞', age=22, stature=175, specialities=null}]
复制代码
2.3 map

转换功能，内部就是Function接口。惰性求值


public class TestCase {
    public static void main(String[] args) {
        List students = new ArrayList<>(3);
        students.add(new Student("路飞", 22, 175));
        students.add(new Student("红发", 40, 180));
        students.add(new Student("白胡子", 50, 185));

        List names = students.stream().map(student -> student.getName())
                .collect(Collectors.toList());
        System.out.println(names);
    }
}
//输出结果
//[路飞, 红发, 白胡子]
复制代码

例子中将student对象转换为String对象，获取student的名字。

2.4 flatMap

将多个Stream合并为一个Stream。惰性求值


public class TestCase {
    public static void main(String[] args) {
        List students = new ArrayList<>(3);
        students.add(new Student("路飞", 22, 175));
        students.add(new Student("红发", 40, 180));
        students.add(new Student("白胡子", 50, 185));

        List studentList = Stream.of(students,
                asList(new Student("艾斯", 25, 183),
                        new Student("雷利", 48, 176)))
                .flatMap(students1 -> students1.stream()).collect(Collectors.toList());
        System.out.println(studentList);
    }
}
//输出结果
//[Student{name='路飞', age=22, stature=175, specialities=null}, 
//Student{name='红发', age=40, stature=180, specialities=null}, 
//Student{name='白胡子', age=50, stature=185, specialities=null}, 
//Student{name='艾斯', age=25, stature=183, specialities=null},
//Student{name='雷利', age=48, stature=176, specialities=null}]
复制代码

调用Stream.of的静态方法将两个list转换为Stream，再通过flatMap将两个流合并为一个。

2.5 max和min

我们经常会在集合中求最大或最小值，使用流就很方便。及早求值。

public class TestCase {
    public static void main(String[] args) {
        List students = new ArrayList<>(3);
        students.add(new Student("路飞", 22, 175));
        students.add(new Student("红发", 40, 180));
        students.add(new Student("白胡子", 50, 185));

        Optional max = students.stream()
            .max(Comparator.comparing(stu -> stu.getAge()));
        Optional min = students.stream()
            .min(Comparator.comparing(stu -> stu.getAge()));
        //判断是否有值
        if (max.isPresent()) {
            System.out.println(max.get());
        }
        if (min.isPresent()) {
            System.out.println(min.get());
        }
    }
}
//输出结果
//Student{name='白胡子', age=50, stature=185, specialities=null}
//Student{name='路飞', age=22, stature=175, specialities=null}
复制代码

max、min接收一个Comparator（例子中使用java8自带的静态函数，只需要传进需要比较值即可。）并且返回一个Optional对象，该对象是java8新增的类，专门为了防止null引发的空指针异常。可以使用max.isPresent()判断是否有值；可以使用max.orElse(new Student())，当值为null时就使用给定值；也可以使用max.orElseGet(() -> new Student());这需要传入一个Supplier的lambda表达式。

2.6 count

统计功能，一般都是结合filter使用，因为先筛选出我们需要的再统计即可。及早求值

public class TestCase {
    public static void main(String[] args) {
        List students = new ArrayList<>(3);
        students.add(new Student("路飞", 22, 175));
        students.add(new Student("红发", 40, 180));
        students.add(new Student("白胡子", 50, 185));

        long count = students.stream().filter(s1 -> s1.getAge() < 45).count();
        System.out.println("年龄小于45岁的人数是：" + count);
    }
}
//输出结果
//年龄小于45岁的人数是：2
复制代码
2.7 reduce

reduce 操作可以实现从一组值中生成一个值。在上述例子中用到的 count 、 min 和 max 方
法，因为常用而被纳入标准库中。事实上，这些方法都是 reduce 操作。及早求值。


public class TestCase {
    public static void main(String[] args) {
        Integer reduce = Stream.of(1, 2, 3, 4).reduce(0, (acc, x) -> acc+ x);
        System.out.println(reduce);
    }
}
//输出结果
//10
复制代码

我们看得reduce接收了一个初始值为0的累加器，依次取出值与累加器相加，最后累加器的值就是最终的结果。

三、高级集合类及收集器 

3.1 转换成值

收集器，一种通用的、从流生成复杂值的结构。只要将它传给 collect 方法，所有
的流就都可以使用它了。标准类库已经提供了一些有用的收集器，以下示例代码中的收集器都是从 java.util.stream.Collectors 类中静态导入的。

public class CollectorsTest {
    public static void main(String[] args) {
        List students1 = new ArrayList<>(3);
        students1.add(new Student("路飞", 23, 175));
        students1.add(new Student("红发", 40, 180));
        students1.add(new Student("白胡子", 50, 185));

        OutstandingClass ostClass1 = new OutstandingClass("一班", students1);
        //复制students1，并移除一个学生
        List students2 = new ArrayList<>(students1);
        students2.remove(1);
        OutstandingClass ostClass2 = new OutstandingClass("二班", students2);
        //将ostClass1、ostClass2转换为Stream
        Stream classStream = Stream.of(ostClass1, ostClass2);
        OutstandingClass outstandingClass = biggestGroup(classStream);
        System.out.println("人数最多的班级是：" + outstandingClass.getName());

        System.out.println("一班平均年龄是：" + averageNumberOfStudent(students1));
    }

    /**
     * 获取人数最多的班级
     */
    private static OutstandingClass biggestGroup(Stream outstandingClasses) {
        return outstandingClasses.collect(
                maxBy(comparing(ostClass -> ostClass.getStudents().size())))
                .orElseGet(OutstandingClass::new);
    }

    /**
     * 计算平均年龄
     */
    private static double averageNumberOfStudent(List students) {
        return students.stream().collect(averagingInt(Student::getAge));
    }
}
//输出结果
//人数最多的班级是：一班
//一班平均年龄是：37.666666666666664
复制代码

maxBy或者minBy就是求最大值与最小值。

3.2 转换成块

常用的流操作是将其分解成两个集合，Collectors.partitioningBy帮我们实现了，接收一个Predicate函数式接口。


将示例学生分为会唱歌与不会唱歌的两个集合。

public class PartitioningByTest {
    public static void main(String[] args) {
        //省略List students的初始化
        Map> listMap = students.stream().collect(
            Collectors.partitioningBy(student -> student.getSpecialities().
                                      contains(SpecialityEnum.SING)));
    }
}
复制代码

3.3 数据分组

数据分组是一种更自然的分割数据操作，与将数据分成 ture 和 false 两部分不同，可以使
用任意值对数据分组。Collectors.groupingBy接收一个Function做转换。


如图，我们使用groupingBy将根据进行分组为圆形一组，三角形一组，正方形一组。

例子：根据学生第一个特长进行分组

public class GroupingByTest {
    public static void main(String[] args) {
        //省略List students的初始化
         Map> listMap = 
             students.stream().collect(
             Collectors.groupingBy(student -> student.getSpecialities().get(0)));
    }
}
复制代码

Collectors.groupingBy与SQL 中的 group by 操作是一样的。

3.4 字符串拼接

如果将所有学生的名字拼接起来，怎么做呢？通常只能创建一个StringBuilder，循环拼接。使用Stream，使用Collectors.joining()简单容易。

public class JoiningTest {
    public static void main(String[] args) {
        List students = new ArrayList<>(3);
        students.add(new Student("路飞", 22, 175));
        students.add(new Student("红发", 40, 180));
        students.add(new Student("白胡子", 50, 185));

         String names = students.stream()
             .map(Student::getName).collect(Collectors.joining(",","[","]"));
        System.out.println(names);
    }
}
//输出结果
//[路飞,红发,白胡子]
复制代码

joining接收三个参数，第一个是分界符，第二个是前缀符，第三个是结束符。也可以不传入参数Collectors.joining()，这样就是直接拼接。

四、总结

本篇主要从实际使用讲述了常用的方法及流，使用java8可以很清晰表达你要做什么，代码也很简洁。本篇例子主要是为了讲解较为简单，大家可以去使用java8重构自己现有的代码，自行领会lambda的奥妙。本文说的Stream要组合使用才会发挥更大的功能，链式调用很迷人，根据自己的业务去做吧。

文章来源：https://juejin.cn/post/6844903849753329678
对我有用，我要     转载  
文章分类： Java  
所属标签： lambda  
本文来自灏识呈-博客-小郝不负流年，转载请注明出处 https://www.hoscen.cn/blog/hao/articles/249334171669889024.html
  • 0条评论
  • 只看作者
  • 按时间|按热度

  • 武汉市个人社保缴费证明网上打印操作流程

    阅读数101426
    由于本人多次涉及需要打印这个证明，而每次都会忘记入口，在网上各种搜索各种摸索很是浪费时间。故本次将操作流程整理记录下来，以备忘。同时也分享给大家。1、打开湖北政务服务网，地址：http://zwfw.hubei.gov.cn/s/index.html2、切换区域到“武汉市”3、在“特色服务”模块找到“(个人)武汉市社会保险公共服务平台”4、进入“(个人)武汉市社会保险公共服务平台”，登录账号密码<imgsrc="https://cdnstatic.hoscen.cn/blog/article/184053017752895488/img/497065960be44747825acb86a17483c1.png"style=

  • postman模拟http发送xml参数报文的POST请求

    阅读数28873
    如何使用postman模拟http发送xml参数报文的POST请求？1、postman工具通过安装软件或使用谷歌插件都可以，这里不再赘述。2、配置postman，选择POST，填写URL；切换到Headers，添加Content-Type:text/xml 3、切换到body，选择raw,XML,下方填写你的请求报文4、点击Send发送请求，如图可以看到响应状态、时间、结果等信息5、讲到这里就结束了，是不是学会了？快去试试吧！

  • 来源于javax.annotation包，这个注解@Generated有什么作用？

    阅读数26992
    java中的注解@Generated用来标注源代码中的某些东西是由某些工具生成的，而不是人写的。这个注解可以用于：包、类、注解类、方法、构造方法、变量、本地变量、方法参数。

  • 解决Spring boot单元测试报错：No tests were found

    阅读数23557
    解决办法：是idea的加载有问题，关闭IDEA,在工程的根目录下删除.idea文件，重新打开IDEA加载就好了。

  • Failed to load project configuration: cannot parse file F:/xx/.idea/modules.xml: ParseError at [row,col]:[1,1] Message: 文件提前结束。

    阅读数16168
    Failedtoloadprojectconfiguration:cannotparsefileF:/xx/.idea/modules.xml:ParseErrorat[row,col]:[1,1]Message:文件提前结束。解决办法：关闭idea,删掉这个文件，重新打开idea

  • 上传图片微服务网关报错：UT000054: The maximum size 1048576 for an individual file in a multipart request was exceeded

    阅读数12193
    上传图片微服务网关报错：UT000054:Themaximumsize1048576foranindividualfileinamultipartrequestwasexceeded原因：所用容器对文件的限制一般项目用的是spring 对spring参数进行配置即可spring:servlet:multipart:#MultipartPropertiesmax-request-size:10MB#总文件大小max-file-size:10MB#单个文件大小注意如果是nginx代理配置限制，报错信息里面会标记nginx。届时需要设置nginx在server_name下加上client_max_body_size20m;

  • Vue入门篇：（一）环境搭建、项目创建、项目运行、项目打包

    阅读数11824
    目录：1、安装node.js环境2、安装cnpm3、安装vue-cli脚手架构建工具4、用vue-cli构建项目5、安装项目所需的依赖6、项目运行7、项目打包1、安装node.js环境下载地址：https://nodejs.org/zh-cn/安装过程没有太多好说的，安装完成后 win+R打开命令行输入node -v , 如图，出现版本号说明安装成功。npm包管理器是集成在node中的 ， npm -v可以查看版本2、安装cnpm由于有些npm有些资源被屏蔽或者是国外资源的原因，经常会导致用npm安装依赖包的时

  • finalshell建立服务器内网其他IP端口的隧道

    阅读数11029
    建立服务器内网其他IP端口的隧道，可以将远程的服务映射到本地进行访问。finalshell配置隧道方法：

  • 解决Return code is: 400, ReasonPhrase: Repository does not allow updating assets: maven-releases.问题

    阅读数8888
    问题maven同一个版本号部署远程仓库，出现报错：Returncodeis: 400,ReasonPhrase:Repositorydoesnotallowupdatingassets:maven-releases. 解决maven在部署(deploy)时候抛的异常，存储库不允许更新资产，这个就是和私有maven库更新策略有关。具体设置步骤：1.访问私有库管理界面http://xxx.xxx.xxx.xxx:80812.登录管理员账号（默认：admin/admin123）3.进入设置界面->repository->repositories->maven-releases(自己需要部署的目标库)->setting->Deploymentpollcy(Allowredeploy)允许更新

  • 解决Could not reserve enough space for 2097152KB object heap

    阅读数7883
    控制台信息：Unabletostartthedaemonprocess.Thisproblemmightbecausedbyincorrectconfigurationofthedaemon.Forexample,anunrecognizedjvmoptionisused.PleaserefertotheUserManualchapteronthedaemonathttps://docs.gradle.org/6.3/userguide/gradle_daemon.htmlProcesscommandline:E:\DevelopTools\Java\OpenJDK8U-jdk_x86-32_windows_hotspot_8u282b08\jdk8u282-b08\bin\java.exe-XX:MaxHeapSize=1024m-Xms1024m-Xmx2048m-Dfile.encoding=UTF-8-Duser.country=CN-Duser.language=zh-Duser.variant-cpE:\DevelopTools\gradle-6.8.2-all\gradle_resp\wrapper\dists\gradle-6.3-bin\8tpu6egwsccjzp10c1jckl0rx\gradle-6.3\lib\gradle-launcher-6.3.jarorg.gradle.launcher.daemon.bootstrap.GradleDaemon6.3Pleasereadthefollowingprocessoutputtofindoutmore:-----------------------ErroroccurredduringinitializationofVMCouldnotreserveenoughspacefor2097152KBobjectheapPickedupJAVA_
推荐阅读