RxJava中Observable.concat传入Observable顺序不同结果异常求助

安全阿岳

2026-5-19

关于RxJava concat操作符顺序差异的问题解析

嘿，我来帮你拆解这个困惑！RxJava的concat操作符乍一看只是把多个Observable串起来，但它的核心特性如果没吃透，确实会遇到这种“顺序不同结果不同”的情况。

首先得明确concat的铁律：它会严格按照传入的顺序，先订阅第一个Observable，等它完全完成（也就是调用了onComplete()）之后，才会去订阅并执行第二个Observable。这是导致你看到差异的根本原因。

结合常见的场景，我猜你的两个Observable大概率属于以下情况之一：

其中一个Observable是“无限流”或者没有发送onComplete
比如你用了Observable.interval()这种天生不会自动完成的流，或者自定义Observable时忘了调用subscriber.onComplete()。如果把这个流放在concat的第一个位置，那concat会一直等它完成，第二个Observable永远没机会被订阅；但如果把它放在第二个位置，第一个Observable完成后，它才会启动，这时候你就能看到第二个流的正常执行了。
两个Observable的完成时机/订阅副作用不同
比如第一个是异步操作（比如网络请求），第二个是同步发射数据的just()。如果顺序调换，订阅的时机、数据发射的顺序自然会不一样——毕竟concat是严格按顺序等前一个做完才做下一个。

给你几个实用的排查建议：

检查每个Observable是否都正确触发了onComplete()：这是concat切换到下一个Observable的唯一信号。

给每个Observable加上日志钩子，看清楚订阅和执行的时机：

Observable<Integer> yourFirstObs = ...
        .doOnSubscribe(d -> System.out.println("订阅第一个Observable"))
        .doOnNext(data -> System.out.println("第一个发射：" + data))
        .doOnComplete(() -> System.out.println("第一个完成"));

Observable<Integer> yourSecondObs = ...
        .doOnSubscribe(d -> System.out.println("订阅第二个Observable"))
        .doOnNext(data -> System.out.println("第二个发射：" + data))
        .doOnComplete(() -> System.out.println("第二个完成"));

把这两个Observable按不同顺序传入concat，看日志就能直观看到哪里出问题了。

举个简单的对比例子，你一看就明白：

// 无限流，永远不会完成
Observable<Long> infiniteObs = Observable.interval(1, TimeUnit.SECONDS)
        .doOnSubscribe(d -> System.out.println("订阅无限流"));

// 有限流，发射完数据就完成
Observable<Integer> finiteObs = Observable.just(1,2,3)
        .doOnSubscribe(d -> System.out.println("订阅有限流"))
        .doOnNext(num -> System.out.println("有限流发射：" + num))
        .doOnComplete(() -> System.out.println("有限流完成"));

// 情况1：concat(infiniteObs, finiteObs)
// 结果：只会看到"订阅无限流"，有限流永远不会被订阅
Observable.concat(infiniteObs, finiteObs).subscribe();

// 情况2：concat(finiteObs, infiniteObs)
// 结果：先看到有限流的所有日志，然后才会订阅并启动无限流
Observable.concat(finiteObs, infiniteObs).subscribe();

本质上，concat的顺序差异问题，都是它“顺序执行、等待前一个完成”的特性导致的。对照你的Observable代码排查一下，应该很快就能找到原因啦！

内容的提问来源于stack exchange，提问作者The-null-Pointer-