Vert.x中MongoDB查询结果存入Future后result返回null的解决求助

问题原因 #

MongoDB的findOne是异步操作，当你同步调用future.result()时，异步查询还未完成，future尚未被complete，因此返回null。Vert.x的Future是异步结果容器，仅在Future已完成时同步调用result()才有效，异步场景下必须通过setHandler或链式调用（如compose/flatMap）处理结果。

另外你的Service层代码存在冗余判断（重复的ar.succeeded()），且失败分支未正确传递错误，需要先修正这部分逻辑。

修正后的代码示例 #

1. Service层：返回Future替代Handler参数 #

将Service方法改为直接返回Future<JsonObject>，更符合Vert.x异步编程风格，便于上层组合操作：

public Future<JsonObject> getClazzById(String clazzId) {
    JsonObject query = new JsonObject().put("_id", clazzId);
    Future<JsonObject> findFuture = Future.future();
    // 直接将MongoDB的异步结果绑定到Future
    client.findOne(Collection.CLAZZ, query, null, findFuture.completer());

    // 处理查询结果为空的情况，转为失败的Future
    return findFuture.map(result -> {
        if (result == null) {
            throw new RuntimeException("Class not found!");
        }
        return result;
    });
}

2. Router层：正确处理异步Future #

通过setHandler监听Future完成事件，避免同步调用result()，同时可将结果存入缓存或共享Future供其他API使用：

private void getClazzById(RoutingContext rc) {
    String clazzId = rc.request().getParam("clazzId");
    
    classService.getClazzById(clazzId)
        .setHandler(ar -> {
            if (ar.succeeded()) {
                JsonClass result = ar.result();
                
                // 方式1：存入Vert.x本地缓存供其他API使用
                rc.vertx().sharedData().getLocalMap("classCache").put(clazzId, result);
                
                // 方式2：创建共享Future供后续异步操作使用
                Future<JsonObject> sharedFuture = Future.succeededFuture(result);
                // 其他API可通过sharedFuture.setHandler获取结果
                
                // 返回响应
                rc.response().setStatusCode(200)
                    .putHeader("Content-Type", "application/json; charset=utf-8")
                    .end(result.encodePrettily());
            } else {
                String errorMsg = ar.cause().getMessage();
                if ("Class not found!".equals(errorMsg)) {
                    rc.response().setStatusCode(404)
                        .putHeader("Content-Type", "application/json; charset=utf-8")
                        .end(new JsonObject().put("error", errorMsg).encodePrettily());
                } else {
                    rc.fail(ar.cause());
                }
            }
        });
}

关键注意事项 #

• 禁止异步流程中同步调用future.result()：这是Vert.x异步编程的核心误区，必须通过setHandler或链式操作处理结果。
• 共享结果给其他API时，优先使用Vert.x的LocalMap/AsyncMap（而非全局Future），避免多请求结果冲突。
• 尽量让Service层返回Future，减少回调嵌套，提升代码可读性和可维护性。

内容的提问来源于stack exchange，提问作者Võ Khắc Bảo