我正在使用用于 akka-persistence 的 scala api 来持久化一组被组织成树的参与者实例。树中的每个节点都是一个持久的参与者,并根据从“根”节点到该节点的路径来命名。persistenceId 设置为名称。例如,根节点 actor 具有 persistenceId 'root'。下一个节点有 persistenceId 'root-europe'。另一个参与者可能有 persistenceId 'root-europe-italy'。
每个参与者的状态包括其孩子的姓名列表。例如,“根”参与者维护一个“欧洲”、“亚洲”等列表作为其状态的一部分。
我已经为这个系统实现了快照。当根被触发快照时,它会这样做,然后告诉每个孩子也这样做。
问题出现在快照恢复期间。当我重新创建一个具有 persistenceId = 'root' 的演员(通过将名称作为构造函数参数传递)时,该演员收到的 SnapshotOffer 事件是错误的。例如,它是“root-europe-italy....”。这似乎与持久性合同相矛盾,其中persistenceId 标识要恢复的参与者状态。我通过反转节点参与者的persistenceId(例如'italy-europe-root')解决了这个问题,所以这似乎与持久性模块检索文件的方式有关。请注意,我首先尝试了其他方法,例如我在节点名称之间使用了各种分隔符,或者根本没有分隔符。
有没有其他人遇到过这个问题,或者 akka-persistence 开发人员可以帮助我理解为什么会发生这种情况?
顺便说一句:我现在正在使用内置的基于文件的快照存储。
谢谢。