Java 基础入门 | 第二十一章 Java stream操作

简介: 1、什么是stream流 stream,中文翻译是流的意思。那么是代码程序中的stream流呢?stream流是从支持数据处理操作的源生成的元素序列,源可以是数组、文件、集合、函数。stream流不是集合元素,它不是数据结构并不保

 1、什么是stream流

 stream,中文翻译是流的意思。那么是代码程序中的stream流呢?stream流是从支持数据处理操作的源生成的元素序列,源可以是数组、文件、集合、函数。stream流不是集合元素,它不是数据结构并不保存数据,它的主要目的在于计算。

   Java开发中经常会遇到不方便使用数据库但又要结构化数据计算的情况。在很长一段时间里,JAVA没有提供类库去处理这种情况,即使排序、分组这类基本计算都要开发者自己从底层开始硬编码,正常的业务逻辑就更难实现了。直到JAVA8推出了Stream类库,库外结构化数据计算的难题终于得以初步解决。

2、如何生成stream流

生成stream流的方式主要有一下五种

2.1、通过集合生成,应用中最常用的一种

List<Integer> integerList = Arrays.asList(1, 2, 3, 4, 5, 6);
Stream<Integer> stream = integerList.stream();

image.gif

2.2、通过数组生成

int[] intArr = {1, 2, 3, 4, 5, 6};
IntStream stream = Arrays.stream(intArr);

image.gif

通过Arrays.stream方法生成的stream流,并且该方法生成的流是数值流【即IntStream】而不是 Stream。补充一点使用数值流可以避免计算过程中拆箱装箱,提高性能。

值得回顾的是,stream以及IntStream、LongStream和DoubleStream 都是java.util.stream 包下的类,主要作用在于计算。而之前的java InputStream、OutputStream等都是java io包下的类,主要作用在于读取和写入。

Stream API提供了mapToInt、mapToDouble、mapToLong三种方式将对象流【即Stream 】转换成对应的数值流,同时提供了boxed方法将数值流转换为对象流.

2.3、通过值生成

Stream<Integer> stream = Stream.of(1, 2, 3, 4, 5, 6);

image.gif

通过Stream的of方法生成流,通过Stream的empty方法可以生成一个空流.

2.4、通过文件生成

Stream<String> lines = Files.lines(Paths.get("data.txt"), Charset.defaultCharset());

image.gif

通过Files.line方法得到一个流,并且得到的每个流是给定文件中的一行.

2.5、通过函数生成

iterator

Stream<Integer> stream = Stream.iterate(0, n -> n + 2).limit(5);

image.gif

iterate方法接受两个参数,第一个为初始化值,第二个为进行的函数操作,因为iterator生成的流为无限流,通过limit方法对流进行了截断,只生成5个偶数。

generator

Stream<Double> stream = Stream.generate(Math::random).limit(5);

image.gif

generate方法接受一个参数,方法参数类型为Supplier ,由它为流提供值。generate生成的流也是无限流,因此通过limit对流进行了截断。

3.流的使用

image.gif编辑

上图列出了stream主要流操作,我们可以看到,其实流操作可以类比我们的sql语句,如filter就类似于sql的where语句,我们就知道filter是对流进行过滤的,传入了一个Predicate断言接口,过滤掉断言为false的数据。相比一起的循环迭代,移除不符合的数据,是不是更加方便。下面我们来详细说说。

filter 筛选

通过使用filter方法进行条件筛选,filter的方法参数为一个条件(过滤保留函数返回值为 true 的元素)。

List<Integer> list= Arrays.asList(1, 2, 3, 4, 5, 6);
Stream<Integer> stream = list.stream().filter(i -> i > 3);

image.gif

如果元素是对象的话,过滤掉小于18岁的未成年用户

List<User> list= Arrays.asList(user1, user2, user3, user4, user5, user6);
Stream<User> stream = list.stream().filter(e -> e.getAge()>=18);
//流转化为list
list=stream.collect(Collectors.toList());

image.gif

map 映射

通过map函数,可以对流内的元素进行操作,下面是将user对象的集合转换 username 用户名的集合

List<User> list= Arrays.asList(user1, user2, user3, user4, user5, user6);
List<String> userNames=list.stream().map(User::getUsername).collect(Collectors.toList());

image.gif

distinct 去重

List<Integer> list= Arrays.asList(1, 1, 2, 3, 4, 5);
Stream<Integer> stream = list.stream().distinct();

image.gif

limit 返回指定流个数

List<Integer> list= Arrays.asList(1, 1, 2, 3, 4, 5,6);
Stream<Integer> stream = list.stream().limit(5);

image.gif

allMatch 匹配所有元素

