0

私はhttp://www.typesafe.com/activator/template/akka-sample-remote-scalaakka-remoteを学び、やり直そうとしています。

プロジェクトを 2 つの別個の JVM で実行しようとすると、 

$ clear;java -jar akkaio-remote/target/akka-remote-jar-with-dependencies.jar com.harit.akkaio.remote.RemoteApp ProcessingActor

ProcessingActorSystem Started

と 

$ clear;java -jar akkaio-remote/target/akka-remote-jar-with-dependencies.jar com.harit.akkaio.remote.RemoteApp WatchingActor

WatchingActorSystem Started
asking processor to process
processing big things

Processing Systemポートで実行するように依頼しました2552 

include "common"
akka {
  # LISTEN on tcp port 2552
  remote.netty.tcp.port = 2552
}

そして、他のシステム ( WatchingSystem) に、ポートで実行するが、ポートで2554開始するように指示しましたprocessingActor2552 

include "common"

akka {
  actor {
    deployment {
      "/processingActor/*" {
        remote = "akka.tcp://ProcessingActorSystem@127.0.0.1:2552"
      }
    }
  }
  remote.netty.tcp.port = 2554
}

common適切なプロバイダを使用することについて です

akka {
  actor {
    provider = "akka.remote.RemoteActorRefProvider"
  }

  remote {
    netty.tcp {
      hostname = "127.0.0.1"
    }
  }
}

質問/懸念事項

  1. ログから、 が on ではなく onでprocessingActor実行されていることがわかります。何が問題なのですか? WatchingActorSystemProcessingActorSystem
  2. 2 つの ActorSystem が相互に接続していることを確認するにはどうすればよいですか? ログが記録されていません。ただし、例では、ログが発生することを共有しました。私は何が欠けていますか？

コード全体がGithubに投稿され、同様に実行されます

4

1 に答える 1

0

1) akka 構成ドキュメントで説明されているように、デプロイ構成は、processingActor のすべての子がリモートになるように設定されています。

代わりにこれを設定する必要があります。

deployment {
  "/processingActor" {
    remote = "akka.tcp://ProcessingActorSystem@127.0.0.1:2552"
  }

2) akka logging documentationで説明されているように、ログレベルを便利なものに設定する必要があります

于 2015-06-24T07:12:42.533 に答える