RxJava 2入门：Hello World程序无输出问题求助

嘿，作为RxJava新手遇到这种情况太正常了！我刚学的时候也踩过一模一样的坑😉，结合你的描述和RxJava的特性，大概率是下面这几个常见问题导致的：

1. 忘记给Observable添加订阅（最常见！） #

RxJava里的冷Observable（比如Observable.just()、Observable.from()这类基础创建方法）是「惰性」的——只有当你调用subscribe()方法订阅它时，整个数据流才会启动。如果你的代码只创建了Observable但没订阅，那程序根本不会执行任何发射数据的逻辑，自然没输出。

举个错误示例（和你遇到的情况一致）：

public class Main {
    public static void main(String[] args) {
        // 只创建了Observable，但完全没触发订阅
        Observable.just("我应该被打印出来");
    }
}

修正方法：加上subscribe()，哪怕只是最简单的订阅逻辑：

public class Main {
    public static void main(String[] args) {
        Observable.just("我应该被打印出来")
            .subscribe(System.out::println); // 关键：添加订阅触发数据流
    }
}

2. 使用了后台线程调度，但主线程提前退出 #

如果你的代码里用了subscribeOn(Schedulers.io())或者observeOn(Schedulers.io())这类线程切换操作，而主线程没有等待后台任务完成就直接结束了，程序会在后台线程的任务执行前就退出，同样看不到输出。

错误示例：

public class Main {
    public static void main(String[] args) {
        Observable.just("我在IO线程执行")
            .subscribeOn(Schedulers.io()) // 切换到后台IO线程
            .subscribe(System.out::println);
        // 主线程直接结束，后台线程还没来得及执行
    }
}

修正方法有两种：

• 用blockingSubscribe()代替subscribe()，它会阻塞当前线程直到Observable完成：

public class Main {
    public static void main(String[] args) {
        Observable.just("我在IO线程执行")
            .subscribeOn(Schedulers.io())
            .blockingSubscribe(System.out::println); // 阻塞主线程等待任务完成
    }
}

• 手动让主线程休眠一段时间（适合测试场景）：

public class Main {
    public static void main(String[] args) throws InterruptedException {
        Observable.just("我在IO线程执行")
            .subscribeOn(Schedulers.io())
            .subscribe(System.out::println);
        
        Thread.sleep(1000); // 等待1秒，给后台线程执行时间
    }
}

3. 依赖配置错误 #

如果你的项目没有正确添加RxJava的依赖，或者依赖版本不兼容，可能会出现代码编译通过但运行时没有实际执行逻辑的情况（比如类加载失败，但没有抛出明显的错误提示）。

比如Maven项目要确保添加了正确的依赖：

<dependency>
    <groupId>io.reactivex.rxjava3</groupId>
    <artifactId>rxjava</artifactId>
    <version>3.1.8</version> <!-- 建议用最新稳定版 -->
</dependency>

Gradle项目：

implementation 'io.reactivex.rxjava3:rxjava:3.1.8'

4. 忽略了错误处理 #

有时候Observable可能抛出了异常，但你没有添加错误回调，导致异常被RxJava内部吞掉，也看不到任何输出。建议订阅时加上错误处理逻辑，方便排查问题：

Observable.just("测试字符串")
    .map(s -> { throw new RuntimeException("模拟一个错误"); })
    .subscribe(
        System.out::println,
        error -> System.err.println("出错了：" + error.getMessage()) // 捕获并打印错误
    );

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