在scala中调用akka actor上的方法

Question

我有一个演员定义如此:

class nodeActor(ID: String) extends Actor

它包含一个方法,用于在actor启动之前设置它:

def addRef(actor:ActorRef)

我将这个actor实例化为:

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

它返回一个ActorRef.编译器不允许我在ActorRef上调用"addRef",因为它是子类型的成员.所以我使用以下方式投射节点:

node1.asInstanceOf[nodeActor].addRef(link1)

这让编译器感到高兴.然后在运行时我得到

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

这对我来说似乎没有意义,因为它是一个子类型,我应该能够投射它.

想法？

Answer 1

如果你想做这个测试,那么在创建actor时你可以这样做:

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

然后你可以在actor上运行方法

Answer 2

你不应该直接从另一个类调用actor的方法.它破坏了系统的整体设计

• 通过仅与ActorRef通过调用actorOf或获得的获得通信来封装actor的特定实现actorFor
• 使用可用的(!,?)方法限制actor与消息传递之间的通信

如果您需要在ActorA另一个中创建引用,ActorB您可以:

• 创建裁判ActorB在ActorA的初始化代码,如图http://doc.akka.io/docs/akka/2.0.3/scala/actors.html
• 将该ActorB引用ActorA作为特定消息发送.然后ActorA可以在receive实现中存储引用

如果需要调用方法来满足Interface/Trait约束,请查看Typed Actors