Android中RxJava+Retrofit实现依赖式多请求的方法咨询

嘿，这个需求完全可行！RxJava的操作符天生就是为这类有依赖关系的异步任务设计的，其中flatMap就是解决这个问题的核心工具——它能把第一个请求的结果作为输入，无缝发起第二个请求，完美串联起这两个调用。

核心思路 #

flatMap的作用是将Observable发射的数据转换为另一个Observable，刚好适配“用第一个请求的响应值作为第二个请求参数”的场景：

1. 先发起第一个网络请求，拿到响应结果
2. 用这个结果作为参数，发起第二个网络请求
3. 最终订阅第二个请求的结果（或组合后的结果）

代码示例 #

首先假设你已经定义好Retrofit的API接口（返回Observable类型）：

// 你的Retrofit Service接口
public interface ApiService {
    // 第一个请求：获取用户信息，返回Observable<User>
    @GET("users/profile")
    Observable<User> getUserProfile();

    // 第二个请求：依赖第一个请求的userId，获取用户订单列表
    @GET("orders")
    Observable<List<Order>> getUserOrders(@Query("userId") String userId);
}

接下来是串联两个请求的核心逻辑：

// 初始化ApiService（这里默认你已经完成Retrofit的基础配置）
ApiService apiService = retrofit.create(ApiService.class);

// 执行依赖式请求
apiService.getUserProfile()
    .subscribeOn(Schedulers.io()) // 指定网络请求在IO线程执行
    .flatMap(user -> {
        // 第一个请求成功拿到User，用它的userId发起第二个请求
        return apiService.getUserOrders(user.getUserId());
    })
    .observeOn(AndroidSchedulers.mainThread()) // 切换回主线程处理结果/更新UI
    .subscribe(
        // 第二个请求成功的回调
        orders -> {
            Log.d("RxDemo", "订单列表获取成功，共" + orders.size() + "条");
            // 在这里处理订单数据，比如更新RecyclerView
        },
        // 异常回调：第一个或第二个请求失败都会触发
        throwable -> {
            Log.e("RxDemo", "请求出错", throwable);
            // 在这里处理错误，比如显示Toast提示用户
        }
    );

进阶：保留第一个请求的结果 #

如果需要同时使用第一个请求的用户信息和第二个请求的订单数据，可以在flatMap里把两个结果组合起来：

apiService.getUserProfile()
    .subscribeOn(Schedulers.io())
    .flatMap(user -> {
        // 把用户信息和订单列表组合成Pair返回
        return apiService.getUserOrders(user.getUserId())
                .map(orders -> new Pair<>(user, orders));
    })
    .observeOn(AndroidSchedulers.mainThread())
    .subscribe(
        userOrdersPair -> {
            User user = userOrdersPair.first;
            List<Order> orders = userOrdersPair.second;
            // 同时处理用户信息和订单数据
            Log.d("RxDemo", "用户" + user.getUserName() + "的订单数：" + orders.size());
        },
        throwable -> {
            // 异常处理
        }
    );

注意事项 #

• 线程调度：务必用subscribeOn(Schedulers.io())指定网络请求在IO线程，避免阻塞主线程；用observeOn(AndroidSchedulers.mainThread())切换回主线程更新UI。
• 异常处理：任何一个请求失败都会触发subscribe的错误回调，你可以在这里统一处理错误逻辑，比如区分是第一个还是第二个请求失败（通过异常信息判断）。
• 内存泄漏：如果是在Activity/Fragment中使用，记得在生命周期销毁时取消订阅（可以用CompositeDisposable管理订阅）。

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