前言

Stream大意概括 将一个列表（List）中的所有类铺平转换成一条流水线，按要求将流水线上的所有类一个一个地处理。像极了SQL语句。

本篇文章将用通俗易懂的语言为你讲解流操作。如果你有一部分卡住看不懂，跳过去就好，再回去看就会了。

-📚-|需要先了解的知识|-📚-

-⭐️-|评分|-⭐️-

原理图

其实整个过程跟流水线差不多。让我们看看由灵魂画手A先生绘制的原理图：

没看懂没关系，做完第一个实践再回来看看。

实践

跳过那些复杂的理论，打开你的IDE，新建一个类名为Arr，把下面的代码复制进去，反复分析代码，最后带着你的疑问再继续：

 1import java.util.ArrayList;
 2import java.util.List;
 3import java.util.stream.Collectors;
 4import java.util.stream.Stream;
 5
 6public class Arr {
 7    public static void main(String[] args) {
 8        //God创建星球
 9        星球 星球1 = new 星球();
10        星球 星球2 = new 星球();
11        星球 星球3 = new 星球();
12        //God给星球起名
13        星球1.设置星球名("地球");
14        星球2.设置星球名("太阳");
15        星球3.设置星球名("唱跳Rap篮球");
16        //God把星球添加到ArrayList中
17        List<星球> 宇宙 = new ArrayList();
18        宇宙.add(星球1);
19        宇宙.add(星球2);
20        宇宙.add(星球3);
21        //灭霸出现
22        Stream<星球> 灭霸 = 宇宙.stream().map(
23                星球 -> {
24                    //如果星球名中带“球”字，则毁灭
25                    if (星球.获取星球名().indexOf("球") != -1) {
26                        星球.设置星球名("已毁灭");
27                    }
28                    return 星球;
29                });
30        //将全部星球重新转换为新宇宙
31        List<星球> 新宇宙 = 灭霸.collect(Collectors.toList());
32        //打印星球存活情况
33        for (星球 i : 新宇宙) {
34            System.out.println(i.获取星球名());
35        }
36    }
37}
38
39class 星球 {
40    private String 星球名;
41
42    public void 设置星球名(String 星球名) {
43        this.星球名 = 星球名;
44    }
45
46    public String 获取星球名() {
47        return 星球名;
48    }
49}
50

map()就是将流中的类挨个儿揪出来，并临时命名为一个局部的星球变量，并且对这个变量进行判断呢修改后，再返回新的星球给灭霸。

运行结果：

1已毁灭
2太阳
3已毁灭

整理思路

其中的流化操作，就像是下边这条伪SQL语句：

1UPDATE 宇宙 SET 星球名=IF(... .indexOf("球") != -1 ...);

SQL语义为：将所有宇宙中的星球名更新，其中如果包含“球”的则修改为“已毁灭”，其它不变。

那么如果下面这条SQL语句，应该怎么表达？

1SELECT * FROM 宇宙 WHERE LOCATE("球", 星球名) LIMIT 1;

将星球名包含“球”字的星球筛选（即不打印不包含“球”字的星球名），并限制仅打印一个。

修改灭霸部分：

1        Stream<星球> 灭霸 = 宇宙.stream()
2                .filter(星球 -> 星球.获取星球名().indexOf("球") != -1)
3                .limit(1);

运行结果：

1地球

其它流操作

其它的几个流操作：

去重 stream().distinct()
排序 stream().sorted()
扔掉前N个元素 stream().skip(n)

自己尝试下吧！

Stream.of

我们演示使用的List中的.stream()方法是继承自Collection集合类的，所以也就是说，只要是基于Collection的集合，大多数都是支持使用Stream类进行流操作的。

那么如果我想省略掉建立List步骤，直接生成为一个Stream流呢？

1Stream.of(星球1, 星球2, 星球3)；

将代码套用到刚刚的实例中。修改主方法:

 1    public static void main(String[] args) {
 2        //God创建星球
 3        星球 星球1 = new 星球();
 4        星球 星球2 = new 星球();
 5        星球 星球3 = new 星球();
 6        //God给星球起名
 7        星球1.设置星球名("地球");
 8        星球2.设置星球名("太阳");
 9        星球3.设置星球名("唱跳Rap篮球");
10        //灭霸出现
11        Stream<星球> 灭霸 = Stream.of(星球1, 星球2, 星球3)
12                .filter(星球 -> 星球.获取星球名().indexOf("球") != -1)
13                .limit(1);
14        //将全部星球重新转换为新宇宙
15        List<星球> 新宇宙 = 灭霸.collect(Collectors.toList());
16        //打印星球存活情况
17        for (星球 i : 新宇宙) {
18            System.out.println(i.获取星球名());
19        }
20    }

是不是优美了一点儿呢？

后语

排坑

如果你将灭霸部分修改为：

1        Stream<星球> 灭霸 = Stream.of(星球1, 星球2, 星球3);
2        灭霸.filter(星球 -> 星球.获取星球名().indexOf("球") != -1)
3                .limit(1);

再次运行，你会发现出现报错：

1Exception in thread "main" java.lang.IllegalStateException: stream has already been operated upon or closed
2	at java.base/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:229)
3	at java.base/java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:578)
4	at Arr.main(Arr.java:21)

这是由于每个Stream只能使用一次。将代码稍稍修改：

1        Stream<星球> 灭霸 = Stream.of(星球1, 星球2, 星球3);
2        灭霸 = 灭霸.filter(星球 -> 星球.获取星球名().indexOf("球") != -1)
3                .limit(1);

将返回的新结果复用，这样就不会报错了。