Java反应堆流量/Mono，在发出元素之前或之后何时触发doOnNext？

恐怕你还没有完全理解反应性，这很好:)。在Rx中，订阅是自下而上的。考虑以下代码：

代码语言：javascript复制Flux f = Flux.fromIterable(Arrays.asList(1,2,3));因为没有订阅者，所以什么都不会发生。不会发出任何项目。现在考虑这一点：

代码语言：javascript复制f.subscribe(System.out::println)所发生的情况是订阅者订阅流量，并发出项。

现在考虑这一点：

代码语言：javascript复制f.doOnNext(System.out::println).subscribe(System.out.println);记住，订阅是以自下而上的方式进行的。在这里，订阅者订阅doOnNext()，doOnNext()订阅原始流量，然后开始发出事件。然后doOnNext()截取每个事件并执行一些副作用。