Java?流處理之收集器詳解
Java 流（Stream）處理操作完成之后，我們可以收集這個流中的元素，使之匯聚成一個最終結(jié)果。這個結(jié)果可以是一個對象，也可以是一個集合，甚至可以是一個基本類型數(shù)據(jù)。
以記錄 Record 為例：
@Data
@NoArgsConstructor
@AllArgsConstructor
public static class Record {
private String col1;
private String col2;
private int col3;
}記錄 Record 包含三個屬性：列1（col1）、列2（col2）和 列3（col3）。
創(chuàng)建四個記錄實例：
Record r1 = new Record("a", "1", 1);
Record r2 = new Record("a", "2", 2);
Record r3 = new Record("b", "3", 3);
Record r4 = new Record("c", "4", 4);添加到列表：
List<Record> records = new ArrayList<>(); records.add(r1); records.add(r2); records.add(r3); records.add(r4);
收集所有記錄的 列1 值，以列表形式存儲結(jié)果
List<String> col1List = records.stream()
.map(Record::getCol1)
.collect(Collectors.toList());
log.info("col1List: {}", Json.toJson(col1List));輸出結(jié)果：
col1List: ["a","a","b","c"]
收集所有記錄的 列1 值，且去重，以集合形式存儲
Set<String> col1Set = records.stream()
.map(Record::getCol1)
.collect(Collectors.toSet());
log.info("col1Set: {}", Json.toJson(col1Set));輸出結(jié)果：
col1Set: ["a","b","c"]
收集記錄的 列2 值和 列3 值的對應(yīng)關(guān)系，以字典形式存儲
Map<String, Integer> col2Map = records.stream()
.collect(Collectors.toMap(Record::getCol2, Record::getCol3));
log.info("col2Map: {}", Json.toJson(col2Map));輸出結(jié)果：
col2Map: {"1":1,"2":2,"3":3,"4":4}
記錄的 列2 不能有重復值，否則會拋出 Duplicate key 異常。
收集所有記錄中 列3 值最大的記錄
Record max = records.stream()
.collect(Collectors.maxBy(Comparator.comparing(Record::getCol3)))
.orElse(null);
log.info("max: {}", Json.toJson(max));輸出結(jié)果：
max: {"col1":"c","col2":"4","col3":4}
收集所有記錄中 列3 值的總和
int sum = records.stream()
.collect(Collectors.summingInt(Record::getCol3));
log.info("sum: {}", sum);輸出結(jié)果：
sum: 10
流的收集需要通過 Stream.collect() 方法完成，方法的參數(shù)是一個 Collector（收集器） ；收集結(jié)果時，需要根據(jù)收集結(jié)果的目標類型，傳遞特定的收集器實例，如上：
Collectors.toList()
Collectors.toSet()
Collectors.toMap()
Collectors.maxBy()
Collectors.summingInt()
Collectors（java.util.stream.Collectors） 是一個工具類，內(nèi)置若干收集器，我們可以通過調(diào)用不同的方法快速獲取相應(yīng)的收集器實例。
收集器（java.util.stream.Collector）本質(zhì)是一個 接口 ，包含以下五個方法：
Supplier supplier()
BiConsumer<A, T> accumulator()
BinaryOperator combiner()
Function<A, R> finisher()
Set characteristics()
以 Collectors.toList() 為例演示收集器的工作過程。
創(chuàng)建一個中間結(jié)果容器
supplier() 方法會返回一個 Supplier 實例，調(diào)用該實例的 get() 方法，會創(chuàng)建一個中間結(jié)果容器。
@Override
public Supplier<List<String>> supplier() {
return new Supplier<List<String>>() {
@Override
public List<String> get() {
List<String> container = new ArrayList<>();
return container;
}
};
}考慮到收集的元素類型 String，這里的中間結(jié)果容器類型為 ArrayList 。
根據(jù)收集過程的需要，中間結(jié)果容器可以是任意的數(shù)據(jù)結(jié)構(gòu)。
逐一遍歷流中的每個元素，處理完成之后，添加到中間結(jié)果
accumulator() 方法會返回一個 BiConsumer 實例，它有一個 accept() 方法，
參數(shù)1：中間結(jié)果 參數(shù)2：流中遍歷到的某個元素
遍歷過程是 Java 自動完成的，每遍歷一個元素，會自動調(diào)用 BiConsumer.accept 方法。我們只需要在方法中實現(xiàn)元素的處理過程，然后把元素的處理結(jié)果添加到中間結(jié)果中就可以了。
@Override
public BiConsumer<List<String>, String> accumulator() {
return new BiConsumer<List<String>, String>() {
@Override
public void accept(List<String> container, String col) {
container.add(col);
}
};
}這個示例中，流中的元素不需要任何處理，直接添加至中間結(jié)果即可。
中間結(jié)果轉(zhuǎn)換成最終結(jié)果
finisher() 方法會返回一個 Fuction 實例，它有一個 apply() 方法，
參數(shù)：中間結(jié)果 返回：最終結(jié)果
遍歷過程結(jié)束之后，Java 會自動調(diào)用 Function.apply() 方法，將中間結(jié)果轉(zhuǎn)換成最終結(jié)果。
@Override
public Function<List<String>, List<String>> finisher() {
return new Function<List<String>, List<String>>() {
@Override
public List<String> apply(List<String> container) {
return container;
}
};
}這個示例中，中間結(jié)果就是最終結(jié)果，不需要任何處理，直接返回中間結(jié)果即可。
combiner()是做什么的？
流中的元素可以被并行處理，這樣的流稱為并行流。并行流相當于把一個大流切分成多個小流，內(nèi)部使用多線程，并行處理這些小流。每一個小流遍歷完成之后，都會產(chǎn)生一個小的中間結(jié)果，需要將這些小的中間結(jié)果合并成一個大的中間結(jié)果。
假設(shè)有兩個小流，收集開始時，會創(chuàng)建兩個中間結(jié)果：
中間結(jié)果也是通過 Supplier.get() 方法創(chuàng)建的。
并行遍歷兩個小流，將各自流的處理結(jié)果添加到各自的中間結(jié)果中：
combiner() 方法會返回一個 BinaryOperator 實例，它有一個 apply() 方法：
參數(shù)1：中間結(jié)果1 參數(shù)2：中間結(jié)果2 返回：中間結(jié)果
Java 會在合適的時機自動調(diào)用 BinaryOperator.apply() 方法，將小的中間結(jié)果合并成大的中間結(jié)果。
@Override
public BinaryOperator<List<String>> combiner() {
return new BinaryOperator<List<String>>() {
@Override
public List<String> apply(List<String> container1, List<String> container2) {
container1.addAll(container2);
return container1;
}
};
}characteristics()是什么的？
characteristics() 會返回一個 Characteristics（枚舉）集合實例，用于設(shè)定收集器的特性，支持以下三個值：
CONCURRENT
收集器支持并發(fā)使用
UNORDERED
收集器不保證元素順序
IDENTITY_FINISH
收集器中間結(jié)果可直接轉(zhuǎn)換成最終結(jié)果
Java 可以根據(jù)這些特性值，保證收集器正確地、有效率地執(zhí)行。
完整代碼
Collector<String, List<String>, List<String>> collector = new Collector<String, List<String>, List<String>>() {
@Override
public Supplier<List<String>> supplier() {
return new Supplier<List<String>>() {
@Override
public List<String> get() {
List<String> container = new ArrayList<>();
return container;
}
};
}
@Override
public BiConsumer<List<String>, String> accumulator() {
return new BiConsumer<List<String>, String>() {
@Override
public void accept(List<String> container, String col) {
container.add(col);
}
};
}
@Override
public BinaryOperator<List<String>> combiner() {
return new BinaryOperator<List<String>>() {
@Override
public List<String> apply(List<String> container1, List<String> container2) {
container1.addAll(container2);
return container1;
}
};
}
@Override
public Function<List<String>, List<String>> finisher() {
return new Function<List<String>, List<String>>() {
@Override
public List<String> apply(List<String> container) {
return container;
}
};
}
@Override
public Set<Characteristics> characteristics() {
return new HashSet<>();
}
};
col1List = records.stream()
.map(Record::getCol1)
.collect(collector);
log.info("col1List: {}", Json.toJson(col1List));到此這篇關(guān)于Java 流處理之收集器的文章就介紹到這了,更多相關(guān)Java 收集器內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！
相關(guān)文章
Java協(xié)程編程之Loom項目實戰(zhàn)記錄
這篇文章主要介紹了Java協(xié)程編程之Loom項目嘗鮮,如果用嘗鮮的角度去使用Loom項目，可以提前窺探JVM開發(fā)者們是如何基于協(xié)程這個重大特性進行開發(fā)的，這對于提高學習JDK內(nèi)核代碼的興趣有不少幫助，需要的朋友可以參考下2021-08-08
這篇文章主要介紹了Spring中的事務(wù)管理,以實例形式詳細分析了事務(wù)的概念與特性以及事物管理的具體用法,需要的朋友可以參考下2014-11-11
java控制Pdf自動打印的小例子，需要的朋友可以參考一下2013-04-04
javaweb實現(xiàn)百度GPS定位接口（經(jīng)緯度）
這篇文章主要介紹了javaweb實現(xiàn)百度GPS定位接口（經(jīng)緯度），文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2020-02-02
Java數(shù)據(jù)結(jié)構(gòu)之隊列的簡單定義與使用方法
這篇文章主要介紹了Java數(shù)據(jù)結(jié)構(gòu)之隊列的簡單定義與使用方法,簡單描述了隊列的功能、特點,并結(jié)合java實例形式分析了隊列的簡單定義與使用方法,需要的朋友可以參考下2017-10-10
在本篇文章里給大家介紹了關(guān)于學習java后的職業(yè)道路，以及需要學習的相關(guān)知識內(nèi)容，有興趣的朋友們可以跟著學習下。2022-11-11
Java?MethodHandles介紹與反射對比區(qū)別詳解
這篇文章主要為大家介紹了Java?MethodHandles介紹與反射對比區(qū)別詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪2023-11-11
本文主要對Java算法逆波蘭表達式的相關(guān)內(nèi)容作了介紹，涉及逆波蘭表達式的定義已經(jīng)在Java中的實現(xiàn)，具有一定參考價值，需要的朋友可以了解下。2017-10-10
這篇文章主要介紹了this關(guān)鍵字，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2019-03-03
Spring?Boot+Aop記錄用戶操作日志實戰(zhàn)記錄
在Spring框架中使用AOP配合自定義注解可以方便的實現(xiàn)用戶操作的監(jiān)控,下面這篇文章主要給大家介紹了關(guān)于Spring?Boot+Aop記錄用戶操作日志實戰(zhàn)的相關(guān)資料,文中通過實例代碼介紹的非常詳細,需要的朋友可以參考下2023-04-04