2

私は akka noob です: akka-sample-cluster-scala transformatino の例を取り、それを壊して 2 台のマシンで実行しようとしています。

設定だけでこれを行うことができると思います。それは私が非常に素朴であると思われます。

また、ネットワークが正しく設定されている vm でこれらを実行しているため、IP 範囲が奇妙です。ドメインがあるので、NAT とホスト オンリー ネットワークの両方を使用しています。これは問題になる可能性がありますが、これが問題になることはないと確信しています。

また、netstat から、これがポートを持っている他の何かによるものではないこともわかっています。nmap -p 2550 192.168.56.101 は、バックエンドの実行中にポートが開いていると言います

ただし、フロントエンドが2551でホストに接続しようとしている理由がわかりません（そして、2550を渡すと、同じ例外で失敗します（以下））

だから私は akka-sample-cluster-scala/src/main/resources/application.conf を取り、これに変更しました

akka {
  actor {
    provider = "akka.cluster.ClusterActorRefProvider"
  }
  remote {
    log-remote-lifecycle-events = off
    netty.tcp {
      hostname = "192.168.56.101"
      port = 2550
    }
  }

  cluster {
    seed-nodes = [
      "akka.tcp://ClusterSystem@192.168.56.102:2551",
      "akka.tcp://ClusterSystem@192.168.56.102:2552"]

    auto-down-unreachable-after = 10s
  }
}

「スレーブ」で（それらは同じです）

akka {
  actor {
    provider = "akka.cluster.ClusterActorRefProvider"
  }
  remote {
    log-remote-lifecycle-events = off
    netty.tcp {
      hostname = "192.168.56.101"
      port = 2550
    }
  }

  cluster {
    seed-nodes = [
      "akka.tcp://ClusterSystem@192.168.56.102:2551",
      "akka.tcp://ClusterSystem@127.168.56.102:2552"]

    auto-down-unreachable-after = 10s
  }
}

次に、バックエンドを実行したい場所でこれを行っています

/activator "runMain sample.cluster.transfortion.TransformationBackend 2550"

そして反対側に

./activator "runMain sample.cluster.transformation.TransformationFrontend 2551"

私は完全に混乱していると思いますが、これを読んでいる人にとってはナンセンスです。教えていただけると助かります。

エラーは、1 台のマシンでバックエンドが起動しているように見え、そこに座って待機していることです。

クライアント側で次の例外が発生しています

