Java8中的Stream,让集合操作酸爽起来

2024-09-08 01:18

本文主要是介绍Java8中的Stream,让集合操作酸爽起来,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

简介

java8也出来好久了,接口默认方法,lambda表达式,函数式接口,Date API等特性还是有必要去了解一下。比如在项目中经常用到集合,遍历集合可以试下lambda表达式,经常还要对集合进行过滤和排序,Stream就派上用场了。用习惯了,不得不说真的很好用。

Stream作为java8的新特性,基于lambda表达式,是对集合对象功能的增强,它专注于对集合对象进行各种高效、便利的聚合操作或者大批量的数据操作,提高了编程效率和代码可读性。

Stream的原理:将要处理的元素看做一种流,流在管道中传输,并且可以在管道的节点上处理,包括过滤筛选、去重、排序、聚合等。元素流在管道中经过中间操作的处理,最后由最终操作得到前面处理的结果。

集合有两种方式生成流:

  • stream() − 为集合创建串行流

  • parallelStream() - 为集合创建并行流

 

上图中是Stream类的类结构图,里面包含了大部分的中间和终止操作。

中间操作主要有以下方法(此类型方法返回的都是Stream):map (mapToInt, flatMap 等)、 filter、 distinct、 sorted、 peek、 limit、 skip、 parallel、 sequential、 unordered

终止操作主要有以下方法:forEach、 forEachOrdered、 toArray、 reduce、 collect、 min、 max、 count、 anyMatch、 allMatch、 noneMatch、 findFirst、 findAny、 iterator

举例说明

首先为了说明Stream对对象集合的操作,新建一个Student类(学生类),覆写了equals()和hashCode()方法

public class Student {private Long id;private String name;private int age;private String address;public Student() {}public Student(Long id, String name, int age, String address) {this.id = id;this.name = name;this.age = age;this.address = address;}@Overridepublic String toString() {return "Student{" +"id=" + id +", name='" + name + '\'' +", age=" + age +", address='" + address + '\'' +'}';}@Overridepublic boolean equals(Object o) {if (this == o) return true;if (o == null || getClass() != o.getClass()) return false;Student student = (Student) o;return age == student.age &&Objects.equals(id, student.id) &&Objects.equals(name, student.name) &&Objects.equals(address, student.address);}@Overridepublic int hashCode() {return Objects.hash(id, name, age, address);}public Long getId() {return id;}public void setId(Long id) {this.id = id;}public String getName() {return name;}public void setName(String name) {this.name = name;}public int getAge() {return age;}public void setAge(int age) {this.age = age;}public String getAddress() {return address;}public void setAddress(String address) {this.address = address;}}

filter(筛选)

