RxJava/RxAndroid多API数据获取：从用户ID列表获取用户列表的最优实现

针对你描述的业务场景，最优实现方式是结合flatMapIterable、flatMap（带并发控制）和toList操作符，既能高效处理批量请求，又能避免因并发数过高导致的服务端压力或客户端资源耗尽问题。

核心实现代码 #

// 基础实现（无并发限制，适合ID数量较少的场景）
fetchUserIds()
    .flatMapIterable { userIds -> userIds } // 将ID列表拆分为单个ID的数据流
    .flatMap { userId -> fetchUser(userId) } // 并行请求每个用户信息
    .toList() // 将所有用户结果收集为List<User>
    .subscribe(
        { users -> // 处理最终的用户列表
            // 业务逻辑处理
        },
        { error -> // 处理异常
            // 异常处理逻辑
        }
    )

// 带并发限制的实现（适合ID数量较多的场景，避免请求过载）
fetchUserIds()
    .flatMapIterable { userIds -> userIds }
    .flatMap(
        { userId -> fetchUser(userId) },
        maxConcurrency = 5 // 限制同时发起的请求数为5，可根据实际场景调整
    )
    .toList()
    .subscribe(
        { users -> /* 处理用户列表 */ },
        { error -> /* 处理异常 */ }
    )

方案说明 #

1. flatMapIterable：把Single<List<String>>转换为发射单个ID的Observable<String>，是拆分列表最简洁高效的方式。
2. flatMap：支持并行发起fetchUser请求，相比串行的concatMap能大幅提升请求效率；通过maxConcurrency参数可以控制并发数，平衡性能和服务端压力。
3. toList：自动收集所有发射的User对象，最终返回Single<List<User>>，正好匹配业务需求的结果类型。

如果需要严格保持用户列表和原ID列表的顺序，可以把flatMap替换为concatMapEager（它会并行发起请求但按顺序收集结果），不过性能会略低于带并发限制的flatMap，需根据业务优先级选择。

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