【发布时间】:2015-12-04 18:24:23
【问题描述】:
我正在使用 Akka + Scala 使用 CQRS + 事件源来设计后端。我不确定如何处理不断增长的状态。例如,我将拥有越来越多的用户列表。据我了解,每个用户都将在 UserCreated 事件之后创建,此类事件将由 PersistentActor 重播,并且用户将存储在一个集合中。比如:
class UsersActor extends PersistentActor {
override def persistenceId = ....
private case class UsersState(users: List[User])
private var state = UsersState()
....
}
显然这样的状态最终会变得太大而无法被这个演员保存在内存中,所以我想我做错了什么。
我找到了this 示例项目:这个想法似乎每个用户都应该由不同的参与者持有,并根据需要(从事件历史记录)加载。
这样做的正确方法是什么?非常感谢。
【问题讨论】:
-
事件溯源不适用于应用程序的所有部分。您是否需要所有用户的列表才能查询它以让用户登录或退出?
-
感谢您的评论@jazmit - 不,我不需要同时让所有用户“出席”。我正在研究我链接的项目,它似乎只会“膨胀”它需要的项目才能提供或更新它。你有进一步的提示吗?
-
是的,但是种子项目为每个用户使用一个持久演员。. 仍然不确定你到底在追求什么,我唯一能想到的就是不要设计不断增长的领域演员状态..
标签: scala akka cqrs event-sourcing akka-persistence