后端控制器如何用Kotlin协程同时调用多个端点并返回正确结果

原有代码的核心问题 #

• 滥用GlobalScope.launch启动协程是出现异常的根本原因：GlobalScope是和应用整体生命周期绑定的顶层作用域，通过它启动的协程和当前函数的执行流程完全解耦，不会被当前函数感知和等待。
  • launch本身是“发射后不管”的协程构建器，没有返回值，自然无法在块内部直接给外层函数返回结果，在launch块内加return的写法从语法上就不被允许。
  • 函数执行到GlobalScope.launch代码时，只会把协程任务丢到后台调度器排队，不会挂起等待它执行完成，所以会直接走到后续的返回逻辑——此时两个接口请求还在后台执行，combinedResult自然处于未初始化状态，也就出现了你调试时看到的“返回逻辑比接口await先执行”的现象。
• 没有把异步任务的执行和结果获取绑定到当前suspend函数的调用链上，协程任务的执行结果没有和当前函数的返回流程做关联。

参考修改版本的待优化点 #

你基于建议修改后的代码虽然能跑通结果，但存在明显的协程使用误区：

• 在普通同步函数里用runBlocking包裹协程逻辑，虽然能通过阻塞线程拿到异步结果，但runBlocking会强制占用当前线程直到所有协程执行完成，完全违背了协程“非阻塞并发”的设计初衷，在后端高并发场景下很容易快速耗尽线程池资源。
• runBlocking块内直接启动两个async任务，没有清晰的作用域边界，协程的取消、异常传播逻辑都不受控。

正确的实现逻辑 #

后端场景下用协程做并发请求，核心原则是不要手动绑定顶层全局作用域，不要用阻塞式的runBlocking，直接利用suspend函数的可挂起特性，依托协程自带的作用域管理能力完成并发任务调度。

最终调整后的代码示例 #

@Singleton
class PersonEndpoint {
    @Inject
    lateinit var employeClient: EmployeClient

    override suspend fun getPersonDetails(request: PersonRequest): PersonResponse {
        // coroutineScope会自动等待块内所有子任务执行完成才退出，本身是suspend函数不会阻塞线程
        val combinedResult = coroutineScope {
            // 并发启动两个接口请求，不需要手动管理线程
            val employeesA = async { employeClient.getEmployeesA() }
            val employeesB = async { employeClient.getEmployeesB() }

            try {
                // 等待两个请求的结果返回后直接拼接
                employeesA.await() + employeesB.await()
            } catch (ex: Exception) {
                // 异常兜底逻辑，比如打印错误、返回默认值、抛出业务异常
                ex.printStackTrace()
                ""
            }
        }
        // 拼接完成后再构造响应返回给客户端，此时combinedResult一定已经完成赋值
        return PersonResponse(content = combinedResult)
    }
}

调整后你之前遇到的两个问题会自然解决：

• 不存在GlobalScope导致的流程割裂：所有并发请求的执行、结果拼接、异常处理逻辑都在同一个suspend作用域内，不需要跨协程传递返回值，自然不存在launch块内无法return的问题。
• 不存在返回逻辑先执行的问题：coroutineScope必须等块内所有任务执行完成才会返回结果，combinedResult一定会在两个接口请求都拿到响应、完成拼接之后才会被赋值，从根源上避免了变量未初始化、执行顺序错乱的问题。

之前示例代码的优化版本 #

把你写的serve方法调整为suspend函数，去掉内部的runBlocking逻辑：

suspend fun serve(): Collection<Int> = coroutineScope {
    val deferredDouble = async { getItemDouble(1) }
    val deferredTriple = async { getItemTriple(1) }
    // 等待所有并发任务的结果并返回
    listOf(deferredDouble, deferredTriple).map { it.await() }
}

suspend fun getItemDouble(i: Int): Int {
    delay(1000)
    return i * 2
}

suspend fun getItemTriple(i: Int): Int {
    delay(1000)
    return i * 3
}

override suspend fun getPersonDetails(request: PersonRequest): PersonResponse {
    // 调用suspend版本的serve时，函数会自然挂起等待两个并发任务完成，全程不会阻塞线程
    val result = serve()
    println("Got result $result")
    // 后续业务逻辑...
}

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