这篇文章将为大家详细讲解有关JAVA8流之概念和收集器的示例分析，小编觉得挺实用的，因此分享给大家做个参考，希望大家阅读完这篇文章后可以有所收获。
十年的金坛网站建设经验，针对设计、前端、开发、售后、文案、推广等六对一服务，响应快，48小时及时工作处理。全网整合营销推广的优势是能够根据用户设备显示端的尺寸不同，自动调整金坛建站的显示方式，使网站能够适用不同显示终端，在浏览器中调整网站的宽度，无论在任何一种浏览器上浏览网站，都能展现优雅布局与设计，从而大程度地提升浏览体验。创新互联公司从事“金坛网站设计”,“金坛网站推广”以来，每个客户项目都认真落实执行。
在没有流以前，处理集合里面的数据一般都会用到显示的迭代器。用一下前面学生的例子吧。目标是获得学分大于5的前俩位同学。
package com.aomi;
import java.util.ArrayList;
import java.util.Iterator;
import java.util.List;
import static java.util.stream.Collectors.toList;
public class Main {
public static void main(String[] args) {
// TODO Auto-generated method stub
List stus = getSources();
Iterator ite = stus.iterator();
List names = new ArrayList<>();
int limit = 2;
while (ite.hasNext() && limit > 0) {
Student stu = ite.next();
if (stu.getScore() > 5) {
names.add(stu.getName());
limit--;
}
}
for (String name : names) {
System.out.println(name);
}
}
public static List getSources() {
List students = new ArrayList<>();
Student stu1 = new Student();
stu1.setName("lucy");
stu1.setSex(0);
stu1.setPhone("13700227892");
stu1.setScore(9);
Student stu2 = new Student();
stu2.setName("lin");
stu2.setSex(1);
stu2.setPhone("15700227122");
stu2.setScore(9);
Student stu3 = new Student();
stu3.setName("lili");
stu3.setSex(0);
stu3.setPhone("18500227892");
stu3.setScore(8);
Student stu4 = new Student();
stu4.setName("dark");
stu4.setSex(1);
stu4.setPhone("16700555892");
stu4.setScore(6);
students.add(stu1);
students.add(stu2);
students.add(stu3);
students.add(stu4);
return students;
}
} 如果用流的话是这样子的。
public static void main(String[] args) {
// TODO Auto-generated method stub
List stus = getSources();
List names = stus.stream()
.filter(st -> st.getScore() > 5)
.limit(2)
.map(st -> st.getName())
.collect(toList());
for (String name : names) {
System.out.println(name);
}
} 把这俩段代码相比较主要是为了说明一个概念：以前做法都是在外部迭代，最为体现就是笔者在外面定义了一个集合names 。而流却什么也没有，现在我们应该能清楚感受到流是在内部迭代。也就是说流已经帮你做好了迭代。我们只要传入相关的函数就可以得到想要的结果。至于内部迭代的好处，笔者没有办法亲身的感受，唯一的感觉就是代码变的简单明了了。但是官方说Stream库为了我们在内部迭代里面做了很多优化和充公利用性能的操作。比如并行操作。所以笔者就听官方了。
事实上，在用流的过程中，我们用到很多方法函数。比如上面的limit方法，filter方法等。这个定义为流操作。但是不管是什么操作，你必须要有一个数据源吧。总结如下：
数据源：用于生成流的数据，比如集合。
流操作：类似于limit方法，filter方法。
流还有一种特点——部分流操作是没有执行的。一般都是在collect函数执行的时候，才开始执行个个函数。所以我们可以细分一下流操作：
数据源：用于生成流的数据，比如集合。
中间操作：类似于limit方法，filter方法。这些操作做变了一个操作链，有一点流水线的概念。
终端操作：执行上面的操作链。比如collect函数。
从上面的讲解我们就可以感觉流好像是先收集相关的目标操作，什么意思呢？就是先把要做的事情计划一下，最后一声令下执行。而下这个命令是collect函数。这一点跟.NET的Linq是很像的。同时记得他只能执行一次。也就是说这个流执行一次之后，就不可能在用了。
笔者列一下以前的用到的函数
forEach：终端
collect：终端
count：终端
limit：中间
filter：中间
map：中间
sorted：中间
到目前为止我们用到的流都是通过集合来建一个流。笔者对此从来没有讲过。现在笔者来讲些构建流的方式。
在stream库里面为我们提供了这样子一个方法——Stream.of
package com.aomi;
import java.util.Optional;
import java.util.stream.Stream;
public class Main {
public static void main(String[] args) {
// TODO Auto-generated method stub
Stream stream = Stream.of("I", "am", "aomi");
Optional firstWord = stream.findFirst();
if(firstWord.isPresent())
{
System.out.println("第一个字："+firstWord.get());
}
}
} 运行结果：
去看一下of方法的代码。如下
public staticStream of(T... values) { return Arrays.stream(values); }
说明我们可能指定一个类型来建一个流。上面可以修改为
Streamstream = Stream.of("I", "am", "aomi");
findFirst函数用于表示返回第一个值。那就是可能数据源是一个空呢？所以他有可以会返回null。所以就是用一个叫Optional类的表示可以为空。这样子我们就可以用Optional类的方法进一步做安全性的操作。比如判断有没有值（isPresent()）
笔者想要建一个int类型的数组流玩玩。为了方便笔者便试给一下上面的代码。却发现报错了。
如果我把int改为Integer呢？没有问题了。所以注意要用引用类型的。int类型对应为Integer类型。
package com.aomi;
import java.util.Optional;
import java.util.stream.Stream;
public class Main {
public static void main(String[] args) {
// TODO Auto-generated method stub
Stream stream = Stream.of(1, 2, 9);
Optional firstWord = stream.findFirst();
if(firstWord.isPresent())
{
System.out.println("第一个字："+firstWord.get());
}
}
} 运行结果：
那想要用int类型呢?什么办呢？改改
package com.aomi;
import java.util.OptionalInt;
import java.util.stream.IntStream;
public class Main {
public static void main(String[] args) {
// TODO Auto-generated method stub
IntStream stream = IntStream.of(1, 2, 9);
OptionalInt firstWord = stream.findFirst();
if(firstWord.isPresent())
{
System.out.println("第一个字："+firstWord.getAsInt());
}
}
}运行结果：
我们以上面的例子来一个猜测：是不是Double类型，只要修改为DoubleStream就行呢？试试。
package com.aomi;
import java.util.OptionalDouble;
import java.util.stream.DoubleStream;
public class Main {
public static void main(String[] args) {
// TODO Auto-generated method stub
DoubleStream stream = DoubleStream.of(1.3, 2.3, 9.5);
OptionalDouble firstWord = stream.findFirst();
if(firstWord.isPresent())
{
System.out.println("第一个字："+firstWord.getAsDouble());
}
}
}运行结果：
结果很明显，我们的猜测是对的。所以见意如果你操作的流是一个int或是double的话，请进可能的用XxxStream 来建流。这样子在流的过程中不用进行拆装和封装了。必竟这是要性能的。在看一下如果数据源是一个数组的情况我们如何生成流呢？
