使用有界消息队列创建一个 actor

Question

我们需要创建一个 Actor，一旦它的邮箱被填满到一定大小就会丢弃消息。浏览程序集发现有一个 BoundedMessageQueue 已经实现并提供选项：

邮箱容量
邮箱推送超时时间

我们无法弄清楚如何使用 BoundedMessageQueue 和适当的设置创建 actor 的正确语法。我们能得到的最接近的是 Props.Create(...).WithMailbox(???)

如有任何帮助，我们将不胜感激。

Answer 1

使用 BoundedMailbox，由 BoundedMessageQueue 支持。

在您的配置中（注意邮箱需要在 akka 命名空间之外定义）：

akka { ... }

bounded-mailbox {
    mailbox-capacity = 1000
    mailbox-push-timeout-time = 10s
    mailbox-type = "Akka.Dispatch.BoundedMailbox, Akka"
}

然后，用这个邮箱创建一个演员：

Props.Create<ActorType>().WithMailbox("bounded-mailbox");

使用有界消息队列创建一个 actor

Create an actor with a BoundedMessageQueue

akka.net