Java8 Streams filter 使用

引言

在本教程中，我們將向您展示幾個 java8 示例，以演示 Streams filter ()、 collect ()、 findAny ()和 orElse ()的使用。

什么是流

Stream（流）是一個來自數據源的元素隊列並支持聚合操作

• 元素 是特定類型的對象，形成一個隊列。 Java 中的 Stream 並不會存儲元素，而是按需計算。
• 數據源 流的來源。 可以是集合，數組，I/O channel， 產生器 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() − 為集合創建並行流。

1. Streams filter() and collect()

1.java 8 之前過濾 list 使用如下方式：

List<String> lines = Arrays.asList("spring", "node", "php");

    List<String> result = getFilterOutput(lines, "php");
    for (String temp : result) {
      System.out.println(temp);    //output : spring, node
    }
  }

  private static List<String> getFilterOutput(List<String> lines, String filter) {
    List<String> result = new ArrayList<>();
    for (String line : lines) {
      if (!"php".equals(line)) { // we dont like php
        result.add(line);
      }
    }
    return result;
  }

2.java 8 之后，使用 stream.filter() 過濾 list，使用 collect() 將流轉為 list.

List<String> lines = Arrays.asList("spring", "node", "php");

    List<String> result = lines.stream()          // convert list to stream
        .filter(line -> !"php".equals(line))      // we dont like php
        .collect(Collectors.toList());            // collect the output and convert streams to a List

    result.forEach(System.out::println);          //output : spring, node

2. Streams filter(), findAny() and orElse()

java8 之前，獲取 name 通過如下方式：

public static void main(String[] args) {
    List<Developer> persons = Arrays.asList(
        new Developer("zhangsan", 20),
        new Developer("lisi",21),
        new Developer("wangwu",22));

    Developer developer = getByNameBefore(persons,"lisi");
    System.out.println(developer == null ? "不存在" : developer.toString());
}

private static Developer getByNameBefore(List<Developer> persons, String lisi) {
    Developer result = null;
    for (Developer developer : persons) {
      if (developer.getName().equals(lisi)) {
        result = developer;
      }
    }

    return result;
  }

java8 之后：

public static void main(String[] args) {
    List<Developer> persons = Arrays.asList(
        new Developer("zhangsan", 20),
        new Developer("lisi",21),
        new Developer("wangwu",22));

    Developer developer = persons.stream().filter(x -> "lisi".equals(x.getName())).findAny()
        .orElse(null);
    System.out.println(developer);

    // 不存在的
    Developer developer1 = persons.stream().filter(x -> "asan".equals(x.getName())).findAny()
        .orElse(null);
    System.out.println(developer1);
}

多條件查詢使用：

public static void main(String[] args) {
    List<Developer> persons = Arrays.asList(
        new Developer("zhangsan", 20),
        new Developer("lisi",21),
        new Developer("wangwu",22));

    Developer result1 = persons.stream()
        .filter(p -> "lisi".equals(p.getName()) && p.getAge() == 21).findAny().orElse(null);

    System.out.println(result1);

    Developer result2 = persons.stream().filter(p -> {
      if ("lisi".equals(p.getName()) && p.getAge() == 21) {
        return true;
      }
      return false;
    }).findAny().orElse(null);

    System.out.println(result2);

  }

3. Streams filter() and map()

public static void main(String[] args) {
    List<Developer> persons = Arrays.asList(
        new Developer("zhangsan", 20),
        new Developer("lisi",21),
        new Developer("wangwu",22));

    String name = persons.stream().filter(x -> "lisi".equals(x.getName()))
        .map(Developer::getName)     //convert stream to String
        .findAny().orElse("");

    System.out.println("name : " + name);

    List<String> collect = persons.stream().filter(x -> "lisi".equals(x.getName()))
        .map(Developer::getName).collect(Collectors.toList());

    collect.forEach(System.out::println);
  }

源碼見：java-8-demo

系列文章詳見：Java 8 教程