Java中怎么合并Stream流

這篇文章將為大家詳細(xì)講解有關(guān)Java中怎么合并Stream流，文章內(nèi)容質(zhì)量較高，因此小編分享給大家做個(gè)參考，希望大家閱讀完這篇文章后對(duì)相關(guān)知識(shí)有一定的了解。

成都創(chuàng)新互聯(lián)公司是專(zhuān)業(yè)的響水網(wǎng)站建設(shè)公司，響水接單;提供成都做網(wǎng)站、成都網(wǎng)站制作,網(wǎng)頁(yè)設(shè)計(jì),網(wǎng)站設(shè)計(jì),建網(wǎng)站,PHP網(wǎng)站建設(shè)等專(zhuān)業(yè)做網(wǎng)站服務(wù);采用PHP框架,可快速的進(jìn)行響水網(wǎng)站開(kāi)發(fā)網(wǎng)頁(yè)制作和功能擴(kuò)展;專(zhuān)業(yè)做搜索引擎喜愛(ài)的網(wǎng)站,專(zhuān)業(yè)的做網(wǎng)站團(tuán)隊(duì),希望更多企業(yè)前來(lái)合作!

1. 前言

Java Stream Api[1]提供了很多有用的 Api 讓我們很方便將集合或者多個(gè)同類(lèi)型的元素轉(zhuǎn)換為流進(jìn)行操作。今天我們來(lái)看看如何合并Stream流。  2. Stream 流的合并  Stream流合并的前提是元素的類(lèi)型能夠一致。   

2.1 concat

最簡(jiǎn)單合并流的方法是通過(guò)   Stream.concat()   靜態(tài)方法：  

    Stream<Integer> stream = Stream.of(1, 2, 3);
      
 
     
     
    

      
 
     
     
     Stream<Integer> another = Stream.of(4, 5, 6);
      
 
     
     
    

      
 
     
     
     Stream<Integer> concat = Stream.concat(stream, another);
      
 
     
     
    

      
 
     
     
    

      
 
     
     
     List<Integer> collect = concat.collect(Collectors.toList());
      
 
     
     
    

      
 
     
     
     List<Integer> expected = Lists.list(1, 2, 3, 4, 5, 6);
      
 
     
     
    

      
 
     
     
    

      
 
     
     
     Assertions.assertIterableEquals(expected, collect);
      
 
     
     
    

   
     

    
    
 這種合并是將兩個(gè)流一前一后進(jìn)行拼接：  
Java中怎么合并Stream流  
 

2.2 多個(gè)流的合并

多個(gè)流的合并我們也可以使用上面的方式進(jìn)行“套娃操作”：  

    Stream.concat(Stream.concat(stream, another), more);
      
 
     
     
    

   
     

    
    
 你可以一層一層繼續(xù)套下去，如果需要合并的流多了，看上去不是很清晰。  我之前介紹過(guò)一個(gè)Stream 的 flatmap 操作[2]，它的大致流程可以參考里面的這一張圖：  
Java中怎么合并Stream流  
因此我們可以通過(guò)   flatmap   進(jìn)行實(shí)現(xiàn)合并多個(gè)流：  

    Stream<Integer> stream = Stream.of(1, 2, 3);
      
 
     
     
    

      
 
     
     
     Stream<Integer> another = Stream.of(4, 5, 6);
      
 
     
     
    

      
 
     
     
     Stream<Integer> third = Stream.of(7, 8, 9);
      
 
     
     
    

      
 
     
     
     Stream<Integer> more = Stream.of(0);
      
 
     
     
    

      
 
     
     
     Stream<Integer> concat = Stream.of(stream,another,third,more).
      
 
     
     
    

      
 
     
     
         flatMap(integerStream -> integerStream);
      
 
     
     
    

      
 
     
     
     List<Integer> collect = concat.collect(Collectors.toList());
      
 
     
     
    

      
 
     
     
     List<Integer> expected = Lists.list(1, 2, 3, 4, 5, 6, 7, 8, 9, 0);
      
 
     
     
    

      
 
     
     
     Assertions.assertIterableEquals(expected, collect);
      
 
     
     
    

   
     

    
    
 這種方式是先將多個(gè)流作為元素生成一個(gè)類(lèi)型為   Stream<Stream<T>>   的流，然后進(jìn)行   flatmap   平鋪操作合并。   

2.3 第三方庫(kù)

有很多第三方的強(qiáng)化庫(kù)StreamEx、Jooλ都可以進(jìn)行合并操作。另外反應(yīng)式編程庫(kù)Reactor 3[3]也可以將Stream流合并為反應(yīng)流，在某些場(chǎng)景下可能會(huì)有用。這里演示一下：  

    List<Integer> block = Flux.fromStream(stream)
   
                            .mergeWith(Flux.fromStream(another))
      
   
                                      .collectList()
      
  
                                      .block();

關(guān)于Java中怎么合并Stream流就分享到這里了，希望以上內(nèi)容可以對(duì)大家有一定的幫助，可以學(xué)到更多知識(shí)。如果覺(jué)得文章不錯(cuò)，可以把它分享出去讓更多的人看到。

分享文章：Java中怎么合并Stream流
網(wǎng)站URL：http://bm7419.com/article12/isgegc.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供建站公司、微信小程序、Google、品牌網(wǎng)站建設(shè)、網(wǎng)站制作、搜索引擎優(yōu)化

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶(hù)投稿、用戶(hù)轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請(qǐng)盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng)，如需處理請(qǐng)聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來(lái)源： 創(chuàng)新互聯(lián)

外貿(mào)網(wǎng)站制作