Java 8的Stream代码，你能看懂吗？

落日映苍穹つ 2021-09-30 22:44 227阅读 0赞

> 本文来源公众号：Hollis  本文作者：Hollis
> 
> 今天在读公司代码的时候，发现用了Java 8 Stream的特性，而且比较复杂(即便用了Stream也写了15行代码)。然后，我就看不懂了…(真菜！)
> 
> 记得我在之前写过一篇Optional的文章，回顾了一下又稍微能看懂一点了（[给女朋友讲解什么是Optional][Optional]）。而前几天正好mark住了Hollis大佬的Stream文章，阅读完感觉又顺畅了一些。这里给大家推荐一下，建议阅读。

以下为正文：

在Java中，集合和数组是我们经常会用到的数据结构，需要经常对他们做增、删、改、查、聚合、统计、过滤等操作。相比之下，关系型数据库中也同样有这些操作，但是在Java 8之前，集合和数组的处理并不是很便捷。

不过，这一问题在Java 8中得到了改善，Java 8 API添加了一个新的抽象称为流Stream，可以让你以一种声明的方式处理数据。本文就来介绍下如何使用Stream。特别说明一下，关于Stream的性能及原理不是本文的重点，如果大家感兴趣后面会出文章单独介绍。

***1***

**Stream介绍**

Stream 使用一种类似用 SQL 语句从数据库查询数据的直观方式来提供一种对 Java 集合运算和表达的高阶抽象。

Stream API可以极大提高Java程序员的生产力，让程序员写出高效率、干净、简洁的代码。

这种风格将要处理的元素集合看作一种流，流在管道中传输，并且可以在管道的节点上进行处理，比如筛选，排序，聚合等。

Stream有以下特性及优点：

*  无存储。Stream不是一种数据结构，它只是某种数据源的一个视图，数据源可以是一个数组，Java容器或I/O channel等。
 *  为函数式编程而生。对Stream的任何修改都不会修改背后的数据源，比如对Stream执行过滤操作并不会删除被过滤的元素，而是会产生一个不包含被过滤元素的新Stream。
 *  惰式执行。Stream上的操作并不会立即执行，只有等到用户真正需要结果的时候才会执行。
 *  可消费性。Stream只能被“消费”一次，一旦遍历过就会失效，就像容器的迭代器那样，想要再次遍历必须重新生成。

我们举一个例子，来看一下到底Stream可以做什么事情：

![640?wx\_fmt=jpeg][640_wx_fmt_jpeg]

上面的例子中，获取一些带颜色塑料球作为数据源，首先过滤掉红色的、把它们融化成随机的三角形。再过滤器并删除小的三角形。最后计算出剩余图形的周长。

如上图，对于流的处理，主要有三种关键性操作：分别是流的创建、中间操作（intermediate operation）以及最终操作(terminal operation)。

***2***

**Stream的创建**

在Java 8中，可以有多种方法来创建流。

1、通过已有的集合来创建流

在Java 8中，除了增加了很多Stream相关的类以外，还对集合类自身做了增强，在其中增加了stream方法，可以将一个集合类转换成流。

以上，通过一个已有的List创建一个流。除此以外，还有一个parallelStream方法，可以为集合创建一个并行流。

这种通过集合创建出一个Stream的方式也是比较常用的一种方式。

2、通过Stream创建流

可以使用Stream类提供的方法，直接返回一个由指定元素组成的流。

如以上代码，直接通过of方法，创建并返回一个Stream。

***3***

**Stream中间操作**

Stream有很多中间操作，多个中间操作可以连接起来形成一个流水线，每一个中间操作就像流水线上的一个工人，每人工人都可以对流进行加工，加工后得到的结果还是一个流。

![640?wx\_fmt=jpeg][640_wx_fmt_jpeg 1]

以下是常用的中间操作列表:

![640?wx\_fmt=jpeg][640_wx_fmt_jpeg 2]

**filter**

filter 方法用于通过设置的条件过滤出元素。以下代码片段使用 filter 方法过滤掉空字符串：

**map**

map 方法用于映射每个元素到对应的结果，以下代码片段使用 map 输出了元素对应的平方数：

**limit/skip**

limit 返回 Stream 的前面 n 个元素；skip 则是扔掉前 n 个元素。以下代码片段使用 limit 方法保理4个元素：

**sorted**

sorted 方法用于对流进行排序。以下代码片段使用 sorted 方法进行排序：

**distinct**

distinct主要用来去重，以下代码片段使用 distinct 对元素进行去重：

接下来我们通过一个例子和一张图，来演示下，当一个Stream先后通过filter、map、sort、limit以及distinct处理后会发生什么。

代码如下：

过程及每一步得到的结果如下图：

![640?wx\_fmt=jpeg][640_wx_fmt_jpeg 3]

***4***

**Stream最终操作**

