scala - 什么机制使用 Akka Actor 来持久化其消息？

Question

Tha Akka 文档表明：

持久邮箱是持久的标准参与者邮箱的替代品。

作为标准邮箱，Actor 可以在重启后读取其消息的机制是什么？

谢谢你。

score 1 · Accepted Answer

我已经实施了一个小项目来亲自检查一下。

Actor 邮箱的配置是通过调度程序实现的。以下是邮箱的可能性：

UnboundedMailbox
BoundedMailbox
UnboundedPriorityMailbox
BoundedPriorityMailbox

最后：

Durable mailboxes

我必须使用指示邮箱是基于文件的调度程序来配置我的演员系统。在 Actor System 的配置中，以下几行是必需的：

my-dispatcher {
  mailbox-type = akka.actor.mailbox.FileBasedMailboxType
}

此外，我为基于文件的持久邮箱配置了属性，其中提供了以下指示：

最后，我想保存在文件中的特定 Actor 的创建者使用以下内容创建 Actor：

context.actorOf(Props[MyActor].withDispatcher("my-dispatcher"), "myactor1"

我仍然需要更多的练习来重新创建一个 Actor 并阅读邮箱中剩余的消息，但现在主要问题已经得到解答。

一切都在文档中找到，这只是完成工作的问题。

1 回答 1