摘要：多級(jí)分組的為鍵，類(lèi)型所對(duì)應(yīng)的集合為值一級(jí)分類(lèi)為的，二級(jí)分類(lèi)為的按子集收集數(shù)據(jù)的為鍵，類(lèi)型所對(duì)應(yīng)的集合的為值分區(qū)分區(qū)是分組的特殊情況由一個(gè)謂詞返回一個(gè)布爾值的函數(shù)作為分類(lèi)函數(shù)，它稱(chēng)分區(qū)函數(shù)。

收集器可以簡(jiǎn)潔而靈活地定義collect用來(lái)生成結(jié)果集合的標(biāo)準(zhǔn)。更具體地說(shuō)，對(duì)流調(diào)用 collect 方法將對(duì)流中的元素觸發(fā)一個(gè)歸約操作（由Collector來(lái)參數(shù)化）。一般來(lái)說(shuō)，Collector 會(huì)對(duì)元素應(yīng)用一個(gè)轉(zhuǎn)換函數(shù)（很多時(shí)候是不體現(xiàn)任何效果的恒等轉(zhuǎn)換， 例如 toList ），并將結(jié)果累積在一個(gè)數(shù)據(jù)結(jié)構(gòu)中，從而產(chǎn)生這一過(guò)程的最終輸出。下面就來(lái)學(xué)習(xí)那些可以從Collectors 類(lèi)提供的工廠方法（例如groupingBy）創(chuàng)建的收集器。

Collectors.maxBy 和 Collectors.minBy 來(lái)計(jì)算流中的最大或最小值。

Optional maxDish = Dish.menu.stream().
      collect(Collectors.maxBy(Comparator.comparing(Dish::getCalories)));
maxDish.ifPresent(System.out::println);

Optional minDish = Dish.menu.stream().
      collect(Collectors.minBy(Comparator.comparing(Dish::getCalories)));
minDish.ifPresent(System.out::println);

Collectors.summingInt 匯總求和；
Collectors.averagingInt 匯總求平均值；
Collectors.summarizingInt 匯總所有信息包括數(shù)量、求和、平均值、最小值、最大值；

//求總熱量
int totalColories = Dish.menu.stream().collect(Collectors.summingInt(Dish::getCalories));
System.out.println(totalColories);

//求平均熱量
double averageColories = Dish.menu.stream().collect(Collectors.averagingInt(Dish::getCalories));
System.out.println(averageColories);

//匯總
IntSummaryStatistics menuStatistics = Dish.menu.stream().collect(Collectors.summarizingInt(Dish::getCalories));
System.out.println(menuStatistics);
IntSummaryStatistics{count=9, sum=4300, min=120, average=477.777778, max=800}

joining 工廠方法返回的收集器會(huì)把對(duì)流中每一個(gè)對(duì)象應(yīng)用toString方法得到的所有字符串連接成一個(gè)字符串。

String menu = Dish.menu.stream().map(Dish::getName).collect(Collectors.joining(","));
System.out.println(menu);
//pork,beef,chicken,french fries,rice,season fruit,pizza,prawns,salmon

Collectors.reducing 工廠方法是上面所有工廠方法的一般情況，它完全可以實(shí)現(xiàn)上述方法的功能。它需要三個(gè)參數(shù)：

第一個(gè)參數(shù)是歸約操作的起始值，也是流中沒(méi)有元素時(shí)的返回值，所以很顯然對(duì)于數(shù)值和而言0是一個(gè)合適的值。

第二個(gè)參數(shù)是一個(gè) Function，就是具體的取值函數(shù)。

第三個(gè)參數(shù)是一個(gè) BinaryOperator，將兩個(gè)項(xiàng)目累積成一個(gè)同類(lèi)型的值。。

int totalCalories = Dish.menu.stream().collect(Collectors.reducing( 0, Dish::getCalories, (i, j) -> i + j));

用Collectors.groupingBy工廠方法返回的收集器可以實(shí)現(xiàn)分組任務(wù)，分組操作的結(jié)果是一個(gè)Map，把分組函數(shù)返回的值作為映射的鍵，把流中 所有具有這個(gè)分類(lèi)值的項(xiàng)目的列表作為對(duì)應(yīng)的映射值。

