jdk8 Stream流

jdk8 Stream流

1.Stream API 简介

Stream API是Java 8中加入的一套新的API，主要用于处理集合操作，不过它的处理方式与传统的方式不同，
称为“数据流处理”。流（Stream）类似于关系数据库的查询操作，是一种声明式操作。比如要从数据库中获取所有年龄大于20岁的用户的名称，
并按照用户的创建时间进行排序，如果在sql中就会很容易完成，但是在java程序中，在jdk8以前可能要使用很多的if条件，但是在jdk8的stream
流中，我们可以这样：

List<String> userNames =
        users.stream()
        .filter(user -> user.getAge() > 20)
        .sorted(comparing(User::getAddDate))
        .map(User::getUserName)
        .collect(toList());

在Java中，集合是一种数据结构，或者说是一种容器，用于存放数据，流不是容器，它不关心数据的存放，只关注如何处理。


在遍历一个数组的时候，我们回采用for-each的方式,这种属于外部遍历，而流使用的是内部遍历的方式，也就是在内部帮你把逻辑给处理好了
可以用一下的方式：

// 外部
List<String> list = Arrays.asList("A", "B", "C", "D");
for (String str : list) {
    System.out.println(str);
}

// 内部
  list.stream().forEach(System.out::println);

其实在stream流的内部，Stream API将迭代操作封装到了内部，它会自动的选择最优的迭代方式，并且使用并行方式处理时，
将集合分成多段，每一段分别使用不同的线程处理，最后将处理结果合并输出。


需要注意的是，每个流的只能去遍历一次，如果对一个流遍历两次，会抛出java.lang.IllegalStateException异常

List<String> list = Arrays.asList("A", "B", "C", "D");
Stream<String> stream = list.stream();
stream.forEach(System.out::println);
stream.forEach(System.out::println); // 这里会抛出java.lang.IllegalStateException异常，因为流已经被关闭

流通常是有三个部分组成

1.数据源：流的获取，比如list.stream()方法；

2.中间处理：中间处理是对流元素的一系列处理。比如过滤filter，排序sorted，映射map；

3.终端处理：终端处理会生成结果，结果可以是任何不是流值。生成List,可用collect(Collectors.toList()),生成Map可用collect(Collectors.toMap())
也可以不返回结果，如stream.forEach(System.out::println)就是将结果打印到控制台中，并没有返回。

2.使用流

  • filter()：对元素进行过滤
  • map()：将流的元素映射成另一个类型
  • distinct()：去除流中重复的元素
  • sorted()：对元素进行排序
  • forEach ：对流中的每个元素执行某个操作
  • peek()：与forEach()方法效果类似，不同的是，该方法会返回一个新的流，而forEach()无返回
  • limit()：截取流中前面几个元素
  • skip()：跳过流中前面几个元素
  • toArray()：将流转换为数组
  • reduce()：对流中的元素归约操作，将每个元素合起来形成一个新的值
  • collect()：对流的汇总操作，比如输出成List集合
  • anyMatch()：匹配流中的元素，类似的操作还有allMatch()和noneMatch()方法
  • findFirst()：查找第一个元素，类似的还有findAny()方法
  • max()：求最大值
  • min()：求最小值
  • count()：求总数

使用方法

2.1过滤和排序
Stream.of(1, 8, 5, 2, 1, 0, 9, 2, 0, 4, 8)
    .filter(n -> n > 2)     // 对元素过滤，保留大于2的元素
    .distinct()             // 去重，类似于SQL语句中的DISTINCT
    .skip(1)                // 跳过前面1个元素
    .limit(2)               // 返回开头2个元素，类似于SQL语句中的SELECT TOP
    .sorted()               // 对结果排序
    .forEach(System.out::println);

    //filter后剩下：8，5，9，4，8
    //去重后排序剩下：5，9
2.2查找和匹配

Stream中提供的查找方法有anyMatch()、allMatch()、noneMatch()、findFirst()、findAny()，
这些方法被用来查找或匹配某些元素是否符合给定的条件：

  boolean  hasMatch = Stream.of("Java", "C#", "PHP", "C++", "Python")
                .anyMatch(s -> s.equals("Java"));
    // hasMatch:true
  boolean hasAllMatch = Stream.of("Java", "C#", "PHP", "C++", "Python")
        .allMatch(s -> s.contains("#"));
        //hasAllMatch:false
   Optional<String> element = Stream.of("Java", "C#", "PHP", "C++", "Python")
        .filter(s -> s.contains("C"))
        // .findFirst()     // 查找第一个元素
        .findAny();         // 查找任意元素
        //element：Optional[C#]

