CQRS和事件来源-读取自己的事件

Question

当前，我正在实现事件驱动的体系结构，并具有用于命令的服务（写部分）和用于查询的另一服务（读部分）。>>

我现在正在做什么。

1. 在CommandService上接受命令
2. 在事件总线上存储事件并发布事件
3. ReadService侦听这些事件并更新读取模型

如果您听自己的活动，这听起来不错。假设我从CommandService监听外部事件

1. 听事件
2. 处理此事件的命令
3. 将您的域生成的事件存储在事件存储中，并将该事件发布到事件总线中
4. ReadService侦听这些事件并更新读取模型

通过这种方法，我可以看到更新读取模型存在两次延迟。第一次延迟-> CommandService时间拉事件第二次延迟-> ReadService时间来拉出从CommandService生成的事件。

我正在考虑，如果我将我的ReadService更新为直接监听CommandService事件存储而不需要事件总线，那么我可以减少这种延迟之一。

你怎么看？

[当前，我正在实现事件驱动的体系结构，并具有用于命令的服务（写部分）和用于查询的另一服务（读部分）。我现在在做什么。在...