NEventStore：Sagas、命令和不丢失它们

Question

NEventStore：5.1
简单设置：WebApp (Asp.NET 4.5) == 命令端

我正在寻找不丢失命令的“正确”方法，着眼于 sagas/process-managers，这可能会无休止地等待一个实际上从未发生过的命令产生的事件处理。

旧：调度员

我最初使用了同步命令，但关注 sagas/process-managers 我认为先存储它们然后通过 SyncDispatcher（或 AsyncDispatcher）获取它们会更安全。否则，我担心的是，如果 saga 尝试发送命令并且由于 app-crash/powerloss/... 导致命令未完成，它将丢失并且 noone会知道。

所以我创建了一个 command-stream 并将每个命令附加到其中。 IsDispatched 显示，如果该命令已被处理。
那行得通。

PollingClient 和 Command-Stream

现在调度程序已经过时，我切换到 PollingClient。我丢失的是Dispatched 信息。

出现了启动问题：
我天真地从当前最新的检查点开始轮询以后，但是当应用程序重新启动时，可能会存储命令但之前没有执行崩溃并因此丢失（实际上发生了）。

我刚刚遇到了想法：
将命令的基本结果作为（非域）事件存储在另一个流中。
此流将包含 CommandSucceeded 和 CommandFailed 事件。
每当应用程序启动时，最新的 command-id 或 command-checkpoint-number 就会被提取出来，用于在该命令之后立即加载命令...

问题

• 我担心同步命令处理会导致丢失 saga 生成的命令的危险吗？如果是，为什么？
• 这通常是个好主意吗：一个大的命令流？
• 这通常是个好主意吗：将通用命令结果事件存储在流中？

Answer 1

你可以：

1. 将您的命令存储在命令队列中|持久性日志
2. 在 NEventStore 上使用命令 ID (guid) 作为提交 ID
3. 在命令处理程序中将您的命令标记为已执行 |管道挂钩 |轮询客户端

NEventStore 在相同的 AggregateId (streamid) + CommitId 上为您提供幂等性，因此如果您的应用在命令被标记为已处理之前崩溃并重播命令，NES 会自动丢弃生成的提交。

Answer 2

Afaik NEventStore 旨在作为事件源的存储，即将域对象存储为事件流。命令和传奇与它无关。您的服务总线应该负责持久性和传奇管理。

就个人而言，我将事件存储简单地视为存储库详细信息。应用程序服务（命令处理程序）将在生成的事件被持久化后分派它们。

如果应用程序崩溃并且服务总线是持久的（不是内存总线），那么事件/命令将再次自动处理，因为服务总线应该检测消息是否未成功处理。当然，出于这个原因，您的消息处理程序应该是幂等的。