AxonIQ 在重放旧事件的同时处理新事件

偶尔，我们不得不从轴突事件存储中重放事件以更新我们的预测。这个重播需要几个小时，随着时间的推移只会持续更长的时间。这意味着我们的应用程序在重放进行时不会处理新事件。

我想知道是否有办法在重播的同时继续处理事件？ axon 是否提供了这样的机制，或者我们是否必须创建两个不同的事件处理程序：一个用于“正常”处理，另一个用于重放？

Axon 没有为此提供开箱即用的解决方案。大致来说，您可以采取两种方法：

进行蓝/绿部署。十分之九，需要重放以符合开发期间构建的新查询模型格式。如果您使用蓝/绿部署方式，您可以简单地预热/重放新实例，并在完成后跳过。
在调用重放期间实现额外的组件以构建新的 TrackingEventProcessor 及其包含的事件处理组件。此外，新的查询模型存储需要并行运行以存储新格式，并在该过程完成后使用别名进行切换。

我打赌其中一种选择是最少的代码工作和更多的操作。选项 2 当然会翻转。

请注意，在进行重播时，您将总是需要处理某种程度的最终一致性。事件只是在系统中不断发生，因此从概念上讲，到达事件流的末尾是不会发生的。因此，在此空间中构建任何解决方案之前，您需要决定重放何时足够。

最后，还有一些方法可以提高事件处理速度，从而也提高了重放速度。 This blog 快速浏览了您为此可以做什么，简而言之，可以通过调整事件处理 batchSize、处理线程和段的数量，最后结合 Axon 的 {{ 1}} 以改进数据库访问。

更新

在谈到重播功能时，需要注意的是，它是一个强大但笨重的工具。任何事件系统（不仅仅是 Axon），您需要对数十亿个事件进行重放，都会给实施和部署策略带来一些压力。或者更进一步，是否应该这样做。

因此，您必须推断重播是否是解决手头问题的最佳解决方案。有时，简单地直接更新您的查询模型是最实用的解决方案，并且可以节省大量时间。但在某些情况下，您会在事件处理和部署策略方面实施增强功能，以允许快速重播。

我还看到很多域的重播不需要事件存储的完整重播。如果应用程序的用户只需要立即显示去年的模型，那么只重放去年的事件要简单得多。也许即使是最后 3 个月也足够了。

从概念的角度来看，重播可以解决您系统中的所有答案。这绝对是寻求事件溯源解决方案的好处，因为您实际上拥有单一的事实来源。但与任何工具一样，您应该在正确的时间将其用于正确的问题。

谢谢Steven。博客中的改进很有趣，但即便如此，10 亿的事件流也需要接近 10 个小时才能重播，而且在如此长的时间内错过新事件是不可接受的。所以我想即使事件处理速度非常好，仍然需要通过实施您提出的两种解决方案之一来解决问题。