call methods on akka actors in scala

2019-04-05 07:01发布

I have a an actor defined as so:

class nodeActor(ID: String) extends Actor

which contains a method, which is used to set up the actor before it is started:

def addRef(actor:ActorRef)

I instantiate this actor as so:

val node1 = system.actorOf(Props(new nodeActor("node1")), name="node1")

which returns me an ActorRef. The compiler doesn't let me call "addRef" on an ActorRef since it's a member of the subtype. So I cast the node using:

node1.asInstanceOf[nodeActor].addRef(link1)

Which keeps the compiler happy. Then at runtime I get

java.lang.ClassCastException: akka.actor.LocalActorRef cannot be cast to ActorStressTest.nodeActor

which doesn't even seem to make sense to me since it's a subtype and I should be able to cast to it.

Ideas?

标签: scala akka actor
3条回答
闹够了就滚
2楼-- · 2019-04-05 07:07

You're not supposed to call an actor's methods directly from another class. It breaks the whole design of the system, which is

  • to encapsulate the actor's specific implementation by communicating only with the ActorRef obtained with the call to actorOf or actorFor
  • to limit communication between actors to message passing, using the available (!, ?) methods

If you need to create a reference in ActorA to another ActorB you can:

If you need to call a method to satisfy an Interface/Trait constraint, have a look at Typed Actors

查看更多
仙女界的扛把子
3楼-- · 2019-04-05 07:24

If you want to do this for testing then when creating actor you can just do this:

import akka.testkit.TestActorRef
val actorRef = TestActorRef[MyActor]
val actor = actorRef.underlyingActor

Then you can run methods on actor

查看更多
贪生不怕死
4楼-- · 2019-04-05 07:26

You can cast anything to anything and the compiler will happily do so, but the check at runtime will fail if it's not possible. The ActorRef is not an instance of your Actor class or a subtype of it.

When you do this:

system.actorOf(Props(new nodeActor("node1")), name="node1")

You get back an ActorRef to which you should only send messages. Apart from that, the actor is started immediately when you call system.actorOf, so trying to call a method on the Actor instance before it is started is not possible.

Here is a description of actors from the Akka Docs explaining actor references.

查看更多
登录 后发表回答