在worker verticle中发出两个请求并合并来自两个请求的响应

Question

我有一个vertx服务器应用程序，在那里我收到单客户端请求，从服务器，我需要进行两次阻塞调用。例如，一个调用后端系统A，另一个调用后端系统B。我希望同时调用两个系统。我需要等待两个调用的响应，然后合并两个调用中的两个数据，然后将响应发送回客户端。我不知道如何在工人垂直运动中做到这一点。

有谁能推荐vertx中最好的方法吗？

Answer 1

从您启动的未来创建一个复合未来，并正常处理它。

public Future<JsonArray> getEntitiesByIndFields(String keyspace, String entidad, String field1, String field2) {
    Promise<JsonArray> p = Promise.promise();
    // launch in parallel
    Future<JsonArray> f1 = getEntitiesByIndField1(keyspace, entidad, field1);
    Future<JsonArray> f2 = getEntitiesByIndField2(keyspace, entidad, field2);
    CompositeFuture.all(f1, f2).setHandler(done ->
        {
            if (done.failed()) {
                p.fail(done.cause());
                return;
            }
            List<JsonArray> ja = done.result().list();
            JsonArray finalarray = ja.get(0);
            ja.get(1).forEach(jo ->
                { // add one by one, don't duplicate ids
                    long id = ((JsonObject) jo).getLong("id");
                    if (!containsKey(finalarray, id)) {
                        finalarray.add(jo);
                    }
                });
            ;
            p.complete(finalarray); // send union of founds
        });
    return p.future();
}

Answer 2

这听起来像是Promises的一个很好的用例。尝试一下模块vertx-promise。