百度360必应搜狗淘宝本站头条
当前位置:网站首页 > IT知识 > 正文

Java 8中的这些小知识你知道多少?( Stream )

liuian 2025-01-09 14:25 21 浏览

前言

上篇只是简单的动手操作操作了流(stream),那 stream 到底是什么呢?

官方的简短定义:“从支持数据处理操作的源生成的元素序列

分成三部分:

  • 元素序列:你可以简单将它类比于一样,不过集合说的是数据的集合,而 stream 重点在于表达计算。如我们之前说到的 filter、map、sorted、limit等等
  • :昨天我提到,如果了解过 Liunx 管道命令的朋友们,会知道,Liunx 的管道命令中的前一条命令的结果(输出流)就是执行下一条命令的输入流。 stream流其实也是类似的,每次执行完一个 filter、sorted 等等它们的返回值也是 stream 流,然后作为下一个操作的输入流,这种。
  • 数据处理:这里说的处理,就是那些filter、map、sorted、limit等。

你可以把它理解为概念上或是形式上的数据结构,而不是具体的。

只能遍历的一次 Stream

Stream 流和 迭代器一样,它只能够迭代一次

当它遍历完的时候,我们就称它已经消费完了。如果还想重新执行操作,那么就只能从原来的地方再获取一个流啦。

 /**
      * 图个乐子
      */
 public static List<String> list = Arrays.asList("医医","一一","花花","菡菡","春春","宁姐","...");
 
 public static void main(String[] args) {
     Stream<String> stream = list.stream();
     stream.forEach(System.out::println);
     stream.forEach(System.out::println);
 }
复制代码

当执行第二句stream.forEach(System.out::println);时,会爆出如下异常:

 Exception in thread "main" java.lang.IllegalStateException: stream has already been operated upon or closed
     at java.util.stream.AbstractPipeline.sourceStageSpliterator(AbstractPipeline.java:279)
     at java.util.stream.ReferencePipeline$Head.forEach(ReferencePipeline.java:580)
     at com.nzc.stream02.Stream02Demo.main(Stream02Demo.java:25)
复制代码

stream has already been operated upon or closed :流已经被操作完或者关闭啦~

那么为什么流只能遍历一次呢?

我的回答肯定是 Java 中的设计是如此。

我们先来回忆一下我昨天没提到的一个知识点:

随便举一个例子,然后我们将 filter、map、limit、collect 都使用上。

 List<Student> students = new ArrayList<>();
 ?
 students.add(new Student("学生A", "大学1", 18, 98.0));
 students.add(new Student("学生A", "大学1", 18, 91.0));
 students.add(new Student("学生A", "大学1", 18, 90.0));
 students.add(new Student("学生A", "大学1", 18, 76.0));
 students.add(new Student("学生B", "大学1", 18, 91.0));
 students.add(new Student("学生C", "大学1", 19, 65.0));
 students.add(new Student("学生D", "大学2", 20, 80.0));
 students.add(new Student("学生E", "大学2", 21, 78.0));
 students.add(new Student("学生F", "大学2", 20, 67.0));
 students.add(new Student("学生G", "大学3", 22, 87.0));
 students.add(new Student("学生H", "大学3", 23, 79.0));
 students.add(new Student("学生I", "大学3", 19, 92.0));
 students.add(new Student("学生J", "大学4", 20, 84.0));
 List<String> collect = students.stream().filter(student -> student.getAge() > 20).map(student -> student.getName()).limit(3).collect(Collectors.toList());
复制代码

昨天我没有具体说明这几步是如何执行的

画张图来简要的说明一下:

filter, 根据条件筛选掉一些元素

map,将元素转换成其他的形式

limit,将流进行截断,只获取其中的一部分

collect,这里主要就是将流转换成其他的集合对象,这一步也是流的终端操作,之后也会聊到。

在这里你可以看到Java 8中的 stream 的设计,就是只能遍历一次,并且当执行完终端操作的时候,流也是已经关闭或者说是消费完了。

流操作

上面刚刚提到了终端操作,这也是一个小小的知识点。

Stream 的api提供了不少方法,诸如 filter、sotred、limit、map、collect等。

其中 filter、sotred、limit、map 它们的返回结果仍然是一个stream 流,这些操作,我们称之为中间操作。并且它们之间的连接可以形成一个流水线任务

而 collect 则是一个终端操作,它会触发并执行流水线任务,最终关闭它

中间操作

