Java8之Stream流（一）基礎(chǔ)體驗(yàn)
Java8之Stream流（二）關(guān)鍵知識(shí)點(diǎn)
Java8之Stream流（三）縮減操作
Java8之Stream流（四）并行流
Java8之Stream流（五）映射流
Java8之Stream流（七）流與迭代器
我們前面的五篇文章基本都是在說(shuō)將一個(gè)集合轉(zhuǎn)成一個(gè)流吗浩，然后對(duì)流進(jìn)行操作，其實(shí)這種操作是最多的，但有時(shí)候我們也是需要從流中收集起一些元素，并以集合的方式返回，我們把這種反向操作稱(chēng)為收集旦棉。流API也給我們提供了相應(yīng)的方法。
如何在流中使用收集功能少孝？
我們先看一看流API給我們提供的方法：
public interface Stream<T> extends BaseStream<T, Stream<T>> {
//...忽略那些不重要的東西
<R> R collect(Supplier<R> supplier,
BiConsumer<R, ? super T> accumulator,
BiConsumer<R, R> combiner);
<R, A> R collect(Collector<? super T, A, R> collector);
｝
流API中給我們提供了兩種邑退，我給大家分析一下
<R, A> R collect(Collector<? super T, A, R> collector);
其中R指定結(jié)果的類(lèi)型竹宋，T指定了調(diào)用流的元素類(lèi)型。內(nèi)部積累的類(lèi)型由A指定地技。collectorFunc是一個(gè)收集器蜈七，指定收集過(guò)程如何執(zhí)行，collect()方法是一個(gè)終端方法莫矗。雖然我們基本上很少會(huì)用到自定義的collectorFunc,但是了為擴(kuò)展大家的知識(shí)面飒硅，我們還是簡(jiǎn)單地聊一聊Collector，Because it's my style!
Collector接口位于java.util.stream包中的聲明作谚，它的容顏是這樣的：
package java.util.stream;
public interface Collector<T, A, R> {
Supplier<A> supplier();
BiConsumer<A, T> accumulator();
BinaryOperator<A> combiner();
Function<A, R> finisher();
}
其中T三娩、A、R的含義和上面是一樣的其中R指定結(jié)果的類(lèi)型妹懒，T指定了調(diào)用流的元素類(lèi)型雀监。內(nèi)部積累的類(lèi)型由A指定。但是這一篇我們不實(shí)現(xiàn)他們眨唬，因?yàn)镴DK已經(jīng)給我們提供了很強(qiáng)大的方法了会前，他們位于java.util.stream下面的Collectors類(lèi)，我們本篇也主要是使用Collectors來(lái)實(shí)現(xiàn)收集的功能匾竿。
Collectors類(lèi)是一個(gè)最終類(lèi)瓦宜，里面提供了大量的靜態(tài)的收集器方法，借助他岭妖，我們基本可以實(shí)現(xiàn)各種復(fù)雜的功能了临庇。我們來(lái)看一下toList和toSet方法:
public static <T> Collector<T, ?, List<T>> toList()
public static <T> Collector<T, ?, Set<T>> toSet()
其中Collectors#toList()返回的收集器可以把流中元素收集到一個(gè)List中，Collectors#toSet()返回的收集器可以把流中的元素收集到一個(gè)Set中区转。比如：如果你想把元素收集到List中苔巨，你可以這樣用，steam.collect(Collectors.toList).接下來(lái)废离，我們把我們的王者榮耀團(tuán)隊(duì)經(jīng)濟(jì)例子修改一下侄泽，把明星玩家和當(dāng)前獲得的金幣數(shù)收集到一個(gè)List里面，把出場(chǎng)的英雄收集到一個(gè)Set里面：
#玩家使用的英雄以及當(dāng)前獲得的金幣數(shù)
public class HeroPlayerGold {
/** 使用的英雄名字 */
private String hero;
/** 玩家的ID */
private String player;
/** 獲得的金幣數(shù) */
private int gold;
public HeroPlayerGold(String hero, String player, int gold) {
this.hero = hero;
this.player = player;
this.gold = gold;
}
@Override
public String toString() {
return "HeroPlayerGold{" +
"hero='" + hero + '\'' +
", player='" + player + '\'' +
", gold=" + gold +
'}';
}
//省略get/set
}
#出場(chǎng)的英雄
public class Hero {
/** 使用的英雄名字 */
private String hero;
public Hero(String hero) {
this.hero = hero;
}
@Override
public String toString() {
return "Hero{" +
"hero='" + hero + '\'' +
'}';
}
//省略get/set
}
#測(cè)試類(lèi)
public class Main {
public static void main(String[] args) {
learnCollect();
}
private static void learnCollect() {
List<HeroPlayerGold> lists = new ArrayList<>();
lists.add(new HeroPlayerGold("蓋倫", "RNG-Letme", 100));
lists.add(new HeroPlayerGold("諸葛亮", "RNG-Xiaohu", 300));
lists.add(new HeroPlayerGold("露娜", "RNG-MLXG", 300));
lists.add(new HeroPlayerGold("狄仁杰", "RNG-UZI", 500));
lists.add(new HeroPlayerGold("牛頭", "RNG-Ming", 500));
List<PlayerGold> playerGolds = lists.stream()
.map(plary -> new PlayerGold(plary.getPlayer(), plary.getGold()))
.collect(Collectors.toList());
System.out.println("============PlayerGold begin==============");
playerGolds.forEach(System.out::println);
System.out.println("============PlayerGold end================\n");
Set<Hero> heroes = lists.stream().map(player -> new Hero(player.getHero())).collect(Collectors.toSet());
System.out.println("============Hero begin==============");
heroes.forEach(System.out::println);
System.out.println("============Hero end================");
}
}
輸出的日志：
============PlayerGold begin==============
PlayerGold{player='RNG-Letme', gold=100}
PlayerGold{player='RNG-Xiaohu', gold=300}
PlayerGold{player='RNG-MLXG', gold=300}
PlayerGold{player='RNG-UZI', gold=500}
PlayerGold{player='RNG-Ming', gold=500}
============PlayerGold end================
============Hero begin==============
Hero{hero='露娜'}
Hero{hero='牛頭'}
Hero{hero='蓋倫'}
Hero{hero='狄仁杰'}
Hero{hero='諸葛亮'}
============Hero end================
看到這里蜻韭，大家有感受到流API的威力了嗎悼尾？提示一下，封裝一個(gè)工具類(lèi)肖方，然后結(jié)合一FastJson這種東西一起使用闺魏！是真的好用啊俯画！其實(shí)將數(shù)據(jù)從集合移到流中析桥，或者將數(shù)據(jù)從流移回集合的能力，是流API給我們提供的一個(gè)強(qiáng)大特性，因?yàn)檫@允許通過(guò)流來(lái)操作集合泡仗，然后把流重新打包成集合埋虹。此外，條件合適的時(shí)候娩怎，讓流操作并行發(fā)生搔课，提高效率。
接下來(lái)我們分析第二個(gè)方法截亦，
<R> R collect(Supplier<R> supplier,
BiConsumer<R, ? super T> accumulator,
BiConsumer<R, R> combiner);
我們第二個(gè)版本的收集方法爬泥，主要是可以在收集的過(guò)程中，給予更多的控制崩瓤。其中supplier指定如何創(chuàng)建用于保存結(jié)果的對(duì)象袍啡，比如，要使用ArrayList作為結(jié)果的集合却桶，需要指定它的構(gòu)造函數(shù)葬馋，accumulator函數(shù)是將一個(gè)元素添加到結(jié)果中，而combiner函數(shù)合并兩個(gè)部分的結(jié)果肾扰。大家應(yīng)該發(fā)現(xiàn)了吧，他的工作方式和我們第三篇介紹縮減操作時(shí)的reduce方法是很像的蛋逾。它們都必須是無(wú)狀態(tài)和不干預(yù)的集晚，并且必須有關(guān)聯(lián)性，三個(gè)約束條件缺一不可区匣。
Supplier也是java.util.function包中的一個(gè)函數(shù)式接口:
@FunctionalInterface
public interface Supplier<T> {
T get();
}
只有一個(gè)get()偷拔，并且是沒(méi)有參數(shù)的，在collect()方法返回一個(gè)R類(lèi)型的對(duì)象亏钩，并且get()方法返回一個(gè)指向集合的引用莲绰。
而accumulator,combiner的類(lèi)型是BiConsumer，他們也是java.util.function包中的一個(gè)函數(shù)式接口:
@FunctionalInterface
public interface BiConsumer<T, U> {
void accept(T t, U u);
}
其中t,u執(zhí)行某種類(lèi)型的操作姑丑，對(duì)于accumulator來(lái)說(shuō)蛤签，t指定了目標(biāo)集合，u指定了要添加到該集合的元素栅哀。對(duì)于combiner來(lái)說(shuō)震肮，t和u指定的是兩個(gè)要被合并的集合。我們把前面的例子改變一下留拾，然后也詳細(xì)地說(shuō)一下戳晌，在沒(méi)有用lambda和使用lambda之后的區(qū)別：
這個(gè)是沒(méi)有使用lambda前的：
private static void learnCollect() {
List<HeroPlayerGold> lists = new ArrayList<>();
lists.add(new HeroPlayerGold("蓋倫", "RNG-Letme", 100));
lists.add(new HeroPlayerGold("諸葛亮", "RNG-Xiaohu", 300));
lists.add(new HeroPlayerGold("露娜", "RNG-MLXG", 300));
lists.add(new HeroPlayerGold("狄仁杰", "RNG-UZI", 500));
lists.add(new HeroPlayerGold("牛頭", "RNG-Ming", 500));
lists.stream().collect(new Supplier<HashSet<HeroPlayerGold>>() {
@Override
public HashSet<HeroPlayerGold> get() {
return new HashSet<>();
}
},//第一個(gè)參數(shù)
new BiConsumer<HashSet<HeroPlayerGold>, HeroPlayerGold>() {
@Override
public void accept(HashSet<HeroPlayerGold> heroPlayerGolds, HeroPlayerGold heroPlayerGold) {
heroPlayerGolds.add(heroPlayerGold);
}
},//第二個(gè)參數(shù)
new BiConsumer<HashSet<HeroPlayerGold>, HashSet<HeroPlayerGold>>() {
@Override
public void accept(HashSet<HeroPlayerGold> heroPlayerGolds, HashSet<HeroPlayerGold> heroPlayerGolds2) {
heroPlayerGolds.addAll(heroPlayerGolds2);
}
}//第三個(gè)參數(shù)
).forEach(System.out::println);
}
在沒(méi)有使用lambda前，雖然看起來(lái)的讓人眼花繚亂的痴柔，但不得不說(shuō)沦偎，他其實(shí)能幫助我們實(shí)現(xiàn)非常強(qiáng)大的功能，我們自定義的收集過(guò)程，全部都可以交給這個(gè)家伙豪嚎，我們用lambda整理一下：
private static void learnCollect() {
List<HeroPlayerGold> lists = new ArrayList<>();
lists.add(new HeroPlayerGold("蓋倫", "RNG-Letme", 100));
lists.add(new HeroPlayerGold("諸葛亮", "RNG-Xiaohu", 300));
lists.add(new HeroPlayerGold("露娜", "RNG-MLXG", 300));
lists.add(new HeroPlayerGold("狄仁杰", "RNG-UZI", 500));
lists.add(new HeroPlayerGold("牛頭", "RNG-Ming", 500));
lists.stream().collect(() -> new HashSet<>(),
(set,elem)->set.add(elem),
(setA,setB)->setA.addAll(setB)
).forEach(System.out::println);
}
大家以為到這里就結(jié)束了嗎搔驼？其實(shí)還可以使用方法引用和構(gòu)造函數(shù)引用來(lái)簡(jiǎn)化：
private static void learnCollect() {
List<HeroPlayerGold> lists = new ArrayList<>();
lists.add(new HeroPlayerGold("蓋倫", "RNG-Letme", 100));
lists.add(new HeroPlayerGold("諸葛亮", "RNG-Xiaohu", 300));
lists.add(new HeroPlayerGold("露娜", "RNG-MLXG", 300));
lists.add(new HeroPlayerGold("狄仁杰", "RNG-UZI", 500));
lists.add(new HeroPlayerGold("牛頭", "RNG-Ming", 500));
lists.stream().collect(HashSet::new,
HashSet::add,
HashSet::addAll
).forEach(System.out::println);
}
小結(jié)一下
本篇帶大家入門(mén)了Stream的收集操作，但是有了些這入門(mén)操作疙渣，我相信匙奴，你在我的演變過(guò)程中已經(jīng)發(fā)現(xiàn)了擴(kuò)展點(diǎn)了，不管是supplier妄荔，accumulator還是combiner泼菌，都可以在里面放一些特別的操作進(jìn)去，從而滿(mǎn)足你們的各種要求啦租。另外一個(gè)點(diǎn)哗伯，大家一定不要忘記了Collectors這個(gè)最終類(lèi)，里面已經(jīng)提供了很多很強(qiáng)大的靜態(tài)方法篷角，如果你們遇到一些特別的需求焊刹，首先要想到的應(yīng)該是Collectors，如果里面的方法都不能實(shí)現(xiàn)你的要求恳蹲，再考慮通過(guò)第二個(gè)版本的collect()方法實(shí)現(xiàn)你的自定義收集過(guò)程吧虐块。
