我正在创建一个测试应用程序,假设与服务器有很多连接。当我从我的 Verticle 创建一个客户端时,它总是在同一个线程上处理连接和消息。
当我创建我的verticle时,我设置了
options.setEventLoopPoolSize(4)
所以我希望它循环到 4 个事件循环,因为我想拥有数百万个连接。
我正在做
launch {
val socket = netClient.connectAwait(port, host)
log.info().log("connected on - {} {}", Thread.currentThread(), Vertx.currentContext())
socket.handler {
log.info().log("{}", it)
}
}
2019-06-04 17:30:06,479 INFO [vert.x-eventloop-thread-0] MainVerticle:连接在 - Thread[vert.x-eventloop-thread-0,5,main] io.vertx.core.impl .EventLoopContext@150049b3
总是在同一个线程上......如何在不同的事件循环上启动连接