如何在Apache Flink中按顺序拼接两个流？

我完全懂你想要的效果——先把第一个流的所有元素挨个输出完，再开始处理第二个流的元素，最终得到严格按1、2、3、4、5排列的合并流。你说之前尝试没保住顺序，哪怕加了时间戳也没用，估计是用了并行或者合并类的操作，而不是专门的顺序拼接工具。

下面给你几个主流场景下的解决方案：

Java 普通 Stream 场景 #

如果你用的是Java 8及以上的标准Stream，直接用Stream.concat()就完美解决，它会严格先遍历完第一个流的所有元素，再处理第二个流：

Stream<Integer> firstStream = Stream.of(1, 2, 3);
Stream<Integer> secondStream = Stream.of(4, 5);
Stream<Integer> combinedStream = Stream.concat(firstStream, secondStream);

// 执行遍历会按顺序输出1、2、3、4、5
combinedStream.forEach(num -> System.out.print(num + "、"));

这个方法本身就是为顺序拼接设计的，完全不会打乱元素顺序。

响应式流场景（RxJava） #

如果是用RxJava处理响应式流，一定要用Observable.concat()（或Flowable.concat()），别用merge()——merge会并行处理多个流，很容易打乱顺序。示例代码：

Observable<Integer> obs1 = Observable.just(1, 2, 3);
Observable<Integer> obs2 = Observable.just(4, 5);
Observable<Integer> combinedObs = Observable.concat(obs1, obs2);

combinedObs.subscribe(num -> System.out.print(num + "、"));

哪怕你的流带有时间戳，只要用concat，就会等第一个流完全结束（onComplete触发）后，才会订阅并处理第二个流的元素，绝对能保证顺序。

响应式流场景（Project Reactor/Spring WebFlux） #

Spring生态常用的Reactor框架里，对应的顺序拼接操作是concatWith()或者Flux.concat()：

Flux<Integer> flux1 = Flux.just(1, 2, 3);
Flux<Integer> flux2 = Flux.just(4, 5);
Flux<Integer> combinedFlux = flux1.concatWith(flux2);
// 也可以用 Flux.concat(flux1, flux2);

combinedFlux.subscribe(num -> System.out.print(num + "、"));

和前面的逻辑一样，concat系列操作符会严格按顺序订阅源，前一个流处理完毕后才会启动下一个，完全符合你的需求。

避坑提醒 #

你之前可能踩的坑是用了merge类操作（比如RxJava的merge、Reactor的mergeWith），或者给Stream开启了并行模式——这些操作会同时处理多个流的元素，自然会打乱顺序。核心就是要选专门的顺序拼接操作符，而不是并行合并类的。

内容的提问来源于stack exchange，提问作者Albert Bikeev