反应堆上的通量操作会按顺序发生吗？

Question

如果我在通量上有两个平面图，它们将始终按顺序执行

Flux.just(1,2,3,4)
    .flatMap(...) 
    .flatMap(...) // Will this always execute 2nd?

Answer 1

这取决于你到底想表达什么——具体细节在这里很重要。

对于任何给定元素，答案是肯定的 - 它将由第一个 flatMap 调用处理，然后由第二个 flatMap 调用处理该 flatMap 调用的结果。回想一下，reactor 中的操作符与普通的 Java 流类似，是链式的——因此没有明智的方法可以让它们不按顺序操作。

但对于所有元素来说，不会 - 因为它不会处理所有 4 个元素的第一个 flatMap 调用，然后处理所有 4 个元素的第二个 flatMap 调用 - 每个元素都是独立处理的。当您认为 Flux 类似于可能没有尽头的元素流，而不是定义的有界集合时，如果它不这样做就没有多大意义。

Answer 2

让我们考虑这些小例子：

Flux.just(3, 2, 1)
  .flatMap(e -> {
    System.out.println("First FlatMap : " + e);
    return Mono.just(e).delayElement(Duration.ofMillis(e * 100));
  })
  .flatMap(e -> {
    System.out.println("Second FlatMap : " + e);
    return Mono.just(e);
  })
  .blockLast();

/*
First FlatMap : 3
First FlatMap : 2
First FlatMap : 1
Second FlatMap : 1
Second FlatMap : 2
Second FlatMap : 3
*/

Flux.just(3, 2, 1)
  .flatMap(e -> {
    System.out.println("First FlatMap : " + e);
    return Mono.just(e);
  })
  .flatMap(e -> {
    System.out.println("Second FlatMap : " + e);
    return Mono.just(e);
  })
  .blockLast();

/*
First FlatMap : 3
Second FlatMap : 3
First FlatMap : 2
Second FlatMap : 2
First FlatMap : 1
Second FlatMap : 1
*/

我们可以说操作员按照元素进入的顺序处理元素。