Jak uzyskać absolutny adres URL zdalnego aktora z wnętrza aktora?

Question

Chcę zrobić coś takiego.

Aktor A:

actorB ! "info" 

    def receive()={ 
    case _ => { 
      println("Remote address is "+ _) 

     } 
} 

Aktor B: (ten wdrożony zdalnie)

def receive()={ 
case "info" => { 
     sender tell self.path.address.toString 

    } 

} 

chcę wrócić mi Akka ciąg: //10.4.20.40: 2555/slave/użytkownik/slaverunner. Ale otrzymuję tylko akka: // slave. Jak uzyskać zdalny host i port? . Własności host, port i hostPort na obiekcie adresowej dont powrócić niczego

Answer 1

Jeśli zadzwonisz

sender.path.toString 

w aktora A dostaniesz adres nadawcy. Nie musisz więc przekazywać adresu innemu systemowi aktorskiemu, o ile możesz wysłać do niego wiadomość.

Akka nie da ci zdalnej ścieżki dla aktora w systemie lokalnym, dlatego self.path.address.toString w aktor B nie będzie działać.

Jeśli naprawdę chcesz wysłać hosta i port z B na A, musisz uzyskać dostęp do RemoteActorRefProvider przez ExtendedActorSystem. Oficjalnym sposobem na to jest Extension. Na przykład:

class MyExtensionImpl(system: ExtendedActorSystem) extends Extension { 
    def address = system.provider match { 
    case rarp: RemoteActorRefProvider => rarp.transport.address 
    case _ => system.provider.rootPath.address 
    } 
} 

object MyExtension extends ExtensionKey[MyExtensionImpl] 

val address = MyExtension(system).address 

I to daje dokładny adres, który trzeba komunikować się zdalnie z B.

(uwaga ten kod działa z Akka 2.0.x. W 2.1.x można uniknąć dzieje przez RemoteActorRefProvider przy użyciu system.provider.getDefaultAddress)

W Akce jeśli używasz konstruowania adresy aktor w ten sposób do pracy z actorFor to trzeba się upewnić, że nazwy hostów dopasować dokładnie.

Na przykład jeśli ActorSystem myśli gospodarz jest foo.bar.com, a następnie będzie ignorować wiadomości wysłane przez zdalnego hosta do actorFor("akka://slave@foo:2555/user/slaverunner")

Answer 2

mam to owinięty String:

ConfigString("akka://serversys@127.0.0.1:2552") 

Korzystanie system.settings:

context.system.settings.config.getValue("akka.actor.deployment.\"/root\".remote") 

Aktor był "root" aktor, w schemat tkaniny zaproponowany przez Viktora Klanga w dyskusji grupy dyskusyjnej dotyczącej "ustalenia, czy aktor nie żyje". Powstał w ten sposób:

lazy val rootActor = actorSystem.actorOf(Props[Root], "root") 

z ActorSystem który został stworzony tak:

lazy val actorSystem = ActorSystem("serversys", ConfigFactory.parseString(""" 
akka { 
    loglevel = "DEBUG" 
    actor { 
    provider = "akka.remote.RemoteActorRefProvider" 
    } 
    remote { 
    transport = "akka.remote.netty.NettyRemoteTransport" 
    } 
} 
serverconf { 
    include "common" 
    akka { 
    actor { 
     deployment { 
     /root { 
      remote = "akka://serversys@127.0.0.1:2552" 
     }  
     } 
    } 
    remote { 
     netty { 
     hostname = "127.0.0.1" 
     port = 2552 
     } 
    } 
    } 
} 
""").getConfig("serverconf")) 

Testowane Scala 2.9.2 rEPL z Akka 2.0.3, że nadal używać.

rozpakować wartość rzeczywistą korzystając Config docs tutaj: http://typesafehub.github.com/config/v0.3.0/

Answer 3

Zobacz public address of an actorsystem. Przeczytaj całą dyskusję i zauważ, że "normalnie" nie musisz chwytać hosta/portu.

Answer 4

Dla nowszych wersjach Akka (2.1+) użyj:

class RemoteAddressExtensionImpl(system: ExtendedActorSystem) extends Extension { 
    def address = system.provider.getDefaultAddress 
} 

object RemoteAddressExtension extends ExtensionKey[RemoteAddressExtensionImpl] 

val remoteAddr = RemoteAddressExtension(context.system).address 
val remotePath = self.path.toStringWithAddress(remoteAddr)) 

remotePath jest to, czego szukali:

chcę wrócić mi ciąg Akka: //10.4.20.40:2555/slave/user/slaverunner

Więcej nowości Akka wersje (2.5.3) użyj:

class RemoteAddressExtensionImpl(system: ExtendedActorSystem) extends Extension { 
    def address = system.provider.getDefaultAddress 
} 

object RemoteAddressExtension extends ExtensionId[RemoteAddressExtensionImpl] 
with ExtensionIdProvider { 
    override def lookup = RemoteAddressExtension 
    override def createExtension(system: ExtendedActorSystem) = new RemoteAddressExtensionImpl(system) 
    override def get(system: ActorSystem): RemoteAddressExtensionImpl = super.get(system) 
}