标签：unit-testing post reactive-programming vert-x java

我有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$2
     .run(SingleThreadEventExecutor.java:111)
  at java.lang.Thread.run(Thread.java:745)

知道我在做什么错吗？

解决方法:

调用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();
}

标签：unit-testing,post,reactive-programming,vert-x,java
来源： https://codeday.me/bug/20191026/1938378.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。