2

我正在尝试通过以下方式运行 AKKA 远程示例

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

远程actor在机器中启动（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

1

在 Remote Actor 类中，您有：

val system = ActorSystem("HelloRemoteSystem", config)

确保在使用actorSelection/时在本地演员中actorFor使用相同的名称，例如：

val remoteActor = context.actorSelection("akka.tcp://HelloRemoteSystem@127.0.0.1:2553/user/RemoteActor")
于 2016-05-17T11:36:38.167 回答
0

为了让 Akka actor 系统与其他主机通信，actor 系统必须绑定到一个主机名或 IP，该主机名或 IP 可由相关的其他主机路由。 localhost，当然不是。

您的远程系统需要绑定到 192.168.1.7：

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

当然，在生产环境中，您可能希望使用主机名而不是 IP。

于 2016-02-14T20:00:25.227 回答