创作演员

Question

我已经实现了一个可以添加到Actor的Listenable/Listener特质。我想知道是否可以将这种风格的特质附加到演员身上，而不必明确地调用监听器处理器方法？

此外，我期待在Akka库中找到这个功能。我是否错过了某些东西，或者有什么原因让阿卡不会包含这个？

trait Listenable { this: Actor => 
    private var listeners: List[Actor] = Nil 

    protected def listenerHandler: PartialFunction[Any, Unit] = { 
     case AddListener(who) => listeners = who :: listeners 
    } 

    protected def notifyListeners(event: Any) = { 
     listeners.foreach(_.send(event)) 
    } 
} 

class SomeActor extends Actor with Listenable 
{ 
    def receive = listenerHandler orElse { 
     case Start => notifyListeners(Started()) 
     case Stop => notifyListeners(Stopped()) 
    } 
} 

Answer 1

为什么不直接延伸Actor，或者如果你想非演员要收听还，创建与收听延伸演员一个ListenableActor？

然后，你可以在Actor中覆盖receive，就像你以前所做的一样（除非你想要调用super.receive也是，不是吗？ - 你只是想修改传入的函数）。

Answer 2

我建议你扩展Actor并使用abstract override。

Answer 3

这里是一个解决方案（从初级斯卡拉的例子的修改版本）：

import se.scalablesolutions.akka.actor.Actor 

case class AddListener(who: Actor) 
case class RemoveListener(who: Actor) 

class ListenableActor extends Actor { 
    private var listeners: List[Actor] = Nil 

    def receive = { 
     case AddListener(who) => listeners ::= who 
     case RemoveListener(who) => listeners.filter(_ ne who) 
    } 

    protected def notifyListeners(event: Any) = { 
     listeners.foreach(_.send(event)) 
    } 
} 

class ImplementingActor extends ListenableActor { 
    override def receive = { 
     super.receive orElse { 
      case Message(content) => println(content) 
     } 
    } 
} 

Answer 4

为什么我没有见过这个问题，嗯，嗯，迟到总比不到好：

http://doc.akka.io/docs/akka/snapshot/scala/routing.html

Answer 5

还有就是内置支持这阿卡：https://github.com/jboner/akka/blob/release-1.2/akka-actor/src/main/scala/akka/routing/Listeners.scala