RxJava怎么入门

下面给你一个RxJava 入门路线图，偏实用、不堆概念，适合刚接触的人。

一、RxJava 是什么（一句话版）

RxJava = 异步 + 事件流 + 链式编程

你可以把它理解为：

“用一串操作符，优雅地处理数据流（网络、点击、定时器等）”

二、先搞懂 3 个核心概念

1️⃣ Observable（被观察者 / 数据源头）

Observable<String> observable = Observable.create(emitter -> {
    emitter.onNext("Hello");
    emitter.onNext("RxJava");
    emitter.onComplete();
});

2️⃣ Observer（观察者 / 接收数据的人）

Observer<String> observer = new Observer<String>() {
    @Override
    public void onSubscribe(Disposable d) {}

    @Override
    public void onNext(String s) {
        System.out.println(s);
    }

    @Override
    public void onError(Throwable e) {}

    @Override
    public void onComplete() {}
};

3️⃣ subscribe（订阅，把两者连起来）

observable.subscribe(observer);

三、最常用、必须先会的操作符

✅ 创建类

Observable.just("A", "B", "C")
Observable.fromArray(array)
Observable.interval(1, TimeUnit.SECONDS) // 定时

✅ 变换类（非常重要）

.map(x -> x + "!")
.flatMap(x -> Observable.just(x, x))

✅ 过滤类

.filter(x -> x.length() > 2)
.take(3)

✅ 线程切换（RxJava 的灵魂）

.subscribeOn(Schedulers.io())        // 上游线程
.observeOn(AndroidSchedulers.mainThread()) // 下游线程

四、一个完整例子（Android 风格）

Observable.just("请求数据")
    .subscribeOn(Schedulers.io())
    .map(data -> data + " -> 处理完成")
    .observeOn(AndroidSchedulers.mainThread())
    .subscribe(result -> {
        System.out.println(result);
    });

五、入门常见坑

❌ 不搞懂线程切换
❌ 滥用 flatMap
❌ 忘记 dispose（内存泄漏）
✅ 新手先用 map / filter / just

六、学习顺序建议

1. just + subscribe
2. map / filter
3. subscribeOn / observeOn
4. flatMap
5. 实际项目（网络请求）

七、推荐资料

• 官方：ReactiveX
• 《RxJava 2.x 实战》
• 搜：RxJava 操作符思维导图

如果你愿意，我可以： ✅ 用 Android 网络请求 举例
✅ 对比 RxJava vs Kotlin Flow
✅ 给你 练习小任务

你想从哪开始？