Akka Persistence和Akka Persistence Query有什么区别？

Question

Akka持久性查询通过提供基于通用异步流的查询接口来补充Persistence,各种日志插件可以实现这种接口以公开其查询功能.

这是来自akka文档的'Akka Persistence Query'的描述.我想知道它只用于查询,换句话说只用于读取端？

Answer 1

可能更好的问题是为什么Akka持久性查询不是Akka持久性的一部分？如果你不能查询,持久性有什么用呢？

Akka持久性只寻求解决一件事和一件事,使一个演员的状态持久.它并不关心该actor是否代表一个域实体,或者它是否只是一个操作actor,其状态需要在重新启动后继续存在(例如集群共享管理器的情况,在切换到之前用于在Akka持久性中存储其状态)分布式数据).它只是一个通用的目的"让这个演员持久化"的功能.

现在,Akka持久性的一个常见用途是实现事件源域实体.然而,事件源域实体需要的不仅仅是"使这个actor持久化",它们通常还需要能够跨域实体执行查询.因此,存在Akka持久性查询以允许此操作,它允许创建可以处理以填充读取侧视图的跨实体流.

问题是,并非所有事件存储都必然能够轻松地进行跨实体流式传输.所以那些不能实现Akka持久性,并用于使actor持久化,而提供更多功能的存储也可以实现Akka持久性查询.

这一切都大大简化了,但希望能解释一些动机.