RxJava与Retrofit怎么结合

在 Android / Java 网络请求开发中，Retrofit 负责定义和发起请求，RxJava 负责异步数据流处理，二者结合非常常见。下面从「基本用法 → 常见操作 → 注意事项」一步步说明。

一、基本依赖

implementation 'io.reactivex.rxjava3:rxjava:3.x.x'
implementation 'io.reactivex.rxjava3:rxandroid:3.x.x'
implementation 'com.squareup.retrofit2:retrofit:2.x.x'
implementation 'com.squareup.retrofit2:converter-gson:2.x.x'
implementation 'com.squareup.retrofit2:adapter-rxjava3:2.x.x'

注意：RxJava2 用 adapter-rxjava2，RxJava3 用 adapter-rxjava3

二、Retrofit 配置（关键）

Retrofit retrofit = new Retrofit.Builder()
        .baseUrl("https://api.example.com/")
        .addConverterFactory(GsonConverterFactory.create())
        .addCallAdapterFactory(RxJava3CallAdapterFactory.create()) // 关键
        .build();

三、定义接口（返回 Observable / Single）

1️⃣ 返回 Observable

public interface ApiService {
    @GET("user/{id}")
    Observable<User> getUser(@Path("id") String id);
}

2️⃣ 返回 Single（推荐，只发一次）

@GET("user/{id}")
Single<User> getUser(@Path("id") String id);

四、发起请求（结合 RxJava）

apiService.getUser("123")
    .subscribeOn(Schedulers.io())        // 网络请求在 IO 线程
    .observeOn(AndroidSchedulers.mainThread()) // 主线程更新 UI
    .subscribe(
        user -> {
            // 成功
        },
        throwable -> {
            // 失败
        }
    );

五、常用操作符示例

✅ 1. 扁平化请求（串行）

apiService.login()
    .flatMap(token -> apiService.getUserInfo(token))
    .subscribeOn(Schedulers.io())
    .observeOn(AndroidSchedulers.mainThread())
    .subscribe(
        userInfo -> {},
        error -> {}
    );

✅ 2. 合并多个请求（并行）

Single.zip(
    apiService.getA(),
    apiService.getB(),
    (a, b) -> new Result(a, b)
).subscribeOn(Schedulers.io())
 .observeOn(AndroidSchedulers.mainThread())
 .subscribe(result -> {});

✅ 3. 错误处理

apiService.getData()
    .onErrorReturn(throwable -> defaultValue)
    .subscribe(data -> {});

六、生命周期管理（很重要）

使用 CompositeDisposable

CompositeDisposable disposable = new CompositeDisposable();

disposable.add(
    apiService.getUser("1")
        .subscribe(...)
);

@Override
protected void onDestroy() {
    disposable.clear();
}

七、RxJava + Retrofit 的优势

• ✅ 链式调用，逻辑清晰
• ✅ 线程切换简单
• ✅ 轻松处理多个接口组合
• ✅ 错误统一处理

八、RxJava or 协程？

如果你愿意，我可以：

• ✅ 给你一个完整 Demo
• ✅ 对比 RxJava vs 协程
• ✅ 讲 背压 / 线程切换原理

你更想看哪一个？