創作演員

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