Akka actor 从数据库中读取状态

Question

当需要从数据库初始化参与者状态时，我想询问模式。我有一个返回 Future[...] 的 DAO，并且通常是非阻塞消息应该在未来完成时发送给参与者。但这种情况不同。在初始化完成之前，我无法从演员邮箱收到任何消息。在等待数据库未来完成时阻塞actor线程的唯一方法是什么？

Answer 1

最简单的方法是定义两个接收方法，例如initializing 和 initialized，以 def receive = initializing 开头。在您的inizializing 上下文中，您可以简单地发回一条类似InitializationNotReady 的消息，告诉其他参与者他应该稍后再试一次。在你的actor初始化之后，你用context become initialized将你的上下文切换到新的状态，你可以正常操作。

毕竟，另一个不错的方法是查看Akka Persistence。它使有状态的 Actor 能够保持其内部状态，以便在 Actor 启动、JVM 崩溃后或由主管重新启动或在集群中迁移时恢复。

在您的情况下，您可以从数据库中恢复您的状态，因为它们是 Akka 持久性的多种存储选项。你可以找到他们here。恢复后，您就可以像习惯一样接收消息了。