如何学习RxJava

学习 RxJava 可以分为“理解思想 → 掌握核心 → 实战练习 → 深入原理”四个阶段。下面给你一条比较系统和可落地的学习路径。

一、先理解响应式编程思想（很重要）

RxJava 不是“又一个异步库”，而是一种编程范式。

1. 核心概念

• 响应式（Reactive）：数据变化自动通知
• 异步（Async）：不阻塞主线程
• 流（Stream）：数据像水流一样被处理

2. 三个核心角色

Observable / Flowable  →  发射数据
Operator               →  转换 / 过滤数据
Observer / Subscriber  →  接收数据

一句话理解：

RxJava 是用“流”的方式处理异步和事件。

二、先学基础 API（必须熟）

1. 创建 Observable

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

2. 订阅

observable.subscribe(
    data -> Log.d("Rx", data),
    error -> Log.e("Rx", error.getMessage()),
    () -> Log.d("Rx", "Complete")
);

3. 常用操作符（重点）

示例：线程切换

Observable.just(1)
    .subscribeOn(Schedulers.io())
    .observeOn(AndroidSchedulers.mainThread())
    .subscribe(i -> updateUI(i));

三、结合 Android 实战（最容易理解）

典型场景

• 网络请求（Retrofit + RxJava）
• 防止按钮重复点击
• 搜索框防抖（debounce）
• 多接口合并（zip）

示例：搜索防抖

RxTextView.textChanges(editText)
    .debounce(300, TimeUnit.MILLISECONDS)
    .switchMap(text -> api.search(text.toString()))
    .subscribe(result -> showResult(result));

四、理解线程模型（难点）

两个关键方法

• subscribeOn()：决定上游在哪执行
• observeOn()：决定下游在哪执行

记住：

subscribeOn 只有第一个有效
observeOn 可以多次切换

五、常见误区（新手必看）

❌ 把 RxJava 当线程池用
❌ 乱用 flatMap 导致顺序错乱
❌ 忘记 dispose() 造成内存泄漏

✅ 推荐用 CompositeDisposable

CompositeDisposable disposable = new CompositeDisposable();
disposable.add(observable.subscribe());
disposable.clear();

六、学习资源推荐

官方

• RxJava GitHub
• ReactiveX 官方文档

中文

• 扔物线《给 Android 开发者的 RxJava 详解》
• 慕课网 / B站 RxJava 教程

书籍

• 《RxJava 实战》
• 《Reactive Programming with RxJava》

七、学习建议（很重要）

1. 不要一上来背操作符
2. 先写 10 个小 Demo
3. 再回头理解“为什么这么设计”
4. 最后看源码（Optional）

如果你愿意，我可以：

• 给你一份 RxJava 学习路线图（PDF结构）
• 或针对 Android / Java 后端 分别讲
• 或直接带你写 第一个 RxJava Demo

你现在是主要用在 Android 还是 后端？