您如何在Kotlin Web服务协程请求中实现响应的Shell脚本？

问题描述

我使用spring boot 2和Kotlin创建了一个Web服务，以通过流程构建器访问同一服务器的相同UNIX脚本和其他程序。响应消息应包含我使用的shell脚本的标准输出。但是我对科特林的协程有疑问。当我使用 process.waitFor（）时，这是一个阻止函数。您如何使用专用线程（池）来跟踪外部进程并在这段时间内暂停协程？ 在下面的代码片段中，您将看到如何获取shell脚本的返回代码以及该脚本的stdout信息：

    val process = ProcessBuilder(cmd)
        .redirectErrorStream(true)
        .start()
    val exitCode = process.waitFor()

    return CmdResult(
        exitCode,process.inputStream
    )

我在以下试验中失败了，因为我没有获得标准输出信息，并且不知道如何将结果用作范围外的返回类型：

val dispatcher = newFixedThreadPoolContext(4,"myPool")
launch(dispatcher) {
    val process = ProcessBuilder(listof(cmdscript))
                .redirectErrorStream(true)
                .start()
    val exitCode = process.waitFor()
            
    CmdResult(
        exitCode,process.inputStream
    )
}.join()

解决方法

您可以使用顶级函数withContext从协程返回：

val dispatcher = newFixedThreadPoolContext(4,"myPool")

val result = withContext(dispatcher) {
    val process = ProcessBuilder(listOf(cmdScript))
                .redirectErrorStream(true)
                .start()
    val exitCode = process.waitFor()
            
    CmdResult(
        exitCode,process.inputStream
    )
}