使用akka-persistence的CQRS + Event Sourcing实现

Question

我想使用akka-persistence事件采购功能,以便在我的新项目中实现CRQS +事件采购理念.问题是除了文档(http://doc.akka.io/docs/akka/snapshot/scala/persistence.html)之外,我找不到任何好的示例或指南如何处理它.该文档在解释体系结构的所有构建块(如处理器,视图,通道)方面非常出色,但没有解释如何将它们组合在一起.

所以问题是:如何在akka-persistence中将写模型与读模型连接起来？我想出了三个选择:

• 直接连接Eventsourcedrocessor - > View,View直接从日志中接收所有事件.这似乎是最简单的解决方案,但我想知道我们是否可以使用这种方法在不同节点上分配处理器和视图.

• Eventsourcedrocessor - > Channel - > View/normal Actor.与第一个选项有什么区别？如果这是正确的解决方案,为什么我们在akka-persistence构建块中有视图？我应该使用频道还是PersistentChannels？

• Eventsourcedrocessor - >某种事件总线(例如context.system.eventStream) - > Views/Actors.

什么是最好的方法,为什么？

Answer 1

EventsourcedProcessor -> View 就是这样做的方法。视图从日志中重播，因此将视图放置在另一台计算机上时需要分布式日志。日志实现列表可以在这里找到： http: //akka.io/community/