Vert.x异步测试

Question

我是新来的。我试图运行一些基本的测试和基准等等来评估框架(所以我可能做错了很多！)

我感兴趣的一件事是运行“控制器”级别测试的性能成本。我设置了一个测试，这个测试应该会反复旋转并撕毁一个httpclient。

@Repeat(100)
@Test
public void testMyApplication(TestContext context) {

    final Async async = context.async(1);
    vertx.createHttpClient().getNow(8080, "localhost", "/",
            response -> {
                response.handler(body -> {
                    context.assertTrue(body.toString().contains("Hello"));
                    context.assertEquals(200, response.statusCode());
                    async.complete();
                });
            });
    async.awaitSuccess();
}

然而，这偶尔也会失败。

SEVERE: io.netty.channel.AbstractChannel$AnnotatedConnectException: Connection refused: localhost/127.0.0.1:8080

有什么更好的方法来拆分多个客户端并确保测试按顺序运行，或者有一些受控的并行性呢？

Answer 1

好的,

这里发生的情况是，由于异步调用，在调用async.complete之前，可以启动新的测试。因此，已经有一个测试服务器运行在端口8080上。

解决方案是在via配置中使用pass端口，并在测试中使用随机端口。

      server.requestHandler(router::accept)
          .listen(
                  config().getInteger("http.port", 8080),
      ...

而测试变成了

@Before
public void setUp(TestContext context) throws Exception {
    ServerSocket socket = new ServerSocket(0);
    port = socket.getLocalPort();
    socket.close();

    DeploymentOptions options = new DeploymentOptions()
            .setConfig(new JsonObject().put("http.port", port)
            );
    vertx = Vertx.vertx();
    vertx.deployVerticle(HelloVerticle.class.getName(), options,
            context.asyncAssertSuccess());
}
...

@Repeat(100)
@Test
public void testMyApplication(TestContext context) {

    final Async async = context.async();
    vertx.createHttpClient().getNow(port, "localhost", "/",
            response -> {
                response.handler(body -> {
                    context.assertTrue(body.toString().contains("Hello"));
                    context.assertEquals(200, response.statusCode());
                    async.complete();
                });
            });
}

这篇博文对http://vertx.io/blog/vert-x-application-configuration/有很大帮助

Answer 2

错误说明Connection refused，这意味着没有服务器运行在端口8080。在您的测试用例中，您需要在端口8080启动一些服务器。

@RunWith(VertxUnitRunner.class)
public class VertxText {
    Vertx vertx;
    HttpServer server;

    @Before
    public void before(TestContext context) {
        vertx = Vertx.vertx();
        server =
                vertx.createHttpServer().requestHandler(req -> req.response().end("Hello")).
                        listen(8080, context.asyncAssertSuccess());
    }

    @After
    public void after(TestContext context) {
        vertx.close(context.asyncAssertSuccess());
    }

    @Repeat(100)
    @Test
    public void testMyApplication(TestContext context) {
        final Async async = context.async(1);
        vertx.createHttpClient().getNow(8080, "localhost", "/",
                response -> {
                    response.handler(body -> {
                        context.assertTrue(body.toString().contains("Hello"));
                        context.assertEquals(200, response.statusCode());
                        async.complete();
                    });
                });
        async.awaitSuccess();
    }
}

在前面，服务器正在初始化的地方，您必须传递请求处理程序，这将测试您的路由。