List<Integer> list= Arrays.asList(1, 2, 3, 4, 5);
if (list.stream().allMatch(i -> i%2==0)) {
    System.out.println("所有元素值都是偶数");
} else {
    System.out.println("有元素值不是偶数");
}

image.gif

anyMatch匹配其中一个

List<Integer> list= Arrays.asList(1, 2, 3, 4, 5);
if (list.stream().anyMatch(i -> i%2==0)) {
  System.out.println("所有数据中有值是偶数");
} else {
   System.out.println("没有一个是偶数的");  
}

image.gif

noneMatch全部不匹配

List<Integer> list= Arrays.asList(1, 2, 3, 4, 5);
if (list.stream().noneMatch(i -> i%2==0)) {
  System.out.println("没有一个是偶数的");
} else {
   System.out.println("数据中有是偶数的");  
}

image.gif

count 统计流中元素个数

list集合中元素值大于3的个数

List<Integer> list= Arrays.asList(1, 2, 3, 4, 5);
Long num= list.stream().filter(i -> i > 3).count();

image.gif

findFirst 查找第一个

输出list集合中大于3的第一个元素

List<Integer> list= Arrays.asList(1, 2, 3, 4, 5);
Optional<Integer> result = list.stream().filter(i -> i > 3).findFirst();
//如果元素不存在输出-1
System.out.println(result.orElse(-1));

image.gif

findAny 随机查找一个

随机输出list集合中的元素

List<Integer> list= Arrays.asList(1, 2, 3, 4, 5);
Optional<Integer> result = list.stream().findAny();
System.out.println(result.get());

image.gif

reduce 归纳

求list中元素的值的总和

List<Integer> list= Arrays.asList(1, 2, 3, 4, 5);
int sum = list.stream().reduce(0, Integer::sum);

image.gif

求最小值和最大值

List<Integer> list= Arrays.asList(1, 2, 3, 4, 5);
Optional<Integer> min = list.stream().reduce(Integer::min);
Optional<Integer> max = list.stream().reduce(Integer::max);

image.gif

查找最后一个元素

Object last=list.stream().reduce((first, second) -> second).orElse(null);

image.gif

min和max 函数

List<Integer> list= Arrays.asList(1, 2, 3, 4, 5);
Optional<Integer> min = list.stream().min(Comparator.comparing(Integer::intValue));
Optional<Integer> max = list.stream().max(Comparator.comparing(Integer::intValue));

image.gif

Skip 函数

查询最后一个函数

Object last=list.stream().skip(list.size() - 1).findFirst().orElse(null);

image.gif

Stream流中的常用方法skip:用于跳过元素

如果希望跳过前几个元素,可以使用skip方法获取一个截取之后的新流

如果流的当前长度大于n,则跳过前n个,否则会得到一个长度为0的空流

averagingxxx 求平均值

求所有元素值的平均值

List<Integer> list= Arrays.asList(1, 2, 3, 4, 5);
double ave = list.stream().collect(Collectors.averagingInt(Integer::intValue));

image.gif

foreach 遍历

List<Integer> list= Arrays.asList(1, 2, 3, 4, 5);
list.stream().forEach(System.out::println);
//简写
list.forEach(System.out::println);

image.gif

joining 拼接流中的元素

将所有元素用-拼接起来

List<Integer> list= Arrays.asList(1, 2, 3, 4, 5);
String result = list.stream().map(i->i.toString()).collect(Collectors.joining("-"));

image.gif

groupingBy 分组

根据用户性别分组

List<User> list= Arrays.asList(user1, user2, user3, user4, user5);
Map<Integer, List<User>> map= list.stream().collect(Collectors.groupingBy(User::getSex));

image.gif

partitioningBy 分区

partitioningBy是分区,结果也是map,但只有两组,分区是特殊的分组,它分类依据是true和false,所以返回的结果最多可以分为两组。

下面是求list集合小于3和大于等于3的分组

List<Integer> list= Arrays.asList(1, 2, 3, 4, 5);
Map<Boolean, List<Integer>> result = list.stream().collect(partitioningBy(i -> i < 3));

image.gif


