我想创建一个从 REST 控制器上的 sendAndWait 命令到 @Endsaga 的同步 saga 流程（包括中间步骤）。
只有在查询端（单独的项目）发送事件（读取存储查询端的成功或失败）后才能到达@Endsaga，通知 Saga 发生了什么。
这是使用下面链接中描述的传奇模式向客户发送电子邮件的唯一性验证过程的一部分：
http://foreverframe.net/how-to-guarantee-username-uniqueness-with-cqrses/
我不确定如何在 Axon 中正确进行此配置。
你能帮帮我吗？
谢谢。
【问题讨论】：
标签： microservices cqrs axon
我个人认为选项 2（来自您提到的文章）是最务实的。我不同意在命令端为 DB 提到的cons。
为了检查唯一性，我会使用一个小的命令端投影（在命令组件/包内）。在 Axon 中，这将是一个常规的事件处理程序，它将处理事件并以非规范化的方式填充一个小表，因此您可以在稍后的命令处理程序中使用它进行唯一性检查。 此事件处理程序/处理器应为订阅类型 (https://docs.axoniq.io/reference-guide/configuring-infrastructure-components/event-processing/event-processors#event-processors)
订阅事件处理器将使用相同的事务来存储事件和投影。这就是为什么在这里使用这种特殊类型的事件处理器很重要的原因。立即一致。
不要在此存储库（投影）之上公开 Axon 查询 API，只需将此存储库注入您的聚合处理程序以检查唯一性。这样，投影 API 将仅可供您的命令组件使用，而不会暴露给外界。
【讨论】：