就是上面说的 filter、map等等,但是需要注意的是,如果流水线上没有一个终端操作,那么你写的filter、map什么的,并不会执行任何处理。

通过一个简单的案例,来看一看stream流中的lambda的函数的执行流程。

     static List<Student> students = new ArrayList<>();
 ?
     static {
         students.add(new Student("学生A", "大学1", 18, 98.0));
         students.add(new Student("学生A", "大学1", 18, 91.0));
         students.add(new Student("学生A", "大学1", 18, 90.0));
         students.add(new Student("学生A", "大学1", 18, 76.0));
         students.add(new Student("学生B", "大学1", 18, 91.0));
         students.add(new Student("学生C", "大学1", 19, 65.0));
         students.add(new Student("学生D", "大学2", 20, 80.0));
         students.add(new Student("学生E", "大学2", 21, 78.0));
         students.add(new Student("学生F", "大学2", 20, 67.0));
         students.add(new Student("学生G", "大学3", 22, 87.0));
         students.add(new Student("学生H", "大学3", 23, 79.0));
         students.add(new Student("学生I", "大学3", 19, 92.0));
         students.add(new Student("学生J", "大学4", 20, 84.0));
     }
复制代码
 public static void main(String[] args) {
     List<String> collect = students.stream().filter(student -> {
         System.out.println("filter==>" + student.getName() + ":" + student.getAge());
         return student.getAge() > 20;
     }).map(student -> {
         System.out.println("map==>" + student.getName() + ":" + student.getAge());
         return student.getName();
     }).collect(Collectors.toList());
 ?
 }
复制代码

输出:

 filter==>学生A:18
 map==>学生A:18
 filter==>学生A:18
 map==>学生A:18
 filter==>学生A:18
 map==>学生A:18
 filter==>学生A:18
 map==>学生A:18
 filter==>学生B:18
 map==>学生B:18
 filter==>学生C:19
 map==>学生C:19
 filter==>学生D:20
 filter==>学生E:21
 filter==>学生F:20
 filter==>学生G:22
 filter==>学生H:23
 filter==>学生I:19
 map==>学生I:19
 filter==>学生J:20
复制代码

也许到这里还看的不明显,我们再加上一个 limit(3),来看一下这次会如何输出

 List<String> collect = students.stream().filter(student -> {
     System.out.println("filter==>" + student.getName() + ":" + student.getAge());
     return student.getAge() < 20;
 }).map(student -> {
     System.out.println("map==>" + student.getName() + ":" + student.getAge());
     return student.getName();
 }).limit(3).collect(Collectors.toList());
 ?
 System.out.println(collect);
复制代码

输出结果:

 filter==>学生A:18
 map==>学生A:18
 filter==>学生A:18
 map==>学生A:18
 filter==>学生A:18
 map==>学生A:18
 [学生A, 学生A, 学生A]
复制代码

1、实际上这里利用到的 limit(n) 就是俗称的短路技巧,像我们刚学 &&、| | 语法时一样,如果&&条件为false,则会短路,不执行&& 之后的表达式,这里的 limit 你可以看作是 || 的表达

Stream 流在内部迭代中主动帮我们进行了优化。

2、另外看似 filter 和 map 是两个独立的函数,但实际上他们都是在一次遍历中所进行的。这一点从输出中也可看出。

终端操作

终端操作,就是触发并执行流水线任务,最终关闭流的操作

像之前写的collect(Collectors.toList())forEach(System.out::println) 都是终端操作。

终端操作其结果返回的都是流的值,collect返回各种各样的集合啦,

forEach 返回的就是 void 值。

中间操作

操 作

类型

结果

操作参数


filter

中间

Stream

Predicate

T -> boolean

map

中间

Stream

Stream Function

T -> R

limit

中间

Stream



sorted

中间

Stream

Comparator

(T, T) -> int

distinct

中间

Stream



终端操作

操 作

类 型

目 的

forEach

终端

消费流中的每个元素并对其应用 Lambda。这一操作返回 void

count

终端

返回流中元素的个数。这一操作返回 long

collect

终端

把流归约成一个集合,比如 List、Map 甚至是 Integer。

相关推荐

2023年最新微信小程序抓包教程(微信小程序 抓包)

声明:本公众号大部分文章来自作者日常学习笔记,部分文章经作者授权及其他公众号白名单转载。未经授权严禁转载。如需转载,请联系开百。请不要利用文章中的相关技术从事非法测试。由此产生的任何不良后果与文...

