簡介
Java 8 API添加了一個新的抽象稱為流Stream，可以讓你以一種聲明的方式處理資料。
Stream 使用一種類似用 SQL 語句從資料庫查詢資料的直覺方式來提供一種對 Java 集合運算和表達的高階抽象。這種風格将要處理的元素集合看作一種流， 流在管道中傳輸， 并且可以在管道的節點上進行處理， 比如篩選， 排序，聚合等。
熟悉Linux的同學對這種風格一定不陌生，因為它跟Linux的|管道符的思想如出一轍。上面這段話引用自runoob.com，但是其教學代碼都是基于String清單進行示範，考慮到實際情況百分之80的時候都是對PO、VO進行處理，是以以下通過一個PO進行講解。
對比起for循環操作list，最大的弊端就是代碼太長太亂了，如果涉及3-4張表的操作，也就是涉及多個PO操作，那個括号簡直就是俄羅斯套娃，寫到最後真的自己都不知道在寫什麼。
流
+--------------------+ +------+ +------+ +---+ +-------+
| stream of elements +-----> |filter+-> |sorted+-> |map+-> |collect|
+--------------------+ +------+ +------+ +---+ +-------+ PO代碼
public class UserPo {
private String name;
private Double score;
// 省略構造函數及getter、setter
} 以下操作均以UserPo進行講解
filter
filter：過濾，就是過濾器，符合條件的通過，不符合條件的過濾掉
// 篩選出成績不為空的學生人數，公衆号：Java精選
count = list.stream().filter(p -> null != p.getScore()).count(); map
map：映射，他将原集合映射成為新的集合，在VO、PO處理的過程中較常見。在本例子中，原集合就是PO集合，新集合可以自定義映射為成績集合，同時也可以對新集合進行相關操作
// 取出所有學生的成績
List<Double> scoreList = list.stream().map(p -> p.getScore()).collect(Collectors.toList());
// 将學生姓名集合串成字元串，用逗号分隔
String nameString = list.stream().map(p -> p.getName()).collect(Collectors.joining(",")); sorted
sorted：排序，可以根據指定的字段進行排序
// 按學生成績逆序排序 正序則不需要加.reversed()
filterList = list.stream().filter(p -> null != p.getScore()).sorted(Comparator.comparing(UserPo::getScore).reversed()).collect(Collectors.toList()); forEach
forEach：這個應該是最常用的，也就是為每一個元素進行自定義操作
除了forEach操作會改變原集合的資料，其他的操作均不會改變原集合，這點務必引起注意
// 學生成績太差了，及格率太低，給每個學生加10分，放個水
// forEach 公衆号：Java精選
filterList.stream().forEach(p -> p.setScore(p.getScore() + 10)); collect
collect：聚合，可以用于GroudBy按指定字段分類，也可以用于傳回清單或者拼湊字元串
// 按成績進行歸集
Map<Double, List<UserPo>> groupByScoreMap = list.stream().filter(p -> null != p.getScore()).collect(Collectors.groupingBy(UserPo::getScore));
for (Map.Entry<Double, List<UserPo>> entry : groupByScoreMap.entrySet()) {
System.out.println("成績：" + entry.getKey() + " 人數：" + entry.getValue().size());
}
// 傳回list
List<Double> scoreList = list.stream().map(p -> p.getScore()).collect(Collectors.toList());
// 傳回string用逗号分隔
String nameString = list.stream().map(p -> p.getName()).collect(Collectors.joining(",")); statistics
另外，推薦下Spring cloud的通用微服務開源項目：
https://gitee.com/yoodb/jingxuan-springcloud DoubleSummaryStatistics statistics = filterList.stream().mapToDouble(p -> p.getScore()).summaryStatistics();
System.out.println("清單中最大的數 : " + statistics.getMax());
System.out.println("清單中最小的數 : " + statistics.getMin());
System.out.println("所有數之和 : " + statistics.getSum());
System.out.println("平均數 : " + statistics.getAverage()); parallelStream
// 并行流
count = list.parallelStream().filter(p -> null != p.getScore()).count(); 完整代碼
package com.cmx.tcn.stream;
/**
* @author: Cai MinXing
**/
public class UserPo {
private String name;
private Double score;
public UserPo(String name, Double score) {
this.name = name;
this.score = score;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public Double getScore() {
return score;
}
public void setScore(Double score) {
this.score = score;
}
@Override
public String toString() {
return "UserPo{" +
"name='" + name + '\'' +
", score=" + score +
'}';
}
} package com.cmx.tcn.stream;
import java.util.ArrayList;
import java.util.Comparator;
import java.util.DoubleSummaryStatistics;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;
/**
* @author: Cai MinXing
* @create: 2020-03-25 18:15
**/
public class StreamTest {
// +--------------------+ +------+ +------+ +---+ +-------+
// | stream of elements +-----> |filter+-> |sorted+-> |map+-> |collect|
// +--------------------+ +------+ +------+ +---+ +-------+
public static void main(String args[]){
List<UserPo> list = new ArrayList<>();
list.add(new UserPo("小一", 10.d));
list.add(new UserPo("小五", 50.d));
list.add(new UserPo("小六", 60.d));
list.add(new UserPo("小6", 60.d));
list.add(new UserPo("小空", null));
list.add(new UserPo("小九", 90.d));
long count = 0;
List<UserPo> filterList = null;
// filter 過濾器的使用
// 篩選出成績不為空的學生人數
count = list.stream().filter(p -> null != p.getScore()).count();
System.out.println("參加考試的學生人數：" + count);
// collect
// 篩選出成績不為空的學生集合
filterList = list.stream().filter(p -> null != p.getScore()).collect(Collectors.toList());
System.out.println("參加考試的學生資訊：");
filterList.stream().forEach(System.out::println);
// map 将集合映射為另外一個集合
// 取出所有學生的成績
List<Double> scoreList = list.stream().map(p -> p.getScore()).collect(Collectors.toList());
System.out.println("所有學生的成績集合：" + scoreList);
// 将學生姓名集合串成字元串，用逗号分隔
String nameString = list.stream().map(p -> p.getName()).collect(Collectors.joining(","));
System.out.println("所有學生的姓名字元串：" + nameString);
// sorted排序
// 按學生成績逆序排序 正序則不需要加.reversed()
filterList = list.stream().filter(p -> null != p.getScore()).sorted(Comparator.comparing(UserPo::getScore).reversed()).collect(Collectors.toList());
System.out.println("所有學生的成績集合，逆序排序：");
filterList.stream().forEach(System.out::println);
System.out.println("按學生成績歸集：");
Map<Double, List<UserPo>> groupByScoreMap = list.stream().filter(p -> null != p.getScore())
.collect(Collectors.groupingBy(UserPo::getScore));
for (Map.Entry<Double, List<UserPo>> entry : groupByScoreMap.entrySet()) {
System.out.println("成績：" + entry.getKey() + " 人數：" + entry.getValue().size());
}
// forEach
filterList.stream().forEach(p -> p.setScore(p.getScore() + 10));
System.out.println("及格人數太少，給每個人加10分");
filterList.stream().forEach(System.out::println);
// count
count = filterList.stream().filter(p -> p.getScore() >= 60).count();
System.out.println("最後及格人數" + count);
DoubleSummaryStatistics statistics = filterList.stream().mapToDouble(p -> p.getScore()).summaryStatistics();
System.out.println("清單中最大的數 : " + statistics.getMax());
System.out.println("清單中最小的數 : " + statistics.getMin());
System.out.println("所有數之和 : " + statistics.getSum());
System.out.println("平均數 : " + statistics.getAverage());
// 并行流 使用
count = list.parallelStream().filter(p -> null != p.getScore()).count();
System.out.println("并行流處理參加考試的學生人數：" + count);
}
} ![Java String.format方法的簡單使用[圖]](data:image/gif;base64,R0lGODlhAQABAIAAAP///wAAACwAAAAAAQABAAACAkQBADs=)