关于部署 Verticle 的上下文问题的 Vertx 测试
Vertx test on context issues deploying verticle
所以这有点狡猾,它不会 100% 发生,但情况是这样的:
我创建了一个 JUnit
集成 class,在上下文中声明了一个 Rule
到 运行,然后我从规则中提取了 vertx
对象。然后我将新的 Verticle 部署到 vertx
,如果尝试部署超过 ~3-4 个 Verticle,我会为每个 Verticle 得到这个:
Jan 09, 2017 2:43:33 PM io.vertx.core.impl.ContextImpl
SEVERE: Unhandled exception
java.lang.IllegalStateException: Result is already complete: succeeded
at io.vertx.core.impl.FutureImpl.checkComplete(FutureImpl.java:164)
at io.vertx.core.impl.FutureImpl.complete(FutureImpl.java:108)
at io.vertx.core.impl.FutureImpl.handle(FutureImpl.java:135)
at io.vertx.core.impl.FutureImpl.handle(FutureImpl.java:23)
at io.vertx.core.eventbus.impl.EventBusImpl.lambda$callCompletionHandlerAsync(EventBusImpl.java:340)
at io.vertx.core.impl.ContextImpl.lambda$wrapTask(ContextImpl.java:316)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:163)
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:418)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:440)
at io.netty.util.concurrent.SingleThreadEventExecutor.run(SingleThreadEventExecutor.java:873)
at java.lang.Thread.run(Thread.java:745)
导致此问题的代码如下所示:
@RunWith(VertxUnitRunner.class)
public class VertxTest {
@Rule
public RunTestOnContext rule = new RunTestOnContext(Vertx::vertx);
@Test
public void testLinearExecution(TestContext context) {
Vertx vertx = rule.vertx();
vertx.deployVerticle(new AbstractVerticle() {
@Override
public void start() throws Exception {
this.vertx.eventBus().consumer("bla", event -> {});
}
});
vertx.deployVerticle(new AbstractVerticle() {
@Override
public void start() throws Exception {
this.vertx.eventBus().consumer("bla", event -> {});
}
});
vertx.deployVerticle(new AbstractVerticle() {
@Override
public void start() throws Exception {
this.vertx.eventBus().consumer("bla", event -> {});
}
});
vertx.deployVerticle(new AbstractVerticle() {
@Override
public void start() throws Exception {
this.vertx.eventBus().consumer("bla", event -> {});
}
});
vertx.deployVerticle(new AbstractVerticle() {
@Override
public void start() throws Exception {
this.vertx.eventBus().consumer("bla", event -> {});
}
});
vertx.deployVerticle(new AbstractVerticle() {
@Override
public void start() throws Exception {
this.vertx.eventBus().consumer("bla", event -> {});
}
});
}
}
这可能取决于 运行 机器,但我的猜测是,如果它不重现,请添加更多这样的人以使其更有可能:
vertx.deployVerticle(new AbstractVerticle() {
@Override
public void start() throws Exception {
this.vertx.eventBus().consumer("bla", event -> {});
}
});
另一件事是,如果我将 Vertx vertx = rule.vertx();
更改为 Vertx vertx = Vertx.vertx();
,我会收到控制台的警告消息,但问题会消失。
所以,我做错了什么吗?有问题吗?
您使用的是 3.3.3 版本吗?您可能会遇到这个问题:https://github.com/eclipse/vert.x/issues/1625(已在 master 中修复)
所以这有点狡猾,它不会 100% 发生,但情况是这样的:
我创建了一个 JUnit
集成 class,在上下文中声明了一个 Rule
到 运行,然后我从规则中提取了 vertx
对象。然后我将新的 Verticle 部署到 vertx
,如果尝试部署超过 ~3-4 个 Verticle,我会为每个 Verticle 得到这个:
Jan 09, 2017 2:43:33 PM io.vertx.core.impl.ContextImpl
SEVERE: Unhandled exception
java.lang.IllegalStateException: Result is already complete: succeeded
at io.vertx.core.impl.FutureImpl.checkComplete(FutureImpl.java:164)
at io.vertx.core.impl.FutureImpl.complete(FutureImpl.java:108)
at io.vertx.core.impl.FutureImpl.handle(FutureImpl.java:135)
at io.vertx.core.impl.FutureImpl.handle(FutureImpl.java:23)
at io.vertx.core.eventbus.impl.EventBusImpl.lambda$callCompletionHandlerAsync(EventBusImpl.java:340)
at io.vertx.core.impl.ContextImpl.lambda$wrapTask(ContextImpl.java:316)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:163)
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:418)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:440)
at io.netty.util.concurrent.SingleThreadEventExecutor.run(SingleThreadEventExecutor.java:873)
at java.lang.Thread.run(Thread.java:745)
导致此问题的代码如下所示:
@RunWith(VertxUnitRunner.class)
public class VertxTest {
@Rule
public RunTestOnContext rule = new RunTestOnContext(Vertx::vertx);
@Test
public void testLinearExecution(TestContext context) {
Vertx vertx = rule.vertx();
vertx.deployVerticle(new AbstractVerticle() {
@Override
public void start() throws Exception {
this.vertx.eventBus().consumer("bla", event -> {});
}
});
vertx.deployVerticle(new AbstractVerticle() {
@Override
public void start() throws Exception {
this.vertx.eventBus().consumer("bla", event -> {});
}
});
vertx.deployVerticle(new AbstractVerticle() {
@Override
public void start() throws Exception {
this.vertx.eventBus().consumer("bla", event -> {});
}
});
vertx.deployVerticle(new AbstractVerticle() {
@Override
public void start() throws Exception {
this.vertx.eventBus().consumer("bla", event -> {});
}
});
vertx.deployVerticle(new AbstractVerticle() {
@Override
public void start() throws Exception {
this.vertx.eventBus().consumer("bla", event -> {});
}
});
vertx.deployVerticle(new AbstractVerticle() {
@Override
public void start() throws Exception {
this.vertx.eventBus().consumer("bla", event -> {});
}
});
}
}
这可能取决于 运行 机器,但我的猜测是,如果它不重现,请添加更多这样的人以使其更有可能:
vertx.deployVerticle(new AbstractVerticle() {
@Override
public void start() throws Exception {
this.vertx.eventBus().consumer("bla", event -> {});
}
});
另一件事是,如果我将 Vertx vertx = rule.vertx();
更改为 Vertx vertx = Vertx.vertx();
,我会收到控制台的警告消息,但问题会消失。
所以,我做错了什么吗?有问题吗?
您使用的是 3.3.3 版本吗?您可能会遇到这个问题:https://github.com/eclipse/vert.x/issues/1625(已在 master 中修复)