Vertx 单元测试阻塞主线程
Vertx unit-test blocking the main thread
在尝试通过测试 class 使用事件总线测试 Vert.x Verticle 时,我得到了 "blocking errors"。在这里垂直并测试 classes:
EventBusReceiverVerticle
:
public class EventBusReceiverVerticle extends AbstractVerticle {
public EventBusReceiverVerticle(String name) {
this.name = name;
}
public void start() {
vertx.eventBus().consumer("geo-service", (Message<JsonObject> handler) -> {
{
try {
System.out.println("sleep 10 seconds");
Thread.sleep(10000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
});
}
}
测试class:
@RunWith(VertxUnitRunner.class)
public class MyFirstVerticleTest {
Vertx vertx;
EventBus eb;
private static final Logger logger = LoggerFactory.getLogger(MyFirstVerticleTest.class);
@Before
public void setUp(TestContext context) {
logger.info("@Before");
vertx = Vertx.vertx();
eb = vertx.eventBus();
Async async = context.async();
vertx.deployVerticle(new EventBusReceiverVerticle("R1"), res -> {
if (res.succeeded()) {
async.complete();
} else {
context.fail();
}
});
}
@After
public void tearDown(TestContext context) {
logger.info("@After");
Async async = context.async();
vertx.close(event -> async.complete());
}
@Test
public void testEventBusVerticle(TestContext context) {
Async async = context.async();
JsonObject msg = new JsonObject("{\"action\":\"pos\"}");
eb.send("geo-service", msg, reply -> {
if (reply.succeeded()) {
async.complete();
} else {
context.fail();
}
});
async.complete();
}
}
控制台输出:
Sep 05, 2015 2:20:23 PM com.company.MyFirstVerticleTest
INFO: @Before
sleep 10 seconds
Sep 05, 2015 2:20:24 PM com.company.MyFirstVerticleTest
INFO: @After
Sep 05, 2015 2:20:27 PM io.vertx.core.impl.BlockedThreadChecker
WARNING: Thread Thread[vert.x-eventloop-thread-2,5,main] has been blocked for 2790 ms, time limit is 2000
Sep 05, 2015 2:20:28 PM io.vertx.core.impl.BlockedThreadChecker
WARNING: Thread Thread[vert.x-eventloop-thread-2,5,main] has been blocked for 3794 ms, time limit is 2000
Sep 05, 2015 2:20:29 PM io.vertx.core.impl.BlockedThreadChecker
WARNING: Thread Thread[vert.x-eventloop-thread-2,5,main] has been blocked for 4796 ms, time limit is 2000
Sep 05, 2015 2:20:30 PM io.vertx.core.impl.BlockedThreadChecker
WARNING: Thread Thread[vert.x-eventloop-thread-2,5,main] has been blocked for 5799 ms, time limit is 2000
io.vertx.core.VertxException: Thread blocked
at java.lang.Thread.sleep(Native Method)
at com.company.verticals.EventBusReceiverVerticle.lambda$start(EventBusReceiverVerticle.java:35)
at com.company.verticals.EventBusReceiverVerticle$$Lambda/2029238960.handle(Unknown Source)
at io.vertx.core.eventbus.impl.EventBusImpl$HandlerRegistration.handle(EventBusImpl.java:1108)
at io.vertx.core.eventbus.impl.EventBusImpl.lambda$doReceive9(EventBusImpl.java:755)
at io.vertx.core.eventbus.impl.EventBusImpl$$Lambda/1888442711.handle(Unknown Source)
at io.vertx.core.impl.ContextImpl.lambda$wrapTask(ContextImpl.java:314)
at io.vertx.core.impl.ContextImpl$$Lambda/911312317.run(Unknown Source)
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:357)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:357)
at io.netty.util.concurrent.SingleThreadEventExecutor.run(SingleThreadEventExecutor.java:111)
at java.lang.Thread.run(Thread.java:745)
我必须通过设置将 Verticle 设置为 worker:
new DeploymentOptions().setWorker(true)
另一种选择是增加超时
VertxOptions options = new VertxOptions();
options.setMaxEventLoopExecuteTime(Long.MAX_VALUE);
vertx = Vertx.vertx(options);`
Vertx documentation 中的关键句子是
Don’t block me!
您收到了阻塞消息,因为您确实在 Verticle 中执行了阻塞代码。调用 Thread.sleep(10000)
会阻止您当前的 Verticle 10 秒。
将您的 Verticle 声明为 worker 是一种解决方法。查看 Vertx 文档 Executing blocking code。根据文档,您可以告诉 Vertx 执行 Thread.sleep(10000)
作为阻塞代码。
vertx.executeBlocking({ future ->
// Call some blocking API that takes a significant amount of time to return
Thread.sleep(10000)
future.complete(result)
}, { res ->
println("The result is: ${res.result()}")
})
也许您可以解释一下您的测试目的以及为什么使用 Thread.sleep(10000)
?
在尝试通过测试 class 使用事件总线测试 Vert.x Verticle 时,我得到了 "blocking errors"。在这里垂直并测试 classes:
EventBusReceiverVerticle
:
public class EventBusReceiverVerticle extends AbstractVerticle {
public EventBusReceiverVerticle(String name) {
this.name = name;
}
public void start() {
vertx.eventBus().consumer("geo-service", (Message<JsonObject> handler) -> {
{
try {
System.out.println("sleep 10 seconds");
Thread.sleep(10000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
});
}
}
测试class:
@RunWith(VertxUnitRunner.class)
public class MyFirstVerticleTest {
Vertx vertx;
EventBus eb;
private static final Logger logger = LoggerFactory.getLogger(MyFirstVerticleTest.class);
@Before
public void setUp(TestContext context) {
logger.info("@Before");
vertx = Vertx.vertx();
eb = vertx.eventBus();
Async async = context.async();
vertx.deployVerticle(new EventBusReceiverVerticle("R1"), res -> {
if (res.succeeded()) {
async.complete();
} else {
context.fail();
}
});
}
@After
public void tearDown(TestContext context) {
logger.info("@After");
Async async = context.async();
vertx.close(event -> async.complete());
}
@Test
public void testEventBusVerticle(TestContext context) {
Async async = context.async();
JsonObject msg = new JsonObject("{\"action\":\"pos\"}");
eb.send("geo-service", msg, reply -> {
if (reply.succeeded()) {
async.complete();
} else {
context.fail();
}
});
async.complete();
}
}
控制台输出:
Sep 05, 2015 2:20:23 PM com.company.MyFirstVerticleTest
INFO: @Before
sleep 10 seconds
Sep 05, 2015 2:20:24 PM com.company.MyFirstVerticleTest
INFO: @After
Sep 05, 2015 2:20:27 PM io.vertx.core.impl.BlockedThreadChecker
WARNING: Thread Thread[vert.x-eventloop-thread-2,5,main] has been blocked for 2790 ms, time limit is 2000
Sep 05, 2015 2:20:28 PM io.vertx.core.impl.BlockedThreadChecker
WARNING: Thread Thread[vert.x-eventloop-thread-2,5,main] has been blocked for 3794 ms, time limit is 2000
Sep 05, 2015 2:20:29 PM io.vertx.core.impl.BlockedThreadChecker
WARNING: Thread Thread[vert.x-eventloop-thread-2,5,main] has been blocked for 4796 ms, time limit is 2000
Sep 05, 2015 2:20:30 PM io.vertx.core.impl.BlockedThreadChecker
WARNING: Thread Thread[vert.x-eventloop-thread-2,5,main] has been blocked for 5799 ms, time limit is 2000
io.vertx.core.VertxException: Thread blocked
at java.lang.Thread.sleep(Native Method)
at com.company.verticals.EventBusReceiverVerticle.lambda$start(EventBusReceiverVerticle.java:35)
at com.company.verticals.EventBusReceiverVerticle$$Lambda/2029238960.handle(Unknown Source)
at io.vertx.core.eventbus.impl.EventBusImpl$HandlerRegistration.handle(EventBusImpl.java:1108)
at io.vertx.core.eventbus.impl.EventBusImpl.lambda$doReceive9(EventBusImpl.java:755)
at io.vertx.core.eventbus.impl.EventBusImpl$$Lambda/1888442711.handle(Unknown Source)
at io.vertx.core.impl.ContextImpl.lambda$wrapTask(ContextImpl.java:314)
at io.vertx.core.impl.ContextImpl$$Lambda/911312317.run(Unknown Source)
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:357)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:357)
at io.netty.util.concurrent.SingleThreadEventExecutor.run(SingleThreadEventExecutor.java:111)
at java.lang.Thread.run(Thread.java:745)
我必须通过设置将 Verticle 设置为 worker:
new DeploymentOptions().setWorker(true)
另一种选择是增加超时
VertxOptions options = new VertxOptions();
options.setMaxEventLoopExecuteTime(Long.MAX_VALUE);
vertx = Vertx.vertx(options);`
Vertx documentation 中的关键句子是
Don’t block me!
您收到了阻塞消息,因为您确实在 Verticle 中执行了阻塞代码。调用 Thread.sleep(10000)
会阻止您当前的 Verticle 10 秒。
将您的 Verticle 声明为 worker 是一种解决方法。查看 Vertx 文档 Executing blocking code。根据文档,您可以告诉 Vertx 执行 Thread.sleep(10000)
作为阻塞代码。
vertx.executeBlocking({ future ->
// Call some blocking API that takes a significant amount of time to return
Thread.sleep(10000)
future.complete(result)
}, { res ->
println("The result is: ${res.result()}")
})
也许您可以解释一下您的测试目的以及为什么使用 Thread.sleep(10000)
?