链式反应组件调用

Question

我有一个下面的对象列表，方法返回被动类型Mono

interface GuyWithReactiveReturnTypeMethod {

    Mono<String> execute();
}

class ReactiveGuysInvocator {

    Mono<String> executeAllGuys(List<GuyWithReactiveReturnTypeMethod> guysToInvoke) {
        ???
    }
}

我需要一个接一个地调用所有的guy（n的guy结果是n1的guy参数），但我不确定如何遍历这样的列表。我想到了flatMapwhile循环中的下一个家伙：

public interface GuyWithReactiveReturnTypeMethod {

    Mono<String> execute(String string);
}

class ReactiveGuysInvocator {

    Mono<String> executeAllGuys(List<GuyWithReactiveReturnTypeMethod> guysToExecute) {
        ListIterator<GuyWithReactiveReturnTypeMethod> iterator = guysToExecute.listIterator();
        Mono<String> currentResult = Mono.just("start");
        while (iterator.hasNext()) {
            GuyWithReactiveReturnTypeMethod guyToInvoke = iterator.next();
            currentResult = currentResult.flatMap(guyToInvoke::execute)
                    .doOnNext(object -> System.out.println("Executed!"))
                    .doOnError(error -> System.out.println("Error"));
        }
        return currentResult;
    }
}

但这种方法似乎完全不正确。有人知道我如何实现这样的东西吗？




Answer 1

更新：flatMap很容易被滥用。使用flatMap时，请确保您正在执行异步工作。大多数情况下，在我看来，你可以用最少的Mono做得很好。只要。

Flatmap是您必须对所提供的约束进行的操作。

executeAllGuys(Arrays.asList(new GuyWithReactiveReturnTypeMethod[] {
        (s)->Mono.just(s+"1"), 
        (s)->Mono.just(s+"2"), 
        (s)->Mono.just(s+"3")})) 
.subscribe(System.out::println);

Mono<String> executeAllGuys(List<GuyWithReactiveReturnTypeMethod> guysToExecute) {
    // your flow is starting here
    Mono<String> stringMono = Mono.just("start");
    for ( GuyWithReactiveReturnTypeMethod guyToInvoke: guysToExecute) {
        stringMono = stringMono.flatMap(guyToInvoke::execute);
    }
    return stringMono;
}

看看那些Mono。只要打电话就行了。为什么要创建N 1流来执行此作业？真正的问题是每次执行接口方法时都会创建一个新的流Flatmap停止当前流，并使用Flatmap方法返回的发布者启动新流。试着思考反应性，并将整个业务视为一条流。Streams中没有flatMap。应仅在单个流上执行反应式执行。

A单声道

>

通过获取Mono并返回Mono，使您的接口更加反应性。您的应用程序在每一步都进行map转换。这就是“连锁反应元件”。

executeAllGuys（Arrays.asList（新GuyWithReactiveReturnTypeMethod[]{s）-

Mono执行所有人（列表guysToExecute) { // 你的流从这里开始Mono stringMono=Mono.just（"start"）； for（Guy天反应返回类型方法guyToInvoke： guysToExecute）{stringMono=guyToInvoke.execute（stringMono）；}返回stringMono；}

接口GuyWithReactiveReturnTypeMethod{Mono execute（Mono string）；}

通过使用Flux而不是列表，使您的界面反应性更小，但使应用程序反应性更强。然后必须使用reduce将通量转换为单声道。您的应用程序正在执行Map/Reduce功能。我不认为Flux可以保证流中元素的执行顺序，但它可以更有效地执行所有的购买。

//你的流从这里开始执行所有的人（Flux.just-

单声道执行所有人（通量guysToExecute）{返回guysToExecute.reduce（"start"，（str， guyToInvoke）-

参考：反应性编程：Spring WebFlux：如何构建微服务调用链？