反应堆核心崩溃和重启状态

Question

我是 reactor-core 的新手，以前做过 Erlang。

希望是一个快速的问题。

假设我们发送了一条消息 'A'，然后期望在 x 分钟内得到回复。如果在 x 分钟内没有响应，我们运行一个回退例程。

可以通过方法 timeout(duration, fallback) 使用 Flux 或 Mono 来完成

Here is the API from the rector-core site

public final Mono<T> timeout(Duration timeout,
                             Mono<? extends T> fallback)
Switch to a fallback Mono in case no item arrives within the given Duration.
If the fallback Mono is null, signal a TimeoutException instead.
Parameters:
timeout - the timeout before the onNext signal from this Mono
fallback - the fallback Mono to subscribe to when a timeout occurs
Returns:
a Mono that will fallback to a different Mono in case of timeout

如果 JVM 崩溃并重新启动会怎样？

假设崩溃和重启需要 y 分钟。（假设 y 小于 x）

reactor-core 知道崩溃发生了吗？知道现在需要等待 (x-y) 分钟，它可以重新启动流的处理吗？

我知道 Camunda 在 RDBMS 中存储状态。因此也许它应该从崩溃中恢复。

Answer 1

Reactor 是一个旨在在 JVM 边界内处理实时事件的库，包括处理数据的位置和生命周期。持久状态（到磁盘或任何地方）或从 JVM 崩溃中恢复超出了库的范围。

反应堆核心崩溃和重启状态

reactor-core crash and restart state

reactor

camunda

project-reactor

reactive-streams