java - 如何在 Vert.x 中进行有效的复合协调编程

Question

我想知道在 Vert.x 中异步运行以下一组调用的最佳方法是什么。

C1: [v1, v2] +--> C2(v1): x --> C2.1(x): xx --|
             |--> C3(v2): y --> C3.1(y): yy --+- C4(xx, yy)

对于符号C1: [v1, v2]表示调用C1，它返回一个值数组[v1, v2]。

我现在的想法是:

Future c1 = Future.future();
call_C1(some_input, handler -> {
    // ... do something
    c1.complete([v1, v2]);
});

c1.compose(array -> {
    // process data and then call C2-->C2.1 and C3-->C3.1
    Future c2 = Future.future();
    call_C2(array[0], c2.completer());

    Future c21 = Future.future();
    c2.compose(x -> {
        // process x and then call C2.1
        call_C2_1(x, h -> {
            // process result and complete c21
            c21.complete(xx);
        });
    });

    Future c3 = Future.future();
    call_C3(array[1], c3.completer());

    Future c31 = Future.future();
    c3.compose(y -> {
        // process y and then call C3.1
        call_C3_1(y, h -> {
            c31.complete(yy);
        });
    });

    CompositeFuture.all(c21, c31).setHandler(h -> {
        xx = h.result().resultAt(0);
        yy = h.result().resultAt(1);
        // process xx and yy
    });
});

我希望它是正确的，但是有没有更好、更自然或更有效的方法来组合所有这些调用？任何帮助表示赞赏。

Answer 1

考虑查看 RxJava 和 Vert.x rxified API ，这对您来说可能会感觉更自然。

这是一个例子:

  interface C1Result {
    Object v1();

    Object v2();
  }

  static Single<C1Result> C1() {
    return null;
  }

  static Single<Object> C2(Object v1) {
    return null;
  }

  static Single<Object> C21(Object x) {
    return null;
  }

  static Single<Object> C3(Object v2) {
    return null;
  }

  static Single<Object> C31(Object y) {
    return null;
  }

  static Single<Void> C4(Object xx, Object yy) {
    return null;
  }

  public static void main(String[] args) {

    C1().flatMap(c1Result -> {

      Single<Object> xxSingle = C2(c1Result.v1()).flatMap(x -> {
        return C21(x);
      });

      Single<Object> yySingle = C3(c1Result.v2()).flatMap(y -> {
        return C31(y);
      });

      return Single.merge(Single.zip(xxSingle, yySingle, (xx, yy) -> {
        return C4(xx, yy);
      }));

    }).subscribe(v -> {
      // Success
    }, throwable -> {
      // Failure
    });

  }