java - vertx 未来失败，但被视为成功（）

Question

我有一个方法：

    public void getVmsAdminToken(HttpClient httpClient, handler<AsyncResult<String>> handler) {
           httpClient.postAbs(url, h -> h.bodyHandler(bh -> {
                try {
                    switch (h.statusCode()) {
                        case 200:
                            JsonObject vmsResponse = bh.toJsonObject();                       
                            handler.handle(Future.succeededFuture(Json.encode(vmsResponse)));
                            break;
                        default:
                            LOG.error("VMS call failed {}", h.statusCode());
                            handler.handle(Future.failedFuture(500 + ""));
                            break;
                    }
                } catch (Throwable t) {
                    LOG.error("Exception in getVmsAdminToken", t);
                    handler.handle(Future.failedFuture(500 + ""));
                }
            }))
                    .setTimeout(timeOutMs)
                    .putHeader("content-type", "application/json")
                    .putHeader("stub", apiKey)
                    .end(vehicleReqBody.encode());
    }

我在以下方法调用中使用它：

private void getAdminToken(RoutingContext ctx, RedisFleetStorage storage, HttpClient httpClient) {

    getVmsAdminToken(fleetId, user, vehicle, httpClient, replyVms -> {
                                            if (reply.succeeded()) {
                                               // why succeeded?!!
                                            }
                                        });
}

而且即使 getVmsToken 失败，执行也会落入if (reply.succeeded())

为什么会这样？

标签： javavert.x

Answer 1

You should check the same AsyncResult object being the result of your HTTP call:

private void getAdminToken(RoutingContext ctx, RedisFleetStorage storage, HttpClient httpClient) {

    getVmsAdminToken(fleetId, user, vehicle, httpClient, replyVms -> {
                                            if (replyVms.succeeded()) {
                                               // do you thing
                                            }
                                        });
}