如何在消息驱动的体系结构中恢复事件

Question

我只是想知道在消息驱动的体系结构中恢复和重放消息的标准方法是什么。

以为例

消费者在完成事件并更新状态以完成之前意外死亡，或者如果事件正在发生要完成的时间比平时长。

每个事件都将在表上有一行，以便我们可以跟踪事件。假设当事件行没有已经更新了一段时间，例如15分钟，并且状态不完整。

在消费者死亡的任何一种情况下意外或某个事件耗时超过15分钟。将触发重播。这将导致的重复事件同样的信息。

解决挂起进程的一种方法是超时并在超时后终止进程。还有别的办法吗？

Answer 1

预计在失败时会重新交付事件。因此，事件处理必须是幂等的。

幂等性是如何实现的取决于一个特定的用例。