scala - 使用 akka-persistence : growing state as list? 的事件溯源

Question

我正在使用 Akka + Scala 设计使用 CQRS + 事件源的后端。我不确定如何处理不断增长的状态。例如，我将拥有越来越多的用户列表。据我了解，每个用户都将在 UserCreated 事件之后创建，这些事件将由 PersistentActor 重放，并且用户将存储在一个集合中。就像是:

class UsersActor extends PersistentActor {

    override def persistenceId = ....

    private case class UsersState(users: List[User])

    private var state = UsersState()

    ....
}

显然这样的状态最终会变得太大而无法被这个 Actor 记住，所以我想我做错了什么。

我找到了 this示例项目:这个想法似乎每个用户都应该由不同的 Actor 持有，并根据需要加载(从事件历史记录)。

这样做的正确方法是什么？非常感谢。

Answer 1

答案是:每个聚合/实体(在我的示例中，每个用户)都有自己的参与者，它嵌入了该特定实体的状态，并且仅嵌入了该实体。