我有这种困惑，doOnNext 何时在 Publisher (Flux/Mono) 元素发射之前或之后触发。
【问题讨论】：
doOnNext 为您提供了带有Consumer 的流经管道的元素，因此它在后面。顺序是这样的：源发出项目 -> doOnNext lambda 被触发 -> 订阅者 onNext 被调用：github.com/reactor/reactor-core/blob/master/reactor-core/src/…
标签： java project-reactor
它在元素的 publication 之后 - 根据定义，它必须 在之后，否则传递给 doOnNext 的 Consumer 将无法访问发出的元素。
但是，doOnNext() 被称为在订阅者之前。例如：
Flux.just("first", "second")
.doOnNext(x -> System.out.println(x + " onNext"))
.subscribe(System.out::println);
...将输出：
first onNext
first
second onNext
second
【讨论】：
恐怕您还没有正确理解响应式，这很好:)。在 Rx 中，订阅是自下而上的。考虑以下代码：
Flux<Integer> f = Flux.fromIterable(Arrays.asList(1,2,3));
由于没有订阅者，所以什么都不会发生。不会发出任何项目。现在考虑一下：
f.subscribe(System.out::println)
发生的情况是订阅者订阅了通量，并发出了项目。
现在考虑一下：
f.doOnNext(System.out::println).subscribe(System.out.println);
请记住，订阅是以自下而上的方式进行的。所以在这里，订阅者订阅了doOnNext()，而doOnNext() 订阅了原始的通量，然后开始发出事件。 doOnNext() 然后拦截每个事件并执行一些副作用。
【讨论】：