是否可以混合使用反应性代码，即 Mono 和 Flux 对象，它们是反应性流以及

Question

我有两个对象，每个对象都包含列表，我的整个 spring boot 项目都在使用项目反应器构造。我应该在 flux 或 mono map 操作中使用 java 流来遍历和操作数据吗？Flux.fromIterable(page.getPageFieldData()).subscribeOn(Schedulers.elastic()).map(pageField - > {        clientDataMono.subscribeOn(Schedulers.elastic()).map(clientData - > {            Flux.fromIterable(clientData.getPageFieldData())            .filter(clientPageField - > clientPageField.getId() == pageField.getId())            .subscribeOn(Schedulers.elastic()).map(field - > {                dataUpdated = true;                pageField.setData(field.getData());                return field;            }).subscribe();            return clientData;        }).subscribe();        if (dataUpdated) {            pageField.setModifiedOn(Instant.now(Clock.systemUTC()));        }        return pageField;    }).subscribe();或者我应该在 flux 的映射操作中使用 java 流。

Answer 1

有时我觉得在 Java 8 出现之后，我们看到了同样的“想要为所有事情使用流”的心态，但是有了 Reactor / RXJava。

我应该在 flux 或 mono map 操作中使用 java 流来遍历和操作数据吗？

简短的回答是，如果您可以明智地使用 Java 流，并且 Reactor 在这种情况下没有提供任何优势，那么就没有理由使用 Reactor。当用例需要时，Reactor / 反应式编程非常棒，但请记住，它是一个外部库（未捆绑在核心 JRE 中），它比标准 Java 流更复杂，更难被普遍理解。

Reactor 当然要强大得多。如果您需要控制产生值的速度、背压、详细的发布者/订阅者行为、多播、缓存、重试等，或者您可能在未来可行，那么它每次都会赢得胜利。

但是，如果您实际上只是过滤和映射现有的 Java 集合，就像您在该示例中那样，反应堆无法提供任何改进，我认为没有充分的理由不使用标准 Java 流。