实际上测试结果发现，findFirst()和findAny()返回的都是第一个元素,两者之间到底有没什么区别呢，
通过查看javadoc描述，大致意思是findAny()是为了提高并行操作时的性能，所以在使用中如果没有特殊需求，都是
建议使用findAny()

2.3 归约

归约操作就是将流中的元素进行合并，形成一个新的值，常见的归约操作包括求和等运算，
求最大值或最小值。归约操作一般使用reduce()方法，
与map()方法搭配使用，可以处理一些很复杂的归约操作。


      List<Book> books =Arrays.asList(
            new Book("Java编程思想", "Bruce Eckel", "机械工业出版社", 108.00D),
            new Book("Java 8实战", "Mario Fusco", "人民邮电出版社", 79.00D),
            new Book("MongoDB权威指南（第2版）", "Kristina Chodorow", "人民邮电出版社", 69.00D)
      );
      // 计算所有图书的总价
      Optional<Double> totalPrice = books.stream()
                                          .map(Book::getPrice)
                                          .reduce((n, m) -> n + m);
      // 价格最高的图书
      Optional<Book> expensive = books.stream().max(Comparator.comparing(Book::getPrice));
      // 价格最低的图书
      Optional<Book> cheapest = books.stream().min(Comparator.comparing(Book::getPrice));
      // 计算总数
      long count = books.stream().count();

在计算图书总价的时候首先使用map()方法得到所有图书价格的流，然后再使用reduce()方法进行归约计算。

3.数据收集

数据收集是流式数据处理的终端处理，与中间处理不同的是，终端处理会消耗流，
也就是说，终端处理之后，这个流就会被关闭，如果再进行中间处理，就会抛出异常。数据收集主要使用collect方法，
该方法也属于归约操作，像reduce()方法那样可以接收各种做法作为参数，将流中的元素累积成一个汇总结果，
具体的做法是通过定义新的Collector接口来定义的。

3.1规约和汇总

      // 求和
      long count = books.stream().collect(counting());

      // 价格最高的图书
      Optional<Book> expensive = books.stream().collect(maxBy(comparing(Book::getPrice)));

      // 价格最低的图书
      Optional<Book> cheapest = books.stream().collect(minBy(comparing(Book::getPrice)));

上面的代码假设你已经使用静态导入了Collectors和Comparator两个类，
这样你就不用再去写Collectors.counting()和Comparator.comparing()这样的代码了：

import static java.util.stream.Collectors.*;
import static java.util.Comparator.*;

Collectors类还包含一个joining()方法，该方法用于连接字符串：


     String str = Stream.of("A", "B", "C", "D").collect(joining(","));
3.2分组

和关系型数据库类似，流也提供了类似数据库的group by的特性，由Collectors.groupingBy()方法提供：

Map<String, List<Book>> booksGroup = books.stream().collect(groupingBy(Book::getPublisher));

上面的代码按照出版社对图书进行分组，分组的结果是一个Map对象
，Map的key值是出版社的名称，value值是每个出版社分组对应的集合。
分组方法groupingBy()接收一个Function接口作为参数，
上面的例子中我们使用了方法引用传递了出版社作为分组的依据
，但实际情况可能比这复杂，比如将价格在0-50之间的书籍分成一组，50-100之间的分成一组，
超过100的分成一组，这时候，我们可以直接使用Lambda表达式来表示这个分组逻辑：

// 获取流
      List<Book> books = Arrays.asList(
          new Book("Java编程思想", "Bruce Eckel", "机械工业出版社", 108.00D),
          new Book("Java 8实战", "Mario Fusco", "人民邮电出版社", 79.00D),
          new Book("MongoDB权威指南（第2版）", "Kristina Chodorow", "人民邮电出版社", 69.00D),
          new Book("MongoDB", "Kristina Chodorow", "人民邮电出版社", 50.00D),
          new Book("MongoDB", "Kristina Chodorow", "人民邮电出版社", 50.00D)
      );

Map<String, List<Book>> booksGroup = books
    .stream()
    .collect(groupingBy(book -> {
        if (book.getPrice() > 0 && book.getPrice() <= 50) {
            return "A";
        } else if (book.getPrice() > 50 && book.getPrice() <=100) {
            return "B";
        } else {
            return "C";
        }
    }));

//输出结果
{A=[Book{name='MongoDB', author='Kristina Chodorow', address='人民邮电出版社', price=50.0}, Book{name='MongoDB', author='Kristina Chodorow', address='人民邮电出版社', price=50.0}],
 B=[Book{name='Java 8实战', author='Mario Fusco', address='人民邮电出版社', price=79.0}, Book{name='MongoDB权威指南（第2版）', author='Kristina Chodorow', address='人民邮电出版社', price=69.0}],
 C=[Book{name='Java编程思想', author='Bruce Eckel', address='机械工业出版社', price=108.0}]}

