問題タブ [akka-remote-actor]

私が抱えている問題は、別のスレーブマシンでシステムを作成できることです。しかし、パーツを別のマシンに配布する方法がわかりません。IE マスター、スレーブ 1、およびスレーブ 2 はすべて、それぞれ IP 101、102、および 103 ではなく、同じマシンで終了します。

マスター サーバーを使用して、基本的に複数のサーバーを介してメッセージのワークフローを管理しています。したがって、マスターが起動すると、次のことを行うマスター サーバー アクターが作成されます。

• 主人：
1. 開始メッセージをスレーブ 1 に送信します
2. スレーブ 1 から成功メッセージを取得し、メッセージをスレーブ 2 に渡します
3. スレーブ 2 から成功メッセージを受け取り、システムをシャットダウンします
• Slave1: サーバーからメッセージを取得し、マスターに成功を返信します
• Slave2: サーバーからメッセージを取得し、マスターに成功を返信します

後で、これらのそれぞれを水平方向にスケーリングしたいのですが、その前に問題が発生しました。すべてのリモート機能は 1 台のマシンでのみ実行されます。

リモートを使用しているため、構成の一部は次のようになります。

アクターシステムとマスター アクターを作成するコード

次に、マスター アクター内で、メッセージを受信したときにこれを実行して、slave1 を使用します。

そのため、システムをすべて 1 台のマシンでホストできます。1 台のマシンで起動して、別のリモート マシンですべて実行することもできます。しかし、構成内の各アクターを異なるマシンで実行することはできません。

私は愚かですが、どのように見ることができません！;)

Akka 2.3.2 には akka-remote-test-experiment がないことに気付きました。この問題を解決する方法について誰かが私に提案できますか:

Play フレームワーク 2.2.2 を使用しており、Akka リモート ライブラリを追加したいと考えています。どのバージョンが互換性がありますか?

Akka リモート 2.3.3 を使用できますか?

====更新

私は akka リモート依存関係を追加しています:

Play フレームワークで akka のバージョンを変更する必要がありますか?

カスタム アクター システムを使用する J2EE アプリがあり、いくつかのカスタム構成を外部化する必要があります。

これを行う方法はありますか？は常にクラスパス上にあるので、application.confとにかくそこにあるので、外部custom.propertiesファイルをロードして以下のように使用できます

akka アプリケーションを実行しようとすると、次のエラーが発生します。

[ERROR] [06/30/2014 15:58:14.591] [Thread-3] [RemoteActorRefProvider] アドレス検索中のエラー [akka://FooPar0@127.0.0.1:2552] akka.remote.RemoteTransportException: トランスポートがありませんロードされたプロトコル: [akka]、利用可能なプロトコル: [akka.tcp] at akka.remote.Remoting$.localAddressForRemote(Remoting.scala:88) ...

私の sbt プロジェクトには、次の build.sbt があります。

名前:=「FooPar」

バージョン:=「0.1」

scalaVersion:= "2.11.1"

リゾルバー += "タイプセーフ リポジトリ" at " http://repo.typesafe.com/typesafe/releases/ "

resolvers += "Sonatype リリース" at " http://oss.sonatype.org/content/repositories/releases "

libraryDependencies += "com.typesafe.akka" %% "akka-actor" % "2.3.4"

libraryDependencies += "com.typesafe.akka" %% "akka-remote" % "2.3.4"

libraryDependencies += "org.scalacheck" %% "scalacheck" % "1.11.4" % "test"

最後に、アプリケーション用に生成された構成文字列は次のようになります。

誰かが問題を見つけるのを手伝ってくれますか? 私はこのガイドに従っていますhttp://doc.akka.io/docs/akka/2.3.4/scala/remoting.htmlですが、私の構成ファイルは本来あるべきものと同じようです

マリオへの応答として：

上記の構成文字列から ActorSystem をインスタンス化し、次のコードを使用します。

つまり、Addressオブジェクトを明示的に作成しません。

最近、プロジェクトにリモート アクター モードを実装しました。アクターを同時に実行している方法を知りたいです。

方法1。

方法 2。

way1 でスレッド名を -akka.actor.default-dispatcher-4 のように出力するのですが、ディスパッチャが 100 にならないのはなぜですか?

どうもありがとう

次の実行ログから、リモートが正常に開始され、2552 のポートでリッスンされていることがわかりました。

しかし、そのポートのtelnetは失敗しました。これは、telnet を使用してリモートを検証できないということですか、それとも
リモート処理に問題があるということですか? 127.0.0.1 を試行しています... telnet: リモート ホストに接続できません: 接続が拒否されました

私はこのアクターを作成します:

さて、小道具 1 を取得したいのですが、できません。手伝って頂けますか？？

私のアプリでは、大量のクライアント (ユーザー マシンにインストールされた Java エージェント) との双方向の継続的な通信が必要です。さらに、これらのエージェントを管理するための標準の jsp UI を提供する spring mvc webapp が含まれています。私は Java akka の基本しか見ていません (このプロジェクトのために scala を学ぶ時間はありません)。しかし、大量のクライアント エージェントを処理するには、良い選択のように思えます。私は akka spring integration module と akka-spring-java の例を見てきましたが、Spring 側で akka を使用するのはかなり簡単に思えます。

クライアントエージェント側でakka remotingを使用することも良い考えかもしれないと思いました。別のアプリに組み込まれる可能性が高いエージェントは、基本的にスレッドを実行し、ユーザーのjvmでさまざまなプロセスを監視し、サーバー上のサービスと通信する必要があります。場所の透過性を使用すると、アーキテクチャが概念的に簡素化され、より効率的になる可能性があります。

この記事は、これが正しいアプローチではない可能性があることを示唆しています

ピアツーピア対クライアントサーバー

リモーティングを使用する代わりに、akka spring 統合モジュールに関連付けられているように見えるキャメル websockets を使用します。

技術スタックを考えると、アプリのコンテキストで取るべき最善の方向性は何ですか?