Akka - コモン・サービスの俳優：識別または拡張

Question

他の俳優のサービス層の俳優によって一般的に使用されているものがあるとします。たとえば、ドメインオブジェクト取り出し店や、レジストリサービス：

case class DomainObject(id: UUID) 

class Registry extends akka.actor.Actor { 
    def receive: Receive = { 
    case o: DomainObject => store(o) // save or update object 

    case id: UUID => sender ! retrieve(id) // retrieve object and send it back 
    } 
} 

を私は明示的にそれを使用する可能性のあるすべての関係者に、このようなレジストリのインスタンスを渡す必要はありません。その代わりに、私は彼らに何とか「位置づける」ことができるようにします。このため

私は2つの解決策を考えることができます：

1. Identifyメッセージ：各レジストリユーザーの俳優は、いくつかの設定と、それに識別メッセージを送ったことができるから、レジストリの俳優の名前を知っています。 AgentIdentityメッセージが戻って受信された後、私たちは行ってもいいです：

   val registryName = ... // some name 
   val registryId = ... // some id 
   var registry = _ 
   
   def preStart() { 
       context.actorSelection(registryName) ! Identify(registryId) 
   } 
   
   def receive: Receive = { 
       case ActorIdentity(`registryId`, ref) => registry = ref 
   } 
   

   右のユーザ俳優初期化した後、システム等でレジストリは、すべてがあれば、我々が知らない段階がありますので、私はこの方法を好きではないし、したがって、私たちは今までに動作するかどうかわからない。

2. アッカ拡張機能：

   ：私は希望拡張機能を作成することができます。初期化時に、指定されたActor Systemでレジストリアクタのインスタンスを作成します。

   b。 Extensionの何らかの方法でこのアクタを必要とするユーザに返します。

   object RegistryKey extends ExtensionKey[RegistryExtension] 
   
   class RegistryExtesion(system: ExtendedActorSystem) extends RegistryKey { 
       val registry = system.actorOf(Props[Registry], "registry") 
   } 
   

質問は：どの方法が優れているとアッカExtesionsがすべてで、このために使用することができていますか？

Answer 1

あなたのレジストリの俳優が常に同じになるつもりである限り、拡張のアイデアは良いと思いますActorSystem。

あるいは、（Remote Lookupから適応）actorSelectionを使用して：

class RegistryClient extends Actor { 
    val path = "/path/to/registry/actor" 
    context.setReceiveTimeout(3.seconds) 

    def sendIdentifyRequest(): Unit = 
    context.actorSelection(path) ! Identify(path) 

    def receive = { 
    case ActorIdentity(`path`, Some(ref)) ⇒ 
     context.setReceiveTimeout(Duration.Undefined) 
     context.become(active(ref)) 
    case ActorIdentity(`path`, None) ⇒ 
     throw new RuntimeException("Registry not found") 
    case ReceiveTimeout ⇒ sendIdentifyRequest() 
    } 

    def active(registry: ActorRef): Actor.Receive = { 
    // use the registry 
    } 
} 

これは、リモートまたはローカルのアクターのために動作します。

拡張ソリューションを見てみましょう。 Actors are created asynchronously。したがって、アクターが初期化に失敗した場合は、actorOfを呼び出すと、拡張コンストラクターが失敗することはありません。

アクターが初期化に失敗したことを知りたい場合は、askにアクターが応答し、Awaitに応答があります。アクターが応答しない場合、AwaitはTimeoutExceptionを投げます。

class RegistryExtension(system: ExtendedActorSystem) extends Extension { 
    val registry = system.actorOf(Props[Registry], "registry") 
    implicit val timeout: Timeout = Timeout(500.millis) 
    val f = registry ? "ping" // Registry should case "ping" => "pong" 
    Await.result(f, 500.millis) // Will throw a TimeoutException if registry fails 
           // to respond 
} 

初めてRegistryExtension(system).registryを呼び出すときTimeoutExceptionがスローされます。

Answer 2

subcutのようなCake Patternまたは依存性注入ライブラリはどうですか。

デレク・ワイアットは、俳優をルックアップするために、彼の著書「アッカ同時実行」の代わりのあまりactorForを使用してDIを言及： http://www.artima.com/forums/flat.jsp?forum=289&thread=347118