【问题标题】:Can an Actor peek at it's MessageQueue in Akka.netActor 可以在 Akka.net 中查看它的 MessageQueue
【发布时间】:2016-09-25 01:52:31
【问题描述】:

我有一个 IPClient 参与者,它管理/拥有一个打开/关闭代价高昂的连接。

在演员处理完一条消息之前,我想看看演员的邮箱顶部是否有另一条消息待处理。 - 如果演员有更多工作,请保持连接打开。 - 如果actor清空了它的邮箱,关闭连接。

以下是我所想的要点:

public void Handle(PollDevice message)
    {
        if (!_client.IsConnected)
            _client.Connect();

        var results = _client.GetData()

        var actorHasMoreWork = Context.Dispatcher.Mailboxes.???
        if (!actorHasMoreWork)
            _client.Disconnect();

        Sender.Tell(true);
    }

这可能吗?这是最好的方法吗?

【问题讨论】:

  • _client 是否具有特定于该参与者的状态?想知道您是否可以只使用池连接,其中您有一个保持打开连接的参与者池,并且示例中的该参与者将消息转发给他们
  • 刚刚遇到这个问题,想知道您是否能够偷看邮箱? (嗯,我想我看到曾经有一个 PeekMailbox 是别的东西 - 让你从邮箱中提取下一条消息而不删除它 - 但它已被弃用。)我只是想说我的工作与 -我知道的解决方案是默认保持连接打开,但让参与者发送一个简单的...
  • ...在方法结束时向自身发送消息(同时还保留对消息的实例级引用)。如果刚刚发送的消息是收到的下一条消息,那么队列中显然没有任何内容,所以继续关闭连接。

标签: akka.net


【解决方案1】:

我有部分答案。

您可以使用Context.Props.Mailbox获取演员的邮箱ID(但不能获取邮箱本身)

一旦你有了演员的邮箱(同样,上一步不会给你),我对文档的理解表明你应该能够使用Mailbox.MessageQueue.HasMessagesMailbox.MessageQueue.Count 来获取有关内容的信息.据我所知,如果不将它们出列,您将无法看到任何消息。

但是,我无法确定获取 Mailbox 对象的方法,实际上我发现了一些证据,目前在 Akka.Net 中是不可能的。 a GitHub issue about making this possible 从 2014 年 9 月开始开放,最后一次更新也是从 2014 年 9 月开始。

【讨论】:

猜你喜欢
  • 2023-04-11
  • 1970-01-01
  • 1970-01-01
  • 2020-04-26
  • 2015-07-21
  • 1970-01-01
  • 2016-06-08
  • 2015-09-06
  • 1970-01-01
相关资源
最近更新 更多