CQRS、EventStore 和事件溯源：SaveEvents 中的并发异常使用 RPC？

Question

我正在实现一个事件存储。我已经定义了一个 SaveEventsConsumer 来处理事件存储中的事件存储。如果我理解正确，CQRS 命令应该没有响应。然而，将事件保存到事件存储时可能会出现并发问题。我使用 RabbitMQ。例如，是否应该通知客户端以便通知用户？应该如何实施？使用 RPC 和错误格式？

我的第一种方法是：

客户端使用类似 RPC 的样式。 SaveEventsConsumer 通知客户端（成功或失败）。如果发生故障（例如并发），则将异常返回给客户端。

此解决方案是否符合 CQRS 模式？是一个好方法吗？还有其他方法吗？有什么改善吗？我应该使用任何 AMQP 标头或属性来指示错误（模仿 HTTP 错误代码）吗？

---

例如，在一个集群中：

同一个应用程序的两个实例修改同一个聚合。这些实例应该协调（在事件存储外部）还是必须检测并通知响应的事件存储？

Answer 1

虽然您确实不从命令返回值，但仍然可能发生异常。并发异常就是一个例子。这意味着异常作为命令处理的一部分被抛出。当你考虑它时，这是有道理的。您永远不希望发布尚未提交到事件存储的事件。因此，并发冲突检查需要作为整个命令过程的一部分进行。

我有一个帖子可能会有所帮助。你可以找到它here。