Stream的中间操作得到的结果还是一个Stream，那么如何把一个Stream转换成我们需要的类型呢？比如计算出流中元素的个数、将流装换成集合等。这就需要最终操作（terminal operation）

最终操作会消耗流，产生一个最终结果。也就是说，在最终操作之后，不能再次使用流，也不能在使用任何中间操作，否则将抛出异常：

俗话说，“你永远不会两次踏入同一条河”也正是这个意思。

常用的最终操作如下图：

![640?wx\_fmt=jpeg][640_wx_fmt_jpeg 4]

**forEach**

Stream 提供了方法 'forEach' 来迭代流中的每个数据。以下代码片段使用 forEach 输出了10个随机数：

**count**

count用来统计流中的元素个数。

**collect**

collect就是一个归约操作，可以接受各种做法作为参数，将流中的元素累积成一个汇总结果：

接下来，我们还是使用一张图，来演示下，前文的例子中，当一个Stream先后通过filter、map、sort、limit以及distinct处理后会，在分别使用不同的最终操作可以得到怎样的结果。

下图，展示了文中介绍的所有操作的位置、输入、输出以及使用一个案例展示了其结果。

![640?wx\_fmt=jpeg][640_wx_fmt_jpeg 5]

***5***

**总结**

本文介绍了Java 8中的Stream 的用途，优点等。还接受了Stream的几种用法，分别是Stream创建、中间操作和最终操作。

Stream的创建有两种方式，分别是通过集合类的stream方法、通过Stream的of方法。

Stream的中间操作可以用来处理Stream，中间操作的输入和输出都是Stream，中间操作可以是过滤、转换、排序等。

Stream的最终操作可以将Stream转成其他形式，如计算出流中元素的个数、将流装换成集合、以及元素的遍历等。

> 3y:最后，我觉得IBM这篇写Stream的文章同样也写得很好，不妨去读读：  
> https://www.ibm.com/developerworks/cn/java/j-lo-java8streamapi/

![640?wx\_fmt=gif][640_wx_fmt_gif]

在 GitHub 更新中，欢迎关注，欢迎star。

**- MORE | 更多精彩文章 -**

*  [带你搭一个SpringBoot+SpringData JPA的Demo][SpringBoot_SpringData JPA_Demo]
 *  [如何理解axis？][axis]

如果你喜欢本文,

请长按二维码，关注** ****Java3y.**

![640?wx\_fmt=jpeg][640_wx_fmt_jpeg 6]

转发至朋友圈，是对我最大的支持。

[Optional]: https://mp.weixin.qq.com/s?__biz=MzI4Njg5MDA5NA==&mid=2247484410&idx=1&sn=ce6d4cf18846cc7b9e6e92427c9bba26&chksm=ebd742fbdca0cbedac796e06ebea4bad92ff7d707a5457c5ce521aa25b522dce96a23c4dcfbc&token=620000779&lang=zh_CN&scene=21#wechat_redirect
[640_wx_fmt_jpeg]: /images/20210827/a5b51a2dc9174e8fbb02d68716a82673.png?wx_fmt=jpeg
[640_wx_fmt_jpeg 1]: /images/20210827/4fbabdc92c854514bd600483b9245e51.png?wx_fmt=jpeg
[640_wx_fmt_jpeg 2]: /images/20210827/898f0178145447dd90d7c7f4d5af875c.png?wx_fmt=jpeg
[640_wx_fmt_jpeg 3]: /images/20210827/1eaa5feb6f2b4eb3ba20b31995cc0954.png?wx_fmt=jpeg
[640_wx_fmt_jpeg 4]: /images/20210827/f219e40a7e6c4090b5bdc494c8be092e.png?wx_fmt=jpeg
[640_wx_fmt_jpeg 5]: /images/20210827/9852918bbf4d49cf8ba3bc4ded0c53ec.png?wx_fmt=jpeg
[640_wx_fmt_gif]: /images/20210827/b4d22b0b45324c059b8a4e6ba7d99ac5.png?wx_fmt=gif
[SpringBoot_SpringData JPA_Demo]: https://mp.weixin.qq.com/s?__biz=MzI4Njg5MDA5NA==&mid=2247484997&idx=1&sn=96bf73ae24307aa800faeb71769d675c&chksm=ebd74744dca0ce525a24af4fd2bb3d975346a0c90c0f36af6ffc6f540f6462384cf678f74b6a&token=1369272705&lang=zh_CN&scene=21#wechat_redirect
[axis]: https://mp.weixin.qq.com/s?__biz=MzI4Njg5MDA5NA==&mid=2247485014&idx=1&sn=b04029123cdb067c113a83fc9470e348&chksm=ebd74757dca0ce416b8d8b2f514245f0f8be4c00a68b0b3e9934b615184e530794ed6a0879ab&token=1369272705&lang=zh_CN&scene=21#wechat_redirect
[640_wx_fmt_jpeg 6]: /images/20210827/99fddfaf0142465db607d7db50ad90f5.png?wx_fmt=jpeg