快捷導(dǎo)航

Java8實(shí)現(xiàn)Stream流的合并的方法展示

更新時(shí)間：2023年05月06日 08:17:29 作者：xfcoding

本文介紹了Java8中Stream流的合并方法，包括concat()、flatMap()和reduce()三種方法。其中，concat()方法可以將兩個(gè)Stream流合并成一個(gè)，flatMap()方法可以將一個(gè)Stream流中的元素映射成多個(gè)Stream流并合并成一個(gè)，reduce()方法可以將Stream流中的元素逐個(gè)合并成一個(gè)結(jié)果

最近的需求里有這樣一個(gè)場(chǎng)景，要校驗(yàn)一個(gè)集合中每個(gè)對(duì)象的多個(gè)Id的有效性。比如一個(gè)Customer對(duì)象，有3個(gè)Id：id1，id2，id3，要把這些Id全部取出來，然后去數(shù)據(jù)庫里查詢它是否存在。

@Data
@AllArgsConstructor
public class Customer {
    private String name;
    private String id1;
    private String id2;
    private String id3;
}

在通常情況下，我們要從集合中取出一個(gè)對(duì)象屬性，很好辦，用這個(gè)辦法：

customerList.stream().map(Customer::getId1).filter(Objects::nonNull).collect(Collectors.toList())

現(xiàn)在要取3個(gè)字段，怎么做呢？

Stream.concat

Stream接口中的靜態(tài)方法concat，可以把兩個(gè)流合成一個(gè)，我們?nèi)?個(gè)字段可以合并兩次：

Stream<String> concat = Stream.concat(customerList.stream().map(Customer::getId1),
		customerList.stream().map(Customer::getId2));
List<String> ids = Stream.concat(concat, customerList.stream().map(Customer::getId3))
        .filter(Objects::nonNull)
        .collect(Collectors.toList());

取4個(gè)字段，就再繼續(xù)合并。但是這種不夠簡潔，可以使用扁平化流flatMap。

flatMap

flatmap方法讓你把一個(gè)流中的每個(gè)值都換成另一個(gè)流，然后把所有的流連接起來成為一個(gè)流。

Stream.flatMap方法的入?yún)橐粋€(gè)Function函數(shù)，函數(shù)返回值的泛型要求為Stream類型。對(duì)比一下，map和flatMap都是將流中的元素映射為我們想要的值，只是flatMap映射的結(jié)果是一個(gè)新的Stream。

而Stream.of方法剛好可以構(gòu)建一個(gè)類型為Stream的原始流，以供flatMap操作。

List<String> ids = Stream.of(customerList.stream().map(Customer::getId1),
                             customerList.stream().map(Customer::getId2),
                             customerList.stream().map(Customer::getId3))
        .flatMap(idStream -> idStream)
        .filter(Objects::nonNull)
        .collect(Collectors.toList());

注意，Stream.of方法返回的流的泛型跟方法入?yún)⒌念愋褪且粯?，上面的代碼就相當(dāng)于，Stream.of(stream, stream, stream)，得到的結(jié)果就是Stream<Stream>，緊接著用flatMap扁平化處理，把每一個(gè)元素合成一個(gè)新流。

Java8中的Stream流提供了多種合并方法，可以方便地將多個(gè)Stream流合并成一個(gè)。其中，concat()方法適用于兩個(gè)Stream流的合并，flatMap()方法適用于將一個(gè)Stream流中的元素映射成多個(gè)Stream流并合并成一個(gè)，reduce()方法適用于將Stream流中的元素逐個(gè)合并成一個(gè)結(jié)果。在實(shí)際開發(fā)中，可以根據(jù)具體需求選擇不同的合并方法，提高代碼的可讀性和效率。

到此這篇關(guān)于Java8實(shí)現(xiàn)Stream流的合并的方法展示的文章就介紹到這了,更多相關(guān)Java8 Stream流的合并內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: