2

AKKAリモートの例を実行しようとしています

1. Running the remote actor in a machine with IP 192.168.1.7
2. Running the local from my machine

リモート アクターがマシンで起動されます (IP アドレス 192.168.1.7)。しかし、自分のマシンからローカル アクターを起動すると、リモート アクターに接続できません。ローカルおよびリモート アクターのシステム構成を見つけてください。

ローカル：

akka {
  //loglevel = "INFO"
  actor {
    provider = "akka.remote.RemoteActorRefProvider"
  }
  remote {
    enabled-transports = ["akka.remote.netty.tcp"]
    netty.tcp {
      hostname = "127.0.0.1"
      port = 0
    }
    //log-sent-messages = on
    //log-received-messages = on
  }
}

リモート:

akka {
  //loglevel = "INFO"
  actor {
    provider = "akka.remote.RemoteActorRefProvider"
  }
  remote {
    enabled-transports = ["akka.remote.netty.tcp"]
    netty.tcp {
      hostname = "127.0.0.1"
      port = 5150
    }
    //log-sent-messages = on
    //log-received-messages = on
  }
}

リモート アクターに接続するローカル システムのコード:

class LocalActor extends Actor {
  val remote = context.actorFor("akka.tcp://HelloRemoteSystem@192.168.1.7:5150/user/RemoteActor")
  var counter = 0
  def receive = {
    case "START" => 
        remote ! "Hello from the LocalActor"
    case msg: String => 
        println(s"LocalActor received message: '$msg'")
        if (counter < 5) {
            sender ! "Hello back to you"
            counter += 1
        }
  }
}

ローカル システムを起動すると、次のメッセージが表示されます。

C:\Users\AnandKrishnan\Documents\GitHub\AkkaRemoteActorsHelloWorld\HelloLocal [master +0 ~5 -0]> sbt run
Java HotSpot(TM) 64-Bit Server VM warning: ignoring option MaxPermSize=256m; support was removed in 8.0
[info] Set current project to HelloLocal (in build file:/C:/Users/AnandKrishnan/Documents/GitHub/AkkaRemoteActorsHelloWorld/HelloLocal/)
[info] Compiling 1 Scala source to C:\Users\AnandKrishnan\Documents\GitHub\AkkaRemoteActorsHelloWorld\HelloLocal\target\scala-2.11\classes...
[warn] there was one deprecation warning; re-run with -deprecation for details
[warn] one warning found
[info] Running local.Local
[INFO] [02/14/2016 22:57:11.755] [run-main-0] [Remoting] Starting remoting
[INFO] [02/14/2016 22:57:12.163] [run-main-0] [Remoting] Remoting started; listening on addresses :[akka.tcp://LocalSystem@127.0.0.1:50830]
[INFO] [02/14/2016 22:57:12.163] [run-main-0] [Remoting] Remoting now listens on addresses: [akka.tcp://LocalSystem@127.0.0.1:50830]
[WARN] [02/14/2016 22:57:13.351] [LocalSystem-akka.remote.default-remote-dispatcher-5] [akka.tcp://LocalSystem@127.0.0.1:50830/system/endpointManager/reliableEndpointWriter-akka.tcp
%3A%2F%2FHelloRemoteSystem%40192.168.1.7%3A5150-0/endpointWriter] AssociationError [akka.tcp://LocalSystem@127.0.0.1:50830] -> [akka.tcp://HelloRemoteSystem@192.168.1.7:5150]: Error
 [Invalid address: akka.tcp://HelloRemoteSystem@192.168.1.7:5150] [
akka.remote.InvalidAssociation: Invalid address: akka.tcp://HelloRemoteSystem@192.168.1.7:5150
Caused by: akka.remote.transport.Transport$InvalidAssociationException: Connection refused: no further information: /192.168.1.7:5150
]
[WARN] [02/14/2016 22:57:13.371] [LocalSystem-akka.remote.default-remote-dispatcher-6] [Remoting] Tried to associate with unreachable remote address [akka.tcp://HelloRemoteSystem@192.168.1.7:5150]. Address is now gated for 5000 ms, all messages to this address will be delivered to dead letters. Reason: Connection refused: no further information: /192.168.1.7:5150
[INFO] [02/14/2016 22:57:13.389] [LocalSystem-akka.actor.default-dispatcher-3] [akka://LocalSystem/deadLetters] Message [java.lang.String] from Actor[akka://LocalSystem/user/LocalActor#1441959988] to Actor[akka://LocalSystem/deadLetters] was not delivered. [1] dead letters encountered. This logging can be turned off or adjusted with configuration settings 'akka.log-dead-letters' and 'akka.log-dead-letters-during-shutdown'.
4

2 に答える 2

0

Akka アクター システムが他のホストと通信するには、アクター システムは、問題の他のホストによってルーティング可能なホスト名または IP にバインドする必要があります。 localhostもちろん、そうではありません。

リモート システムは 192.168.1.7 にバインドする必要があります。

akka {
  remote {
    netty.tcp {
      hostname = "192.168.1.7"
    }
  }
}

もちろん、本番環境では、IP ではなくホスト名を使用することをお勧めします。

于 2016-02-14T20:00:25.227 に答える