Java中怎么合并Stream流

这篇文章将为大家详细讲解有关Java中怎么合并Stream流，文章内容质量较高，因此小编分享给大家做个参考，希望大家阅读完这篇文章后对相关知识有一定的了解。

成都创新互联公司是专业的响水网站建设公司，响水接单;提供成都做网站、成都网站制作,网页设计,网站设计,建网站,PHP网站建设等专业做网站服务;采用PHP框架,可快速的进行响水网站开发网页制作和功能扩展;专业做搜索引擎喜爱的网站,专业的做网站团队,希望更多企业前来合作!

1. 前言

Java Stream Api^[1]提供了很多有用的 Api 让我们很方便将集合或者多个同类型的元素转换为流进行操作。今天我们来看看如何合并Stream流。  2. Stream 流的合并  Stream流合并的前提是元素的类型能够一致。   

2.1 concat

最简单合并流的方法是通过   Stream.concat()   静态方法：  

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

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

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

      
 
     
     
    

      
 
     
     
     List collect = concat.collect(Collectors.toList());
      
 
     
     
    

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

      
 
     
     
    

      
 
     
     
     Assertions.assertIterableEquals(expected, collect);
      
 
     
     
    

   
     

    
    

 这种合并是将两个流一前一后进行拼接：  

 

 

2.2 多个流的合并

多个流的合并我们也可以使用上面的方式进行“套娃操作”：  

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

   
     

    
    

 你可以一层一层继续套下去，如果需要合并的流多了，看上去不是很清晰。  我之前介绍过一个Stream 的 flatmap 操作^[2]，它的大致流程可以参考里面的这一张图：  

 

因此我们可以通过   flatmap   进行实现合并多个流：  

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

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

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

      
 
     
     
     Stream more = Stream.of(0);
      
 
     
     
    

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

      
 
     
     
         flatMap(integerStream -> integerStream);
      
 
     
     
    

      
 
     
     
     List collect = concat.collect(Collectors.toList());
      
 
     
     
    

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

      
 
     
     
     Assertions.assertIterableEquals(expected, collect);
      
 
     
     
    

   
     

    
    

 这种方式是先将多个流作为元素生成一个类型为   Stream>   的流，然后进行   flatmap   平铺操作合并。   

2.3 第三方库

有很多第三方的强化库StreamEx、Jooλ都可以进行合并操作。另外反应式编程库Reactor 3^[3]也可以将Stream流合并为反应流，在某些场景下可能会有用。这里演示一下：  

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

关于Java中怎么合并Stream流就分享到这里了，希望以上内容可以对大家有一定的帮助，可以学到更多知识。如果觉得文章不错，可以把它分享出去让更多的人看到。

文章标题：Java中怎么合并Stream流
转载来于：http://cqcxhl.cn/article/isgegc.html