混合使用反应式代码（即单声道）可以吗

Question

我有两个对象，每个对象都包含一个列表，我的整个Spring Boot项目都使用ProjectReactor构造。我应该在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

我有时觉得，就在Java8出现后，我们看到了同样的“想为一切使用流”心态的重现，但是有了Reactor/RXJava。

我应该在通量或单声道映射操作中使用java流进行遍历吗

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

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

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