groupingBy()方法还支持多级分组，
他有一个重载方法，除了接收一个Function类型的参数外，还接收一个Collector类型的参数：

Map<String, Map<String, List<Book>>> booksGroup = books.stream().collect(
        groupingBy(Book::getPublisher, groupingBy(book -> {
            if (book.getPrice() > 0 && book.getPrice() <= 50) {
                return "A";
            } else if (book.getPrice() > 50 && book.getPrice() <=100) {
                return "B";
            } else {
                return "C";
            }
        }))
);

//输出结果
{Mario Fusco={B=[Book{name='Java 8实战', author='Mario Fusco', address='人民邮电出版社', price=79.0}]},
 Bruce Eckel={C=[Book{name='Java编程思想', author='Bruce Eckel', address='机械工业出版社', price=108.0}]},
 Kristina Chodorow={A=[Book{name='MongoDB', author='Kristina Chodorow', address='人民邮电出版社', price=50.0},
                       Book{name='MongoDB', author='Kristina Chodorow', address='人民邮电出版社', price=50.0}],
                    B=[Book{name='MongoDB权威指南（第2版）', author='Kristina Chodorow', address='人民邮电出版社', price=69.0}]}}

groupingBy()的第二个参数可以是任意类型，只要是Collector接口的实例就可以，比如先分组，再统计数量：

Map<String, Long> countGroup = books.stream()
        .collect(groupingBy(Book::getPublisher, counting()));

还可以获取分组后每组价格最高的的图书：

Map<String, Book> expensiveGroup = books.stream()
               .collect(groupingBy(Book::getAuthor, collectingAndThen(
                       maxBy(comparingDouble(Book::getPrice)),
                       Optional::get
               )));
//输入结果
/*{Mario Fusco=Book{name='Java 8实战', author='Mario Fusco', address='人民邮电出版社', price=79.0},
 Bruce Eckel=Book{name='Java编程思想', author='Bruce Eckel', address='机械工业出版社', price=108.0},
 Kristina Chodorow=Book{name='MongoDB', author='Kristina Chodorow', address='人民邮电出版社', price=80.0}}*/
最后编辑于 ：
©著作权归作者所有,转载或内容合作请联系作者
  • 人面猴
    序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
    沈念sama阅读 206,013评论 6赞 481
  • 死咒
    序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
    沈念sama阅读 88,205评论 2赞 382
  • 救了他两次的神仙让他今天三更去死
    文/潘晓璐 我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
    开封第一讲书人阅读 152,370评论 0赞 342
  • 道士缉凶录：失踪的卖姜人
    文/不坏的土叔 我叫张陵，是天一观的道长。 经常有香客问我，道长，这世上最难降的妖魔是什么？ 我笑而不...
    开封第一讲书人阅读 55,168评论 1赞 278
  • 港岛之恋（遗憾婚礼）
    正文 为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
    茶点故事阅读 64,153评论 5赞 371
  • 恶毒庶女顶嫁案：这布局不是一般人想出来的
    文/花漫 我一把揭开白布。 她就那样静静地躺着，像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上，一...
    开封第一讲书人阅读 48,954评论 1赞 283
  • 城市分裂传说
    那天，我揣着相机与录音，去河边找鬼。 笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。 我是一名探鬼主播，决...
    沈念sama阅读 38,271评论 3赞 399
  • 双鸳鸯连环套：你想象不到人心有多黑
    文/苍兰香墨 我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
    开封第一讲书人阅读 36,916评论 0赞 259
  • 万荣杀人案实录
    序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
    沈念sama阅读 43,382评论 1赞 300
  • 护林员之死
    正文 独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,877评论 2赞 323
  • 白月光启示录
    正文 我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,989评论 1赞 333
  • 活死人
    序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
    沈念sama阅读 33,624评论 4赞 322
  • 日本核电站爆炸内幕
    正文 年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
    茶点故事阅读 39,209评论 3赞 307
  • 男人毒药：我在死后第九天来索命
    文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 30,199评论 0赞 19
  • 一桩弑父案，背后竟有这般阴谋
    文/苍兰香墨 我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,418评论 1赞 260
  • 情欲美人皮
    我被黑心中介骗来泰国打工， 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。 一个月前我还...
    沈念sama阅读 45,401评论 2赞 352
  • 代替公主和亲
    正文 我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
    茶点故事阅读 42,700评论 2赞 345