当前位置: 首页 > 知识库问答 >
问题:

了解阿克卡演员存在的三种方法

翁昊乾
2023-03-14

我正在研究akka actors(JAVA),最近我知道有3种方法(可能更多)来了解一个演员的存在。

>

ActorSelection sel = actorSystem.actorSelection("akka://test/user/TestActor");
AskableActorSelection asker = new AskableActorSelection(sel);
Future<Object> future = asker.ask(new Identify(1), new Timeout(5,
        TimeUnit.SECONDS));
ActorIdentity identity = (ActorIdentity) Await.result(future, timeOut.duration());
ActorRef reference = identity.getRef();
if(reference != null){
  // Actor exists
} else {
// Actor does not exits
}

解决方法之一:

ActorSelection sel = actorSystem.actorSelection("akka://test/user/TestActor");
Future<ActorRef> future = sel.resolveOne(new Timeout(5,
        TimeUnit.SECONDS));
// Wait for the completion of task to be completed.
future.onComplete(new OnComplete<ActorRef>() {
    @Override
    public void onComplete(Throwable excp, ActorRef child)
            throws Throwable {
        // ActorNotFound will be the Throwable if actor not exists
        if (excp != null) {
                // Actor does not exists
        } else {
            // Actor exits
        }
    }
}, actorSystem.dispatcher());

DeatchWatch:创建另一个参与者调用getContext()。手表(ActorWatch的ActorRef);并检查是否接收到终止的消息。这只能用于已创建的参与者。

1,2表示存在参与者和3个监视器。我想知道这三个应用程序的用例以及它们对actors邮箱和功能的影响,以便我可以选择适合我的应用程序的类型。

检查演员是否存在是一种好的做法吗?如果不是,为什么。

共有1个答案

惠野
2023-03-14

好吧,只有一种方法可以知道演员在过去的某个时刻是否存在:如果你从他那里收到信息。以上所有这些都只是这个主题的变体。

也就是说,一旦你有了ActorRef,你就可以使用死亡观察来通知那个演员的终止。但是尚未收到终止消息并不意味着参与者还活着:终止可能已经在路上了。

把演员想象成只能通过发送电子邮件进行交流的人。这种类比在它们交互的语义上非常有效。

 类似资料:
  • 问题内容: 我正在研究akka演员(JAVA),最近才知道有3种方法(可能更多)来了解演员的存在。 发送识别消息 : resolveOne方法 : DeatchWatch :创建另一个actor调用 getContext()。watch(actorToWatch的ActorRef); 并检查是否收到 终止 消息。这只能用于已经创建的actor。 1,2告诉演员和3个监视器的存在。我想知道这三个的用

  • 我有父母和孩子。每个儿童演员控制一个装置。当我创建所有的子角色时,我给他们一个uuid。 每个子参与者都是通过设备配置创建的,当配置更改时,我希望通过以下方式重新创建参与者: > 停止旧的: 最终的未来停止了=优雅的停止(actorRef,Duration.create(1,时间单位。秒)); Await.result(停止,Duration.create(1, TimeUnit.二)); 重新创

  • 我正在学习如何使用上下文。为了控制我的参与者的状态,我使用以下代码: 当我发送第一条消息时,“接收”工作并打印消息,第二条消息不显示后,这是我的输出: 如果我改变接收方式,为此: 我收到以下输出: 所以我试着跟踪“接收”被“阻止”的时刻,但没有成功,我的疑问是:当我使用上下文时。在《我的演员》中,Akka如何以及何时处理第一次之后的信息?

  • 我只是从阿卡开始,我试图将一些混乱的功能分成更容易管理的部分,每个部分都由不同的演员执行。 我的任务似乎正是适合演员模式的。我有一个对象树,它们保存在数据库中。每个节点都有一些属性;让我们只关注一个,称之为财富。孩子的财富取决于父母的财富。当计算节点上的财富时,这应该会在子节点上触发类似的计算。我想收集节点的所有更新实例,并同时将它们保存在数据库中。 这似乎很简单:一个参与者只需执行计算,然后为当

  • 是否有方法获取创建actor的类。例如,我有一个actorRef或actor selection实例,我想从中获取创建现有actor的类。提前感谢您的回复!

  • 我是Akka的新手,我想知道我应该如何处理将工作委托给其他(儿童)演员的演员,但在哪里: 其中一些儿童演员必须按特定顺序参与;和 其中一些子参与者可以以任何顺序参与,并且可以真正地与主/父参与者所做的事情异步执行 假设我有以下儿童演员(不管他们做什么): 假设我有以下调用它们的父参与者: 如你所见: 必须首先“参与”(由家长调用),我们必须等待家长的响应,然后才能继续参与/调用、或 换句话说,当消