RxSwift中处理多不同模型请求响应问题（无需GCD/Semaphore）

核心问题分析 #

你当前使用Observable.zip的思路是完全正确的，它符合「不依赖GCD/Semaphore，仅用RxSwift实现多请求结果合并」的需求。遇到的问题大概率是以下两种：

1. 模型类型不匹配：请求返回的Observable未完成数据解析，或类型声明错误
2. 多请求场景下元组冗余：当请求数量超过2个时，原生元组会变得难以维护

针对2个请求的修正方案 #

首先确保每个请求的Observable返回已解析完成的对应模型类型，比如：

// 假设你的API服务定义如下
class APIService {
    // 返回解析后的Album模型数组
    func fetchAlbums() -> Observable<[Album]> {
        return URLSession.shared.rx.data(request: URLRequest(url: albumUrl))
            .map { data in
                try JSONDecoder().decode([Album].self, from: data)
            }
    }
    
    // 返回解析后的User模型数组
    func fetchUsers() -> Observable<[User]> {
        return URLSession.shared.rx.data(request: URLRequest(url: userUrl))
            .map { data in
                try JSONDecoder().decode([User].self, from: data)
            }
    }
}

此时你的原代码可以正常工作，订阅时能直接拿到强类型的模型：

Observable.zip(service.fetchAlbums(), service.fetchUsers())
    .subscribe(onNext: { albums, users in
        // albums 是 [Album] 类型，users 是 [User] 类型
        print(albums)
        print(users)
    })
    .disposed(by: self.disposeBag)

如果需要处理请求失败的情况，给每个请求添加错误兜底，避免单个请求失败导致整个序列终止：

Observable.zip(
    service.fetchAlbums().catchAndReturn([]), // 请求失败时返回空数组
    service.fetchUsers().catchAndReturn([])
)
.subscribe(onNext: { albums, users in
    print(albums)
    print(users)
}, onError: { error in
    print("全局错误：\(error)")
})
.disposed(by: self.disposeBag)

针对3个及以上请求的优化方案 #

当请求数量较多时，原生元组会变得冗长，推荐用自定义结构体+数组版zip来管理结果：

1. 定义一个结构体统一封装所有请求结果：

struct CombinedResponse {
    let albums: [Album]
    let users: [User]
    let posts: [Post]
}

2. 使用数组参数的Observable.zip，并通过map转换为自定义结构体：

Observable.zip([
    service.fetchAlbums(),
    service.fetchUsers(),
    service.fetchPosts()
])
.map { responses in
    // 强转类型，确保每个请求的返回类型与结构体字段匹配
    let albums = responses[0] as! [Album]
    let users = responses[1] as! [User]
    let posts = responses[2] as! [Post]
    return CombinedResponse(albums: albums, users: users, posts: posts)
}
.subscribe(onNext: { combined in
    print(combined.albums)
    print(combined.users)
    print(combined.posts)
})
.disposed(by: self.disposeBag)

关键注意点 #

• zip的特性：会等待所有Observable都发射一个元素后，才会组合发射结果；如果其中一个Observable完成，整个zip序列会停止发射新元素
• 类型安全：务必确保每个请求的Observable返回正确的模型类型，避免运行时类型转换错误
• 错误处理：如果不需要单个请求失败终止整个序列，给每个请求添加catchAndReturn或retry操作符

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