问CQRS和事件源-阅读您自己的事件

EN

不久前我们也做过类似的事。基本上，我们

1. --实现流程管理器模式的服务，并使用EventSourcing和Saga在多个服务之间执行一些编排逻辑。存储在数据库中的每个事件都包含一个序列化为Avro格式的EventPayload，其中包含事件发生时进程的状态。该有效载荷包含所有状态，而不仅仅是差异，因此我们在processing.
2. We've使用Kafka连接器从EventStore中读取时，我们一直在更新该有效负载。基本上，当一个新事件在EventStore中发布时，连接器读取事件并将其发布给卡夫卡(卡夫卡用作EventBus)。放置在另一个服务中的读取模型
3. 是通过Kafka更新的(这里有两种方法:使用卡夫卡连接JDBC Sink连接器或使用卡夫卡消费者和从消费者进行事务更新)。

我希望它能帮到你！

--我在想，如果我更新我的ReadService来直接听CommandService事件存储，而不需要事件总线，那么我可以减少其中一个延迟。

是的，您将减少延迟，但是您将引入两个服务之间的耦合，这并不一定不好，但是如果这两个服务是解耦的(使用总线)，您可以独立地扩展每个服务。

此外，如果您使用托管总线(如RabbitMQ )，您将受益于消息确认、多种类型的消息传递和queues..etc。