平武建站

Java中Stream流怎么实现合并操作

小编这次要给大家分享的是Java中Stream流怎么实现合并操作，文章内容丰富，感兴趣的小伙伴可以来了解一下，希望大家阅读完这篇文章之后能够有所收获。

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

1. 前言

Java Stream Api 提供了很多有用的 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);

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

Java中Stream流怎么实现合并操作

2.2 多个流的合并

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

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

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

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

Java中Stream流怎么实现合并操作

因此我们可以通过 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 也可以将 Stream 流合并为反应流，在某些场景下可能会有用。这里演示一下：

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

看完这篇关于Java中Stream流怎么实现合并操作的文章，如果觉得文章内容写得不错的话，可以把它分享出去给更多人看到。


本文名称：Java中Stream流怎么实现合并操作
分享地址：http://pwwzsj.com/article/pdhgdg.html

其他资讯