如何对包含vertx（）的方法进行单元测试。eventBus（）。发送（）？

Question

令人沮丧的。我到处都能看到测试异步Vertx代码的示例，但没有任何内容接近我要测试的内容。

• Vertx 3.3.2，JUnit 4.12，Java8

被测试的方法向事件总线发送消息。我想验证在eventBus（）中发生的事情。发送（）响应处理程序正在发生。

所以，我看到的许多例子在TEST ITSELF中有eventBus（）。发送（）方法（因此，测试事件总线的另一端——消费者）我想测试。发送（）中的响应处理程序

我在测试中尝试了异步。尝试ArgumentCaptor。尝试Thread.sleep（）。尝试do答案（）。似乎没有什么可以让测试（a）等待异步事件Bus（）。发送（）在测试的方法中调用完成，并且（b）能够验证（）有交互（我认为这可能与Vertx之间的不同有关...TestContext和JUnit。运行上下文...（

代码：测试方法：

public void sendToEventBusAddress(RoutingContext context, String requestId, String userId) {
    List<String> stuff = split(context.request().getParam("stuffToSplit"));
    JsonObject eventBusMessage = new JsonObject()
            .put("requestId", requestId)
            .put("stuffList", new JsonArray(stuff))
            .put("userId", userId);
    LOGGER.info("Putting message: {} onto the EventBus at address: {}", eventBusMessage.encodePrettily(), EventBusEndpointEnum.STUFF_ACCESS.getValue());
    context.vertx().eventBus().send(EventBusEndpointEnum.STUFF_ACCESS.getValue(), eventBusMessage, new DeliveryOptions().setSendTimeout(timeout), async -> {
        if (async.succeeded()) {
            LOGGER.info("EventBus Response: {}", async.result().body().toString());
            context.response().setStatusCode(HttpStatus.SC_OK);
            context.response().headers().set(HttpHeaders.CONTENT_TYPE, MediaType.TEXT_PLAIN);
            context.response().end(async.result().body().toString());
        } else {
            LOGGER.error(errorMessage);
            context.response().setStatusCode(HttpStatus.SC_BAD_REQUEST);
            context.response().end(errorMessage);
        }
    });
}

简化（非工作）测试用例和类：

@RunWith(VertxUnitRunner.class)
public class MyBrokenTest {
    @Mock private RoutingContext routingContext;
    @Mock private HttpServerRequest contextRequest;
    @Mock private HttpServerResponse contextResponse;
    @Mock private MultiMap responseHeaders;

    @Rule public RunTestOnContext rule = new RunTestOnContext();

    @Before
    public void setUp(TestContext context) {
        MockitoAnnotations.initMocks(this);
    }

    @Test
    public void testOne(TestContext context) {
        when(routingContext.vertx()).thenReturn(rule.vertx());
        when(routingContext.request()).thenReturn(contextRequest);
        when(contextRequest.getParam("stuffToSplit")).thenReturn("04MA");
        when(routingContext.response()).thenReturn(contextResponse);
        when(contextResponse.headers()).thenReturn(responseHeaders);

        rule.vertx().eventBus().consumer(EventBusEndpointEnum.STUFF_ACCESS.getValue(), res -> {
            res.reply("yo");
        });

        ClassUnderTest cut= new ClassUnderTest(180000);
        cut.sendToEventBusAddress(routingContext, "testRequestId", "UnitTestId");
        verify(contextResponse).setStatusCode(200);
    }
}

我知道当前形式的测试不起作用，因为在测试中的方法一旦在方法内部调用eventBus（）。发送（）方法就会返回，因此，验证失败，没有交互。

我不明白的是，鉴于Vertx的异步特性，如何正确地验证它！

谢谢

Answer 1

我这样做了：

>

在@beforeach-我为给定的消息创建一个消费者，并将消息存储到变量/集合中

比如：

receivedMessage = new Message[1];
   eventBus.consumer("DB",
        message -> {
            message.reply("OK");
            receivedMessage[0] = message;
        });
context.completeNow();

在测试中，我验证存储值：

client.get(8080, "localhost", "/user/" + id)
    .as(BodyCodec.string())
    .send(context.succeeding((response -> context.verify(() -> {
        Assertions.assertEquals(expectedMessage, receivedMessage[0].body());
        context.completeNow();
}))));