vert.x：你如何正确发送帖子请求？

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 - 我没有看到像任何字符串“一些回调。”

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) 

不知道我在这里做错了什么？

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