使用 CoroutineVerticle 构建非阻塞 VertX 服务器

Question

我正在试验 VertX+Couroutines，只是想检查一下这个设置是否在任何时候都被阻塞或有我需要注意的潜在问题。

例如，runBlocking 在这种情况下是否被正确使用，还是我应该使用deployVerticle？然后在 requestHandler 内部，我正在做 GlobalScope.launch，这似乎不鼓励，这里使用的正确范围是什么？

我已将 VertX 4.0.0-milestone5 添加到我的 Gradle 构建脚本中，我没有使用 VertX Web：

            val vertxVersion = "4.0.0-milestone5"
            implementation("io.vertx:vertx-core:$vertxVersion") {
                exclude(group = "com.fasterxml.jackson.core", module = "jackson-core")
                exclude(group = "com.fasterxml.jackson.core", module = "jackson-databind")
                exclude(group = "log4j", module = "log4j")
                exclude(group = "org.apache.logging.log4j", module = "log4j-api")
                exclude(group = "org.apache.logging.log4j", module = "log4j-core")

            }
            implementation("io.vertx:vertx-lang-kotlin:$vertxVersion")
            implementation("io.vertx:vertx-lang-kotlin-coroutines:$vertxVersion")

在Routing.kt 内部我有以下设置：

class Routing(
    private val port: Int
) : CoroutineVerticle() {

    override suspend fun start() {

        Vertx.vertx().createHttpServer(
            HttpServerOptions().setCompressionSupported(true)
        ).requestHandler { req ->
            GlobalScope.launch {
                try {

                    log.info("${req.method()}:${req.path()}")

                    req.response().setStatusCode(200).end("Hello World")
                } catch (e: Exception) {
                    log.error(e.message ?: "", e)
                    req.response().setStatusCode(500).end("Something Went Wrong")
                }
            }
        }.listen(port)

        log.info("Listening on $port")

    }


    override suspend fun stop() {

    }

    companion object {

        private val log = LoggerFactory.getLogger(Routing::class.java)
        private val root = RoutingTree()

        suspend fun setup(port: Int) {
            Endpoint.all.forEach {
                root.addPath(it.key, it.value)
            }
            log.info("\n" + root.toString())
            Routing(port = port).start()
        }
    }

}

这个Routing.setup 然后在main() 中使用

object Server {

    private val log = LoggerFactory.getLogger(this.javaClass)

    @JvmStatic
    @ExperimentalTime
    fun main(args: Array<String>) = runBlocking {

        ....

        // setup routing
        Routing.setup(
            port = if (ENV.env == LOCAL) {
                5555
            } else {
                80
            },
        ) 

Answer 1

Kotlin 与 Vert.x 集成的重点在于您不必使用 GlobalScope.launch

这是一个如何实现它的最小示例：

fun main() {
    val vertx = Vertx.vertx()

    vertx.deployVerticle("Server")
}

class Server : CoroutineVerticle() {
    override suspend fun start() {
        vertx.createHttpServer().requestHandler { req ->
            // You already have access to all coroutine generators
            launch {
                // In this scope you can use suspending functions
                delay(1000)
                req.response().end("Done!")
            }
        }.listen(8888)
    }
}