Android项目：Repository并行网络请求实现或移至ViewModel可行吗？

一、能否将并行请求逻辑移至ViewModel？ #

技术上完全可行，但不推荐。ViewModel的核心职责是管理UI状态、处理用户交互，如果把网络请求的并行调度、数据合并逻辑放到ViewModel中，会让它承担数据层的职责，违反单一职责原则：

• 后续其他ViewModel需要相同并行逻辑时，会出现代码重复；
• ViewModel会变得臃肿，难以维护和测试；
• 数据层逻辑（如请求重试、缓存策略）与UI层耦合，不利于后续扩展。

如果只是临时快速验证功能可以这么做，但长期来看建议把数据相关逻辑保留在Repository层。

二、在Repository中实现并行网络请求的方案 #

Repository层完全可以实现Coroutine的并行请求，核心是正确管理CoroutineScope，以下是具体实现方式：

1. 依赖外部传入的CoroutineScope（推荐） #

通过ViewModel调用Repository方法时，传入viewModelScope（自带生命周期感知，避免内存泄漏），在Repository内部用async启动并行任务：

class PostsRepository(private val apiService: ApiService) {
    // 接收外部传入的Scope，推荐用viewModelScope
    suspend fun fetchCombinedPost(scope: CoroutineScope): Post {
        // 启动两个并行的异步请求
        val newsPostDeferred = scope.async(Dispatchers.IO) {
            apiService.getNewspost()
        }
        val postPriceDeferred = scope.async(Dispatchers.IO) {
            apiService.getPostPrice()
        }

        // 等待两个请求都完成，获取结果
        val newsPost = newsPostDeferred.await()
        val postPrice = postPriceDeferred.await()

        // 合并结果为Post数据类
        return Post(
            content = newsPost.content,
            price = postPrice.price,
            // 填充其他字段...
        )
    }
}

// ViewModel中的调用示例
class PostViewModel(private val repo: PostsRepository) : ViewModel() {
    fun loadPost() {
        viewModelScope.launch {
            try {
                val post = repo.fetchCombinedPost(viewModelScope)
                // 更新UI状态
            } catch (e: Exception) {
                // 处理请求错误
            }
        }
    }
}

2. Repository内部创建CoroutineScope（需注意生命周期） #

如果不想依赖外部传入的Scope，也可以在Repository内部创建独立的Scope，但必须在合适时机取消（比如Repository被销毁时），避免内存泄漏：

class PostsRepository(private val apiService: ApiService) {
    private val repoScope = CoroutineScope(Dispatchers.IO + SupervisorJob())

    suspend fun fetchCombinedPost(): Post {
        val newsPostDeferred = repoScope.async {
            apiService.getNewspost()
        }
        val postPriceDeferred = repoScope.async {
            apiService.getPostPrice()
        }

        val newsPost = newsPostDeferred.await()
        val postPrice = postPriceDeferred.await()

        return Post(/* 合并字段 */)
    }

    // 当Repository不再使用时，调用该方法取消所有协程
    fun clear() {
        repoScope.cancel()
    }
}

这种方式需要上层（比如ViewModel）在合适时机调用clear()方法，比如ViewModel的onCleared()生命周期回调中。

关键说明 #

• async启动的任务会并行执行，相比串行请求能大幅减少总耗时；
• 网络请求必须在Dispatchers.IO调度器中执行，避免阻塞主线程；
• 可以用SupervisorJob保证一个请求失败不会影响另一个请求的执行（根据业务需求选择）。

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