测试人员必看的软件测试面试文档(软件测试面试怎么说)

前言又到了毕业季,我们将会迎来许多需要面试的小伙伴,在这里呢笔者给从事软件测试的小伙伴准备了一份顶级的面试文档。1、什么是bug?bug由哪些字段(要素)组成?1)将在电脑系统或程序中,隐藏着的...

复活,视频号一键下载,有手就会,长期更新(2023-12-21)

视频号下载的话题,也算是流量密码了。但也是比较麻烦的问题,频频失效不说,使用方法也难以入手。今天,奶酪就来讲讲视频号下载的新方案,更关键的是,它们有手就会有用,最后一个方法万能。实测2023-12-...

新款HTTP代理抓包工具Proxyman(界面美观、功能强大)

不论是普通的前后端开发人员,还是做爬虫、逆向的爬虫工程师和安全逆向工程,必不可少会使用的一种工具就是HTTP抓包工具。说到抓包工具,脱口而出的肯定是浏览器F12开发者调试界面、Charles(青花瓷)...

使用Charles工具对手机进行HTTPS抓包

本次用到的工具:Charles、雷电模拟器。比较常用的抓包工具有fiddler和Charles,今天讲Charles如何对手机端的HTTS包进行抓包。fiddler抓包工具不做讲解,网上有很多fidd...

苹果手机下载 TikTok 旧版本安装包教程

目前苹果手机能在国内免拔卡使用的TikTok版本只有21.1.0版本,而AppStore是高于21.1.0版本,本次教程就是解决如何下载TikTok旧版本安装包。前期准备准备美区...

【0基础学爬虫】爬虫基础之抓包工具的使用

大数据时代,各行各业对数据采集的需求日益增多,网络爬虫的运用也更为广泛,越来越多的人开始学习网络爬虫这项技术,K哥爬虫此前已经推出不少爬虫进阶、逆向相关文章,为实现从易到难全方位覆盖,特设【0基础学爬...

防止应用调试分析IP被扫描加固实战教程

防止应用调试分析IP被扫描加固实战教程一、概述在当今数字化时代,应用程序的安全性已成为开发者关注的焦点。特别是在应用调试过程中,保护应用的网络安全显得尤为重要。为了防止应用调试过程中IP被扫描和潜在的...

一文了解 Telerik Test Studio 测试神器

1.简介TelerikTestStudio(以下称TestStudio)是一个易于使用的自动化测试工具,可用于Web、WPF应用的界面功能测试,也可以用于API测试,以及负载和性能测试。Te...

HLS实战之Wireshark抓包分析(wireshark抓包总结)

0.引言Wireshark(前称Ethereal)是一个网络封包分析软件。网络封包分析软件的功能是撷取网络封包,并尽可能显示出最为详细的网络封包资料。Wireshark使用WinPCAP作为接口,直接...

信息安全之HTTPS协议详解(加密方式、证书原理、中间人攻击 )

HTTPS协议详解(加密方式、证书原理、中间人攻击)HTTPS协议的加密方式有哪些?HTTPS证书的原理是什么?如何防止中间人攻击?一:HTTPS基本介绍:1.HTTPS是什么:HTTPS也是一个...

Fiddler 怎么抓取手机APP:抖音、小程序、小红书数据接口

使用Fiddler抓取移动应用程序(APP)的数据接口需要进行以下步骤:首先,确保手机与计算机连接在同一网络下。在计算机上安装Fiddler工具,并打开它。将手机的代理设置为Fiddler代理。具体方...

python爬虫教程:教你通过 Fiddler 进行手机抓包

今天要说说怎么在我们的手机抓包有时候我们想对请求的数据或者响应的数据进行篡改怎么做呢?我们经常在用的手机手机里面的数据怎么对它抓包呢?那么...接下来就是学习python的正确姿势我们要用到一款强...

Fiddler入门教程全家桶,建议收藏

学习Fiddler工具之前,我们先了解一下Fiddler工具的特点,Fiddler能做什么?如何使用Fidder捕获数据包、修改请求、模拟客户端向服务端发送请求、实施越权的安全性测试等相关知识。本章节...

fiddler如何抓取https请求实现手机抓包(100%成功解决)

一、HTTP协议和HTTPS协议。(1)HTTPS协议=HTTP协议+SSL协议,默认端口:443(2)HTTP协议(HyperTextTransferProtocol):超文本传输协议。默认...