Netty - 如何实现扇出模式

Question

是否有任何示例说明如何实现扇出模式？基本上在我的处理程序中，我想发出多个请求，然后处理这些请求的结果。

Answer 1

对于多个目标，我相信您可以使用 PromiseAggregator和/或 PromiseCombiner .如果我正确理解您的用例，那么这些抽象就是为了做到这一点:加入多个 future / promise 并等待它们的聚合结果。详细信息可能因您的要求而异，如果至少一项 promise 失败，您可能希望失败，或者如果至少一项 promise 完成，您可能没问题。无论如何，可以在文档或此处找到一些示例:PromiseCombiner example .

final PromiseCombiner combiner = new PromiseCombiner(eventExecutor);
combiner.add(makeAsyncCall1());
combiner.add(makeAsyncCall2());
final DefaultPromise<Void> promise = new DefaultPromise<>(eventExecutor);
promise.addListener(new GenericFutureListener<Future<? super Void>>() {
    @Override
    public void operationComplete(Future<? super Void> future) throws Exception {
        // handle
    }
});
combiner.finish(promise);