Java Stream 流实现合并操作示例

更新时间：2020年05月20日 11:00:26 作者：码农小胖哥

这篇文章主要介绍了Java Stream 流实现合并操作,结合实例形式详细分析了Java Stream 流实现合并操作原理与相关注意事项,需要的朋友可以参考下

1. 前言

Java Stream Api 提供了很多有用的 Api 让我们很方便将集合或者多个同类型的元素转换为流进行操作。今天我们来看看如何合并 Stream 流。

2. Stream 流的合并

Stream 流合并的前提是元素的类型能够一致。

2.1 concat

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

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);

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

2.2 多个流的合并

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

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

你可以一层一层继续套下去，如果需要合并的流多了，看上去不是很清晰。

我之前介绍过一个Stream 的 flatmap 操作，它的大致流程可以参考里面的这一张图：

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

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);

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

2.3 第三方库

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

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

3. 总结

如果你经常使用 Java Stream Api ，合并 Stream 流是经常遇到的操作。

更多关于java算法相关内容感兴趣的读者可查看本站专题：《Java文件与目录操作技巧汇总》、《Java数据结构与算法教程》、《Java操作DOM节点技巧总结》和《Java缓存操作技巧汇总》

希望本文所述对大家java程序设计有所帮助。

您可能感兴趣的文章:

springboot集成shiro权限管理简单实现
这篇文章主要介绍了springboot集成shiro权限管理简单实现，文章围绕主题展开详细的内容介绍，具有一定的参考价值，需要的小伙伴可以参考一下
2022-08-08
Java实现Dijkstra输出最短路径的实例
这篇文章主要介绍了Java实现Dijkstra输出最短路径的实例的相关资料,希望通过本文能帮助到大家，需要的朋友可以参考下
2017-09-09
详细总结Java堆栈内存、堆外内存、零拷贝浅析与代码实现
零拷贝,这是个耳熟能详的名词,是开发岗面试中经常提及的问题.最近在回顾Netty的基础原理,还是把NIO中关于堆外内存的知识点过了一遍,这里就针对堆栈内存堆外内存和零拷贝这几个概念以及相关知识做一下记录,需要的朋友可以参考下
2021-05-05
一文带你搞懂Java中的泛型和通配符
泛型机制在项目中一直都在使用，甚至很多源码中都用到了泛型机制。但是里面很多的机制和特性一直没有明白，尤其通配符这块，经常忘记。本文对此做了一些总结，具有一定借鉴价值，希望有所帮助
2022-09-09
详细介绍Spring的配置文件
这篇文章主要为大家详细介绍了Spring中的配置文件的命名以及它的配置文件都有些什么。文中的示例代码讲解详细，感兴趣的小伙伴可以跟上小编一起学习一下
2022-10-10
浅析JavaMail发送邮件后再通过JavaMail接收格式问题
这篇文章主要介绍了JavaMail发送邮件后再通过JavaMail接收格式问题 ,本文通过代码实例给大家详细解说，需要的朋友可以参考下
2019-06-06
Java中常用的类型转换(推荐)
这篇文章主要介绍了Java中常用的类型转换(推荐)的相关资料,非常不错，具有参考借鉴价值，需要的朋友可以参考下
2016-06-06
SpringBoot用@Async注解实现异步任务
这篇文章主要介绍了SpringBoot用@Async注解实现异步任务，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
2020-12-12
Spring Boot基础学习之Mybatis操作中使用Redis做缓存详解
这篇文章主要给大家介绍了关于Spring Boot基础学习之Mybatis操作中使用Redis做缓存的相关资料，文中通过示例代码介绍的非常详细，对大家学习或者使用spring boot具有一定的参考学习价值，需要的朋友们下面来一起看看吧
2018-11-11
elasticsearch java客户端action的实现简单分析
这篇文章主要为大家介绍了elasticsearch java客户端action的实现简单分析，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪
2022-04-04