如何在Kotlin web服务协同程序请求中实现响应shell脚本



我用spring-boot 2和Kotlin创建了一个web服务,通过流程生成器访问特定服务器的相同unix脚本和其他程序。响应消息应包含我使用的shell脚本的stdout。但我对科特林的郊游有意见。当我使用process.waitFor时,这是一个阻塞函数。如何使用专用线程(-池(来跟踪外部进程并在此期间挂起协同程序?在下面的代码片段中,您可以看到我是如何获得shell脚本的返回代码及其stdout信息的:

val process = ProcessBuilder(cmd)
.redirectErrorStream(true)
.start()
val exitCode = process.waitFor()
return CmdResult(
exitCode,
process.inputStream
)

我在下面的试验中失败了,因为我没有得到stdout信息,也不知道如何将结果从范围之外用作返回类型:

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
)
}

最新更新