相关文章
|
6天前
|
设计模式 Java 关系型数据库
【Java笔记+踩坑汇总】Java基础+JavaWeb+SSM+SpringBoot+SpringCloud+瑞吉外卖/谷粒商城/学成在线+设计模式+面试题汇总+性能调优/架构设计+源码解析
本文是“Java学习路线”专栏的导航文章,目标是为Java初学者和初中高级工程师提供一套完整的Java学习路线。
|
9天前
|
Java API C++
Java 8 Stream Api 中的 peek 操作
本文介绍了Java中`Stream`的`peek`操作,该操作通过`Consumer&lt;T&gt;`函数消费流中的每个元素,但不改变元素类型。文章详细解释了`Consumer&lt;T&gt;`接口及其使用场景,并通过示例代码展示了`peek`操作的应用。此外,还对比了`peek`与`map`的区别,帮助读者更好地理解这两种操作的不同用途。作者为码农小胖哥,原文发布于稀土掘金。
Java 8 Stream Api 中的 peek 操作
|
6天前
|
安全 Java API
【Java面试题汇总】Java基础篇——String+集合+泛型+IO+异常+反射(2023版)
String常量池、String、StringBuffer、Stringbuilder有什么区别、List与Set的区别、ArrayList和LinkedList的区别、HashMap底层原理、ConcurrentHashMap、HashMap和Hashtable的区别、泛型擦除、ABA问题、IO多路复用、BIO、NIO、O、异常处理机制、反射
【Java面试题汇总】Java基础篇——String+集合+泛型+IO+异常+反射(2023版)
|
6天前
|
缓存 安全 Java
【Java面试题汇总】Java基础篇——基础、修饰符和关键字(2023版)
Java的特点和优点,、Java 8的新特性、面向对象、基本数据类型和引用类型、自动拆装箱与自动装箱、==与equals()的区别、为什么重写equals()就要重写hashcode()、抽象类和接口的区别、重载和重写的区别、四种引用方式、wt()和sleep()的区别、java方法是值传递还是引用传递?访问修饰符、static、final、this和super、volatile的用法及原理
【Java面试题汇总】Java基础篇——基础、修饰符和关键字(2023版)
|
9天前
|
Java C# Swift
Java Stream中peek和map不为人知的秘密
本文通过一个Java Stream中的示例,探讨了`peek`方法在流式处理中的应用及其潜在问题。首先介绍了`peek`的基本定义与使用,并通过代码展示了其如何在流中对每个元素进行操作而不返回结果。接着讨论了`peek`作为中间操作的懒执行特性,强调了如果没有终端操作则不会执行的问题。文章指出,在某些情况下使用`peek`可能比`map`更简洁,但也需注意其懒执行带来的影响。
Java Stream中peek和map不为人知的秘密
|
19天前
|
Java
盘点java8 stream中隐藏的函数式接口
`shigen`是一位坚持更新文章的博客作者,记录成长历程,分享认知见解,留住感动瞬间。本文介绍了函数式接口的概念及其在Java中的应用,包括`Comparator`、`Runnable`、`Callable`等常见接口,并详细讲解了`Function`、`Predicate`、`Consumer`、`Supplier`和`Comparator`等函数式接口的使用方法及应用场景,展示了如何利用这些接口简化代码并提高编程效率。**个人IP:shigen**,与shigen一起,每天进步一点点!
29 0
盘点java8 stream中隐藏的函数式接口
|
20天前
|
算法 Java 开发者
Java 编程入门:从零到一的旅程
本文将带领读者开启Java编程之旅,从最基础的语法入手,逐步深入到面向对象的核心概念。通过实例代码演示,我们将一起探索如何定义类和对象、实现继承与多态,并解决常见的编程挑战。无论你是编程新手还是希望巩固基础的开发者,这篇文章都将为你提供有价值的指导和灵感。
|
8天前
|
Java 程序员
Java中的异常处理:从入门到精通
在Java编程的世界中,异常处理是保持程序稳定性和可靠性的关键。本文将通过一个独特的视角—把异常处理比作一场“捉迷藏”游戏—来探讨如何在Java中有效管理异常。我们将一起学习如何识别、捕捉以及处理可能出现的异常,确保你的程序即使在面对不可预见的错误时也能优雅地运行。准备好了吗?让我们开始这场寻找并解决Java异常的冒险吧!
|
20天前
|
Java 程序员 UED
Java 中的异常处理:从入门到精通
【8月更文挑战第31天】在Java编程的世界中,异常处理是保持应用稳定性的重要机制。本文将引导你理解异常的本质,学会如何使用try-catch语句来捕获和处理异常,并探索自定义异常类的魅力。我们将一起深入异常的世界,让你的代码更加健壮和用户友好。
|
20天前
|
Java 数据库连接 开发者
Java中的异常处理:从入门到精通
【8月更文挑战第31天】 在编程世界中,错误和异常就像是不请自来的客人,总是在不经意间打扰我们的程序运行。Java语言通过其异常处理机制,为开发者提供了一套优雅的“待客之道”。本文将带你走进Java异常处理的世界,从基础语法到高级技巧,再到最佳实践,让你的程序在面对意外时,也能从容不迫,优雅应对。