JAVA基础---Stream流

Stream流出现背景

背景

在Java8之前，通常用 fori、for each 或者 Iterator 迭代来重排序合并数据，或者通过重新定义 Collections.sorts的 Comparator 方法来实现，这两种方式对大数量系统来说，效率不理想。

Java8 中添加了一个新的接口类 Stream，相当于高级版的 Iterator，通过Lambda 表达式对集合进行各种非常便利、高效的聚合操作（Aggregate Operation），或者大批量数据操作 (Bulk Data Operation）。Stream不仅可以通过串行的方式实现数据操作，还可以通过并行的方式处理大批量数据，提高数据的处理效率。

解释

Java 8 API添加了一个新的抽象称为流Stream，可以让你以一种声明的方式处理数据。

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

select * from user where age >30

流水线：

空瓶子--》灌水---》盖盖子--》贴标签 --->一瓶农夫三拳
Stream API可以极大提高Java程序员的生产力，让程序员写出高效率、干净、简洁的代码。
这种风格将要处理的元素集合看作一种流，流在管道中传输，并且可以在管道的节点上进行处理，比如筛选，排序，聚合等。
元素流在管道中经过中间操作（intermediate operation）的处理，最后由最终操作(terminal operation)得到前面处理的结果。

什么是Stream流

Stream（流）是一个来自数据源的元素队列并支持聚合操作

<strong元素队列< strong="">元素是特定类型的对象，形成一个队列。 Java中的Stream并不会存储元素，而是按需计算。</strong元素队列<>
数据源流的来源。可以是集合，数组，I/O channel（nio new IO非阻塞式IO），产生器generator 等。
聚合操作类似SQL语句一样的操作，比如filter, map, reduce, find, match, sorted等。

和以前的Collection操作不同， Stream操作还有两个基础的特征：
Pipelining: 中间操作都会返回流对象本身。这样多个操作可以串联成一个管道，如同流式风格（fluent style）。这样做可以对操作进行优化，比如延迟执行(laziness)和短路( short-circuiting)。
内部迭代：以前对集合遍历都是通过Iterator或者For-Each的方式, 显式的在集合外部进行迭代，这叫做外部迭代。 Stream提供了内部迭代的方式，通过访问者模式(Visitor)实现。

如何生成流

在 Java 8 中, 集合接口有两个方法来生成流：

stream() − 为集合创建串行流。

parallelStream() − 为集合创建并行流。

常用方法

for each(循环遍历)

public class StreamTest {
    public static void main(String[] args) {
        List<Integer> list= Arrays.asList(1,2,-2,3,4,5,6,7,8);
        //for each
        list.stream().forEach(System.out::println);
        }
}

运行结果

map

public class StreamTest {
    public static void main(String[] args) {
        List<Integer> list= Arrays.asList(1,2,-2,3,4,5,6,7,8);
        //for each
        list.stream().forEach(System.out::println);
        //list中的每个元素都乘以3然后再打印
        list.stream()
                .map(integer -> integer*3)//map表示对什么进行操作，箭头前面为数据，箭头后面为对数据进行的操作
                .forEach(System.out::println);
        }
}

运行结果

fliter

public class StreamTest {
    public static void main(String[] args) {
        List<Integer> list= Arrays.asList(1,2,-2,3,4,5,6,7,8);
        //for each
        list.stream().forEach(System.out::println);
        //list中的每个元素都乘以3然后再打印
        list.stream()
                .map(integer -> integer*3)//map表示对什么进行操作，箭头前面为数据，箭头后面为对数据进行的操作
                .forEach(System.out::println);
        System.out.println("======================使用过滤器=============================");
        list.stream()
                .map(integer -> integer*2)
                .filter(integer -> integer>7)
                .forEach(System.out::println);
    }
}

运行结果

limit

public class StreamTest {
    public static void main(String[] args) {
        List<Integer> list= Arrays.asList(1,2,-2,3,4,5,6,7,8);
        //for each
        list.stream().forEach(System.out::println);
        //list中的每个元素都乘以3然后再打印
        list.stream()
                .map(integer -> integer*3)//map表示对什么进行操作，箭头前面为数据，箭头后面为对数据进行的操作
                .forEach(System.out::println);
        System.out.println("======================使用过滤器=============================");
        list.stream()
                .map(integer -> integer*2)
                .filter(integer -> integer>7)
                .forEach(System.out::println);
        System.out.println("======================使用限制器=============================");
        list.stream()
                .map(integer -> integer*2)
                .filter(integer -> integer>7)
                .limit(3)//限制只输出3个元素(前三个)
                .forEach(System.out::println);
    }
}

运行结果

sorted

public class StreamTest {
    public static void main(String[] args) {
        List<Integer> list= Arrays.asList(1,2,-2,3,4,5,6,7,8);
        //for each        list.stream().forEach(System.out::println);
        //list中的每个元素都乘以3然后再打印
        list.stream()
                .map(integer -> integer*3)//map表示对什么进行操作，箭头前面为数据，箭头后面为对数据进行的操作
                .forEach(System.out::println);
        System.out.println("======================使用过滤器=============================");
        list.stream()
                .map(integer -> integer*2)
                .filter(integer -> integer>7)
                .forEach(System.out::println);
        System.out.println("======================使用限制器=============================");
        list.stream()
                .map(integer -> integer*2)
                .filter(integer -> integer>7)
                .limit(3)//限制只输出3个元素(前三个)
                .forEach(System.out::println);
        System.out.println("======================使用排序器=============================");
        list.stream()
                .map(integer -> integer*2)
                .filter(integer -> integer>-100)
                .sorted()//默认从小到大排序
                .limit(6)//限制只输出3个元素(前三个)
                .forEach(System.out::println);
    }
}

运行结果