Spring反应器Thread模型

Question

我的理解是Spring Webflux提供了一个非阻塞/异步并发模型。然而，我得到了一个需要帮助的基本问题。作为一个免责声明，这种反应编程的整个概念对我来说是非常新的，我仍然处于这种范式转变的过程中。

请考虑以下代码：

Mono.just("ONE")
.map(item -> func(" A " + item))
.map(item -> func(" B " + item))
.map(item -> func(" C " + item))
.subscribe(System.out::println);

Mono.just("TWO")
.map(item -> func(" A " + item))
.map(item -> func(" B " + item))
.map(item -> func(" C " + item))
.subscribe(System.out::println);

我从文档中了解到，在调用“subscribe”函数之前，事件处理链不会发生任何事情。

我注意到代码总是按顺序运行，并且使用相同的线程。spring WebFlux的线程模型是什么？

Answer 1

反应编程是一种编程范例，因此它不对技术实现做任何假设。

reactive manifesto描述了reactive系统，并将异步通信和背压放在桌面上。除此之外，它也没有对技术细节做任何假设。

Spring Reactor是Webflux的基础，它是一个库，允许您轻松地构建反应性系统并遵循反应性编程范例。

Flux.interval(Duration.ofMillis(100))
    .take(2)
    .subscribe(i -> System.out.println(Thread.currentThread().getName()));

再来看一个例子：

Scheduler scheduler = Schedulers.newElastic("foo");

Flux<Integer> flux = Flux.just(1, 2)
    .subscribeOn(scheduler);

flux.subscribe(i -> System.out.println(Thread.currentThread().getName()));
flux.subscribe(i -> System.out.println(Thread.currentThread().getName()));

您将注意到，每个订阅服务器都运行在自己的线程上（尽管来自相同的线程池）。publishon运算符与此类似。

如果您订阅了发布服务器，则可以使用相同的编程范例，而不管它是同步的还是异步的。并且始终可以通过添加subscribeon或publishon运算符引入异步行为。