vert.x: 如何正确发送post请求？

Question

我有 vert.x 具有最简单授权的应用程序服务器，它有一些像这样的路由：

router.post("/user/sign").handler(this::userSignIn);

当我从 GUI 执行此操作时，它工作正常。

但我想为这个动作创建 Unit-Test。我做的代码：

@Test
public void testServerUserRegister(TestContext context) {
  HttpClient client = vertx.createHttpClient();
  HttpClientRequest request = client.post("user/sign", response -> {
  System.out.println("Some callback " + response.statusCode());
  });

  String body = "{'username':'www','password':'www'}";
  request.putHeader("content-length", "1000");
  request.putHeader("content-type", "application/x-www-form-urlencoded");
  request.write(body);
  request.end();
}

当我开始这个测试时：mvn test

我看到了结果但是：

1- 我没有看到任何像 "Some callback..."

这样的字符串

2- 我得到一个 RejectedExecutionException:

вер. 16, 2016 4:29:20 PM io.vertx.core.http.impl.HttpClientImpl
  SEVERE: java.nio.channels.ClosedChannelException
  вер. 16, 2016 4:29:20 PM io.netty.channel.AbstractChannel$AbstractUnsafe invokeLater
  WARNING: Can't invoke task later as EventLoop rejected it
  java.util.concurrent.RejectedExecutionException: event executor terminated

  at io.netty.util.concurrent.SingleThreadEventExecutor
     .reject(SingleThreadEventExecutor.java:707)
  at io.netty.util.concurrent.SingleThreadEventExecutor
     .addTask(SingleThreadEventExecutor.java:299)
  at io.netty.util.concurrent.SingleThreadEventExecutor
     .execute(SingleThreadEventExecutor.java:687)
  at io.netty.channel.AbstractChannel$AbstractUnsafe
     .invokeLater(AbstractChannel.java:826)
  at io.netty.channel.AbstractChannel$AbstractUnsafe
     .deregister(AbstractChannel.java:656)
  at io.netty.channel.AbstractChannel$AbstractUnsafe
     .fireChannelInactiveAndDeregister(AbstractChannel.java:626)
  at io.netty.channel.AbstractChannel$AbstractUnsafe
     .close(AbstractChannel.java:600)
  at io.netty.channel.nio.NioEventLoop.closeAll(NioEventLoop.java:576)
  at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:361)
  at io.netty.util.concurrent.SingleThreadEventExecutor
     .run(SingleThreadEventExecutor.java:111)
  at java.lang.Thread.run(Thread.java:745)

知道我做错了什么吗？

Answer 1

调用 request.end() 后，JUnit 测试退出并且您的 Vert.x 实例关闭（因此 RejectedExecutionException）。

请记住，Vert.x API 是异步的。看看 Vert.x Unit section about asynchronous testing.

你应该做的是：

@Test
public void testServerUserRegister(TestContext context) {
  // Get an async object to control the completion of the test
  Async async = context.async();
  HttpClient client = vertx.createHttpClient();
  HttpClientRequest request = client.post("user/sign", response -> {
    // You may want to check response code here
    // to either complete or fail the test
    async.complete();
    System.out.println("Some callback " + response.statusCode());
  });

  String body = "{'username':'www','password':'www'}";
  request.putHeader("content-length", "1000");
  request.putHeader("content-type", "application/x-www-form-urlencoded");
  request.write(body);
  request.end();
}

vert.x: 如何正确发送post请求？

vert.x: How do you correctly send a post request?

java

post

unit-testing

reactive-programming

vert.x