[info] [INFO] [04/24/2014 15:06:23.989] [main] [Remoting] Starting remoting
[error] Exception in thread "main" org.jboss.netty.channel.ChannelException: Failed to bind to: /192.168.56.101:2551
[error]     at org.jboss.netty.bootstrap.ServerBootstrap.bind(ServerBootstrap.java:272)
[error]     at akka.remote.transport.netty.NettyTransport$$anonfun$listen$1.apply(NettyTransport.scala:392)
[error]     at akka.remote.transport.netty.NettyTransport$$anonfun$listen$1.apply(NettyTransport.scala:389)
[error]     at scala.util.Success$$anonfun$map$1.apply(Try.scala:206)
[error]     at scala.util.Try$.apply(Try.scala:161)
[error]     at scala.util.Success.map(Try.scala:206)
[error]     at scala.concurrent.Future$$anonfun$map$1.apply(Future.scala:235)
[error]     at scala.concurrent.Future$$anonfun$map$1.apply(Future.scala:235)
[error]     at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:32)
[error]     at akka.dispatch.BatchingExecutor$Batch$$anonfun$run$1.processBatch$1(BatchingExecutor.scala:67)
[error]     at akka.dispatch.BatchingExecutor$Batch$$anonfun$run$1.apply$mcV$sp(BatchingExecutor.scala:82)
[error]     at akka.dispatch.BatchingExecutor$Batch$$anonfun$run$1.apply(BatchingExecutor.scala:59)
[error]     at akka.dispatch.BatchingExecutor$Batch$$anonfun$run$1.apply(BatchingExecutor.scala:59)
[error]     at scala.concurrent.BlockContext$.withBlockContext(BlockContext.scala:72)
[error]     at akka.dispatch.BatchingExecutor$Batch.run(BatchingExecutor.scala:58)
[error]     at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:41)
[error]     at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:393)
[error]     at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
[error]     at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
[info] [INFO] [04/24/2014 15:06:24.140] [ClusterSystem-akka.remote.default-remote-dispatcher-15] [akka://ClusterSystem/system/remoting-terminator] Shutting down remote daemon.
[error]     at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
[error]     at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
[error] Caused by: java.net.BindException: Cannot assign requested address
[error]     at sun.nio.ch.Net.bind0(Native Method)
[error]     at sun.nio.ch.Net.bind(Net.java:444)
[error]     at sun.nio.ch.Net.bind(Net.java:436)
[error]     at sun.nio.ch.ServerSocketChannelImpl.bind(ServerSocketChannelImpl.java:214)
[error]     at sun.nio.ch.ServerSocketAdaptor.bind(ServerSocketAdaptor.java:74)
[error]     at org.jboss.netty.channel.socket.nio.NioServerBoss$RegisterTask.run(NioServerBoss.java:193)
[error]     at org.jboss.netty.channel.socket.nio.AbstractNioSelector.processTaskQueue(AbstractNioSelector.java:372)
[error]     at org.jboss.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:296)
[error]     at org.jboss.netty.channel.socket.nio.NioServerBoss.run(NioServerBoss.java:42)
[error]     at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
[error]     at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
[info] [INFO] [04/24/2014 15:06:24.146] [ClusterSystem-akka.remote.default-remote-dispatcher-15] [akka://ClusterSystem/system/remoting-terminator] Remote daemon shut down; proceeding with flushing remote transports.
[error]     at java.lang.Thread.run(Thread.java:744)
4

1 に答える 1

1

フロントエンド コード

object TransformationFrontend {
  def main(args: Array[String]): Unit = {
    // Override the configuration of the port when specified as program argument
    val port = if (args.isEmpty) "0" else args(0)
    val config = ConfigFactory.load()

    val system = ActorSystem("ClusterSystem", config)
    val frontend = system.actorOf(Props[TransformationFrontend], name = "frontend")

    val counter = new AtomicInteger
    import system.dispatcher
    system.scheduler.schedule(2.seconds, 2.seconds) {
      implicit val timeout = Timeout(5 seconds)
      (frontend ? TransformationJob("hello-" + counter.incrementAndGet())) onSuccess {
        case result => println(result)
      }
    }

  }
}

バックエンド コード:

object TransformationBackend {
  def main(args: Array[String]): Unit = {
    // Override the configuration of the port when specified as program argument
    val port = if (args.isEmpty) "0" else args(0)
    val config = ConfigFactory.load()

    val system = ActorSystem("ClusterSystem", config)
    system.actorOf(Props[TransformationBackend], name = "backend")
  }
}

フロントエンド構成:

akka {
  actor {
    provider = "akka.cluster.ClusterActorRefProvider"
  }
  remote {
    log-remote-lifecycle-events = off
    netty.tcp {
      hostname = "192.168.56.102"
      port = 2551
    }
  }

  cluster {
    roles = [frontend]
    seed-nodes = [
      "akka.tcp://ClusterSystem@192.168.56.102:2551"]

    auto-down-unreachable-after = 10s
  }
}

バックエンド構成:

akka {
  actor {
    provider = "akka.cluster.ClusterActorRefProvider"
  }
  remote {
    log-remote-lifecycle-events = off
    netty.tcp {
      hostname = "192.168.56.101"
      port = 2550
    }
  }

  cluster {
    roles = [backend]
    seed-nodes = [
      "akka.tcp://ClusterSystem@192.168.56.102:2551"]

    auto-down-unreachable-after = 10s
  }
}

ポートを指定するこれらの変更が実行するステートメントから省略された後にも追加する必要があります

于 2014-04-24T15:50:25.517 に答える