是否建议将 Arraylist 转换为 Reactor 的 flux 来处理数据？

Question

我的一位同事对我说，与其处理流，不如创建一个 Flux 而不是按原样使用 List，然后将我的数据处理到它。但这对我来说没有意义，因为我认为反应流通常对阻塞 io 而不是数据处理有用。有人可以验证我的同事建议的新方法是否正确。如果它是正确的，它比我以前的方法有什么优势（性能方面）//ModelrootObject{List<rootNodes> rootNodes}//My current code MonoOfRootObject.map( rootobject.getrootnodes.stream().(..do some filtering and replacement..) )//Proposed code according to my colleagueMonoOfRootObject.map( Flux.fromIterable(rootobject.getrootnodes).(..do some filtering and replacement..) )请帮助我对 Reactor（或一般的函数式编程）有点陌生

Answer 1

你是对的。当您需要处理异步数据和/或并发时，Reactor 和 Reactive Streams 通常很有用。

要在内存列表上进行常规过滤和转换，Java Stream 完全没问题，而使用 Reactive Stream 就太过分了（而且可能在性能方面也有开销）。