斯卡拉消息總線實施的演員？

Question

我想在我的一個Scala應用程序中實現某種消息總線。的特徵是：

• 能力訂閱1 ... N類型的消息
• 消息可以具有有效載荷
• 鬆耦合（僅節點持有參考總線）
• 輕量級（無全面的企業消息隊列等）

我打算做的是實現所有節點和總線本身作爲標準的斯卡拉參與者。比如我要定義一個特質Subscriber這樣的：

trait Subscriber[M <: Message[_]] { 
    this: Actor => 
    def notify(message: M) 
} 

在這個特質理想的混合應該已經登記認購類型M。

這個想法是否有意義？是否有更好的方法來實現消息總線？

Answer 1

免責聲明：我是阿卡的PO

嗨ITTI，

這已經爲你在阿卡完成，演員內核：www.akka.io

文檔：http://doc.akkasource.org/routing-scala

酒吧/ Sub：Akka Listeners 路由器：Akka Routers 便利性：Akka Routing