public static void main(String [] args) {Student s1 = new Student(1L, "肖战", 15, "浙江");Student s2 = new Student(2L, "王一博", 15, "湖北");Student s3 = new Student(3L, "杨紫", 17, "北京");Student s4 = new Student(4L, "李现", 17, "浙江");List<Student> students = new ArrayList<>();students.add(s1);students.add(s2);students.add(s3);students.add(s4);List<Student> streamStudents = testFilter(students);streamStudents.forEach(System.out::println);}/*** 集合的筛选* @param students* @return*/private static List<Student> testFilter(List<Student> students) {//筛选年龄大于15岁的学生
//        return students.stream().filter(s -> s.getAge()>15).collect(Collectors.toList());//筛选住在浙江省的学生return students.stream().filter(s ->"浙江".equals(s.getAddress())).collect(Collectors.toList());}

运行结果:

这里我们创建了四个学生,经过filter的筛选,筛选出地址是浙江的学生集合。

map(转换)

    public static void main(String [] args) {Student s1 = new Student(1L, "肖战", 15, "浙江");Student s2 = new Student(2L, "王一博", 15, "湖北");Student s3 = new Student(3L, "杨紫", 17, "北京");Student s4 = new Student(4L, "李现", 17, "浙江");List<Student> students = new ArrayList<>();students.add(s1);students.add(s2);students.add(s3);students.add(s4);testMap(students);}/*** 集合转换* @param students* @return*/private static void testMap(List<Student> students) {//在地址前面加上部分信息,只获取地址输出List<String> addresses = students.stream().map(s ->"住址:"+s.getAddress()).collect(Collectors.toList());addresses.forEach(a ->System.out.println(a));}

运行结果

map就是将对应的元素按照给定的方法进行转换。

distinct(去重)

    public static void main(String [] args) {testDistinct1();}/*** 集合去重(基本类型)*/private static void testDistinct1() {//简单字符串的去重List<String> list = Arrays.asList("111","222","333","111","222");list.stream().distinct().forEach(System.out::println);}

运行结果:

public static void main(String [] args) {testDistinct2();}/*** 集合去重(引用对象)*/private static void testDistinct2() {//引用对象的去重,引用对象要实现hashCode和equal方法,否则去重无效Student s1 = new Student(1L, "肖战", 15, "浙江");Student s2 = new Student(2L, "王一博", 15, "湖北");Student s3 = new Student(3L, "杨紫", 17, "北京");Student s4 = new Student(4L, "李现", 17, "浙江");Student s5 = new Student(1L, "肖战", 15, "浙江");List<Student> students = new ArrayList<>();students.add(s1);students.add(s2);students.add(s3);students.add(s4);students.add(s5);students.stream().distinct().forEach(System.out::println);}

运行结果:

可以看出,两个重复的“肖战”同学进行了去重,这不仅因为使用了distinct()方法,而且因为Student对象重写了equals和hashCode()方法,否则去重是无效的。

sorted(排序)

    public static void main(String [] args) {testSort1();}/*** 集合排序(默认排序)*/private static void testSort1() {List<String> list = Arrays.asList("333","222","111");list.stream().sorted().forEach(System.out::println);}

运行结果:

    public static void main(String [] args) {testSort2();}/*** 集合排序(指定排序规则)*/private static void testSort2() {Student s1 = new Student(1L, "肖战", 15, "浙江");Student s2 = new Student(2L, "王一博", 15, "湖北");Student s3 = new Student(3L, "杨紫", 17, "北京");Student s4 = new Student(4L, "李现", 17, "浙江");List<Student> students = new ArrayList<>();students.add(s1);students.add(s2);students.add(s3);students.add(s4);students.stream().sorted((stu1,stu2) ->Long.compare(stu2.getId(), stu1.getId())).sorted((stu1,stu2) -> Integer.compare(stu2.getAge(),stu1.getAge())).forEach(System.out::println);}

运行结果:

上面指定排序规则,先按照学生的id进行降序排序,再按照年龄进行降序排序

limit(限制返回个数)

    public static void main(String [] args) {testLimit();}/*** 集合limit,返回前几个元素*/private static void testLimit() {List<String> list = Arrays.asList("333","222","111");list.stream().limit(2).forEach(System.out::println);}

运行结果:

skip(删除元素)

    public static void main(String [] args) {testSkip();}/*** 集合skip,删除前n个元素*/private static void testSkip() {List<String> list = Arrays.asList("333","222","111");list.stream().skip(2).forEach(System.out::println);}

运行结果:

reduce(聚合)

    public static void main(String [] args) {testReduce();}/*** 集合reduce,将集合中每个元素聚合成一条数据*/private static void testReduce() {List<String> list = Arrays.asList("欢","迎","你");String appendStr = list.stream().reduce("北京",(a,b) -> a+b);System.out.println(appendStr);}

运行结果:

min(求最小值)

    public static void main(String [] args) {testMin();}/*** 求集合中元素的最小值*/private static void testMin() {Student s1 = new Student(1L, "肖战", 14, "浙江");Student s2 = new Student(2L, "王一博", 15, "湖北");Student s3 = new Student(3L, "杨紫", 17, "北京");Student s4 = new Student(4L, "李现", 17, "浙江");List<Student> students = new ArrayList<>();students.add(s1);students.add(s2);students.add(s3);students.add(s4);Student minS = students.stream().min((stu1,stu2) ->Integer.compare(stu1.getAge(),stu2.getAge())).get();System.out.println(minS.toString());}

运行结果:

上面是求所有学生中年龄最小的一个,max同理,求最大值。

anyMatch/allMatch/noneMatch(匹配)

    public static void main(String [] args) {testMatch();}private static void testMatch() {Student s1 = new Student(1L, "肖战", 15, "浙江");Student s2 = new Student(2L, "王一博", 15, "湖北");Student s3 = new Student(3L, "杨紫", 17, "北京");Student s4 = new Student(4L, "李现", 17, "浙江");List<Student> students = new ArrayList<>();students.add(s1);students.add(s2);students.add(s3);students.add(s4);Boolean anyMatch = students.stream().anyMatch(s ->"湖北".equals(s.getAddress()));if (anyMatch) {System.out.println("有湖北人");}Boolean allMatch = students.stream().allMatch(s -> s.getAge()>=15);if (allMatch) {System.out.println("所有学生都满15周岁");}Boolean noneMatch = students.stream().noneMatch(s -> "杨洋".equals(s.getName()));if (noneMatch) {System.out.println("没有叫杨洋的同学");}}

运行结果:

anyMatch:Stream 中任意一个元素符合传入的 predicate,返回 true

allMatch:Stream 中全部元素符合传入的 predicate,返回 true

noneMatch:Stream 中没有一个元素符合传入的 predicate,返回 true

总结

上面介绍了Stream常用的一些方法,虽然对集合的遍历和操作可以用以前常规的方式,但是当业务逻辑复杂的时候,你会发现代码量很多,可读性很差,明明一行代码解决的事情,你却写了好几行。试试lambda表达式,试试Stream,你会有不一样的体验。

这篇关于Java8中的Stream,让集合操作酸爽起来的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1146703

相关文章

Spring Security+JWT如何实现前后端分离权限控制

《SpringSecurity+JWT如何实现前后端分离权限控制》本篇将手把手教你用SpringSecurity+JWT搭建一套完整的登录认证与权限控制体系,具有很好的参考价值,希望对大家... 目录Spring Security+JWT实现前后端分离权限控制实战一、为什么要用 JWT?二、JWT 基本结构

java解析jwt中的payload的用法

《java解析jwt中的payload的用法》:本文主要介绍java解析jwt中的payload的用法,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录Java解析jwt中的payload1. 使用 jjwt 库步骤 1:添加依赖步骤 2:解析 JWT2. 使用 N

springboot项目如何开启https服务

《springboot项目如何开启https服务》:本文主要介绍springboot项目如何开启https服务方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录springboot项目开启https服务1. 生成SSL证书密钥库使用keytool生成自签名证书将

Java实现优雅日期处理的方案详解

《Java实现优雅日期处理的方案详解》在我们的日常工作中,需要经常处理各种格式,各种类似的的日期或者时间,下面我们就来看看如何使用java处理这样的日期问题吧,感兴趣的小伙伴可以跟随小编一起学习一下... 目录前言一、日期的坑1.1 日期格式化陷阱1.2 时区转换二、优雅方案的进阶之路2.1 线程安全重构2

Java中的JSONObject详解

《Java中的JSONObject详解》:本文主要介绍Java中的JSONObject详解,需要的朋友可以参考下... Java中的jsONObject详解一、引言在Java开发中,处理JSON数据是一种常见的需求。JSONObject是处理JSON对象的一个非常有用的类,它提供了一系列的API来操作J

SpringBoot多数据源配置完整指南

《SpringBoot多数据源配置完整指南》在复杂的企业应用中,经常需要连接多个数据库,SpringBoot提供了灵活的多数据源配置方式,以下是详细的实现方案,需要的朋友可以参考下... 目录一、基础多数据源配置1. 添加依赖2. 配置多个数据源3. 配置数据源Bean二、JPA多数据源配置1. 配置主数据

将Java程序打包成EXE文件的实现方式

《将Java程序打包成EXE文件的实现方式》:本文主要介绍将Java程序打包成EXE文件的实现方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录如何将Java程序编程打包成EXE文件1.准备Java程序2.生成JAR包3.选择并安装打包工具4.配置Launch4

SpringBoot内嵌Tomcat临时目录问题及解决

《SpringBoot内嵌Tomcat临时目录问题及解决》:本文主要介绍SpringBoot内嵌Tomcat临时目录问题及解决,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,... 目录SprinjavascriptgBoot内嵌Tomcat临时目录问题1.背景2.方案3.代码中配置t

SpringBoot使用GZIP压缩反回数据问题

《SpringBoot使用GZIP压缩反回数据问题》:本文主要介绍SpringBoot使用GZIP压缩反回数据问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录SpringBoot使用GZIP压缩反回数据1、初识gzip2、gzip是什么,可以干什么?3、Spr

Java程序进程起来了但是不打印日志的原因分析

《Java程序进程起来了但是不打印日志的原因分析》:本文主要介绍Java程序进程起来了但是不打印日志的原因分析,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录Java程序进程起来了但是不打印日志的原因1、日志配置问题2、日志文件权限问题3、日志文件路径问题4、程序