//Dish的Type為鍵，Dish類(lèi)型所對(duì)應(yīng)的dish集合為值
Map> dishesByType = Dish.menu.stream().collect(Collectors.groupingBy(Dish::getType));
System.out.println(dishesByType);
//{FISH=[prawns, salmon], OTHER=[french fries, rice, season fruit, pizza], MEAT=[pork, beef, chicken]}

//一級(jí)分類(lèi)為Dish的Type，二級(jí)分類(lèi)為Dish的CaloricLevel
Map>> dishes = Dish.menu.stream()
      .collect(Collectors.groupingBy(Dish::getType, Collectors.groupingBy(Dish::getLevel)));
System.out.println(dishes);
//{FISH={NORMAL=[salmon], DIET=[prawns]}, OTHER={NORMAL=[french fries, pizza], DIET=[rice, season fruit]}, MEAT={NORMAL=[beef], FAT=[pork], DIET=[chicken]}}

//Dish的Type為鍵，Dish類(lèi)型所對(duì)應(yīng)的dish集合的size為值
Map dishTypeCount = Dish.menu.stream().collect(Collectors.groupingBy(Dish::getType, Collectors.counting()));
System.out.println(dishTypeCount);
//{FISH=2, OTHER=4, MEAT=3}

分區(qū)是分組的特殊情況：由一個(gè)謂詞（返回一個(gè)布爾值的函數(shù)）作為分類(lèi)函數(shù)，它稱(chēng)分區(qū)函數(shù)。分區(qū)函數(shù)返回一個(gè)布爾值，這意味著得到的分組 Map 的鍵類(lèi)型是 Boolean，于是它最多可以分為兩組——true是一組，false是一組。分區(qū)的好處在于保留了分區(qū)函數(shù)返回true或false的兩套流元素列表。

Map>> partitioningDish = Dish.menu.stream().collect(Collectors.partitioningBy(Dish::isVegetarian, Collectors.groupingBy(Dish::getType)));
System.out.println(partitioningDish);
//false={FISH=[prawns, salmon], MEAT=[pork, beef, chicken]}, 
//true={OTHER=[french fries, rice, season fruit, pizza]}

下表展示 Collectors 類(lèi)的靜態(tài)工廠方法。

package com.company.bean;

import java.util.Arrays;
import java.util.List;
import java.util.stream.Collectors;

/**
 * Created by liuguoquan on 2017/4/26.
 */
public class Dish {

    private String name;
    private boolean vegetarian;
    private int calories;
    private Type type;
    private CaloricLevel level;

    public CaloricLevel getLevel() {

        if (calories <= 400) {

            return CaloricLevel.DIET;
        } else if (calories <= 700) {

            return CaloricLevel.NORMAL;
        }
        return CaloricLevel.FAT;
    }

    public void setLevel(CaloricLevel level) {
        this.level = level;
    }

    public enum Type { MEAT, FISH, OTHER }
    public enum CaloricLevel { DIET, NORMAL, FAT }

    public Dish(String name, boolean vegetarian, int calories, Type type) {
        this.name = name;
        this.vegetarian = vegetarian;
        this.calories = calories;
        this.type = type;
    }

    public String getName() {
        return name;
    }

    public boolean isVegetarian() {
        return vegetarian;
    }

    public int getCalories() {
        return calories;
    }

    public Type getType() {
        return type;
    }

    @Override
    public String toString() {
        return name;
    }

    public static final List menu =
            Arrays.asList( new Dish("pork", false, 800, Dish.Type.MEAT),
                    new Dish("beef", false, 700, Dish.Type.MEAT),
                    new Dish("chicken", false, 400, Dish.Type.MEAT),
                    new Dish("french fries", true, 530, Dish.Type.OTHER),
                    new Dish("rice", true, 350, Dish.Type.OTHER),
                    new Dish("season fruit", true, 120, Dish.Type.OTHER),
                    new Dish("pizza", true, 550, Dish.Type.OTHER),
                    new Dish("prawns", false, 400, Dish.Type.FISH),
                    new Dish("salmon", false, 450, Dish.Type.FISH));
}