project-reactor - 序列化反应堆中的通量

Question

可以序列化 Reactor Flux。例如，我的 Flux 处于某种状态，当前正在处理某个事件。突然服务终止。Flux 的当前状态保存到数据库或文件中。然后在重新启动应用程序时，我只需从该文件/表中获取所有 Flux 并订阅它们以从上一个状态重新启动处理。这在反应堆中可能吗？

Answer 1

不，这是不可能的。Flux不可序列化并且更接近于函数链，它们不一定具有状态^[1]但描述给定输入（由初始生成提供Flux）要做什么......

因此，为了“重新启动” a Flux，您必须实际创建一个新的，以获取原始输入在服务终止时收到的剩余输入。

因此，保存最后发出的状态并允许从那里重新启动新的Flux 序列将更多地取决于您的数据源。

---

^[1]虽然，根据您链接的运算符，您可能会影响某些外部状态。在这种情况下，事情会变得更加复杂，因为您还必须保持该状态。