在HTTP服务器中使用rxEnd时未提交响应

Question

我有一个用vert编写的双垂直服务器。x反应性扩展。HTTP server verticle使用事件总线向DB verticle发送请求。从DB verticle（通过事件总线）接收到响应后，我使用rxEnd将响应发送到http客户端。然而，客户似乎没有收到这种回复，最终超时。如果我用end（）来代替，事情会很顺利。我使用postman来测试这个RESTAPI。请参阅下面的代码，该代码将结果从数据库垂直转发到客户端。

routerFactory.addHandlerByOperationId("createChargePoints", routingContext -> {
            RequestParameters params = routingContext.get("parsedParameters");

            RequestParameter body = params.body();
            JsonObject jsonBody = body.getJsonObject();

            vertx.eventBus().rxRequest("dbin", jsonBody)
                    .map(message -> {
                        System.out.println(message.body());
                        return routingContext.response().setStatusCode(200).rxEnd(message.body().toString());
                    })
                    .subscribe(res -> {
                        System.out.println(res);
                    }, res -> {
                        System.out.println(res);
                    });
        });

Answer 1

rxEnd方法是end的一个变体，它返回一个可完成的。前者懒惰，后者则不然。

换句话说，如果您调用rxend，您必须订阅完成，否则什么都不会发生。

看看你的代码片段，我认为没有必要使用rxEnd。实际上，您似乎不需要知道请求是否成功发送。