問題タブ [akka-remote-actor]

次のシナリオがあります。

• Akka リモートシステム A
• アッカリモートシステムB

B は分析エンジンで、A に一連のファイア アンド フォーゲット メッセージを送信します。システム B は分析後に停止します。

しかし、B が分析後に呼び出した場合system.shutdown、すべてのメッセージが A に配信されるわけではありません。B のアクター システムはメッセージをバッファリングしていますか?

B さんのすべてのメッセージが A さんの受信トレイにあることを確認するにはどうすればよいですか? B が切断しても安全な時期を判断できますか? B を A から適切に切断するにはどうすればよいですか?

アドバイスありがとうございます！

クライアントとサーバーの通信に Akka を使用することを考えており、データ転送のベンチマークを試みています。現在、各メッセージが 8 つの文字列フィールドを持つケース クラスである 100 万のメッセージを送信しようとしています。

現時点では、許容できるパフォーマンスを得るのに苦労しています。クライアントとサーバーで約 600KB/s の転送速度とアイドル状態の CPU が見られるため、何か問題が発生しています。多分それは私たちのネット設定です。

これは私たちの akka 設定です

アップデート：

最後に、シリアライゼーションに関する議論 (以下を参照) にもかかわらず、ペイロードを変換してバイト配列を使用するようにしました。これにより、シリアライゼーションはテストに影響しません。jeroMQ を使用した 24 GB RAM のコア i7 (つまり、Java で再実装された zeroMQ - まだ最速ではない) で、生の akka (つまり、zeroMQ プラグインなし) で約 200k メッセージ/秒または約 20 MB/秒が一貫して見られることがわかりました。約 10k メッセージ/秒、つまり 1MB/秒弱でした。akka + zeroMQ を試してみると、パフォーマンスが悪化しました。

Spark で最初のステップを実行すると、アプリケーション コードからクラスターにジョブを送信する際に問題が発生します。ログを掘り下げると、マスター ログにいくつかの定期的な WARN メッセージがあることに気付きました。

問題は、IP アドレスがネットワーク上に存在せず、どこにも構成されていないことです。タスクを実行しようとすると、ワーカー ログに同じ間違った IP が表示されます (間違った IP が --driver-url に渡されます)。

私が何を間違えたのか、どうすれば修正できますか？

Java のバージョンは 1.8.0_20 で、ビルド済みの Spark バイナリを使用しています。

ありがとう！

こんにちは、AskTimeOutException をラップして適切なメッセージを送信したいと思います ....

適切な処理方法を教えてください..

spark が sbt でテストを実行しているとき。私はこの例外を受け取ります:

私が最初に考えたのは、私のサブライブラリの1つによってインポートされた netty のバージョンが間違っていることです。

依存関係グラフを調べたところ、netty の 4 つの異なるバージョンが見つかりました。 3.6.6 3.8.0 3.9.3 4.0.23

これらのバージョンは、主に spark 自身によってインポートされます :o4.0.23は spark によって直接インポートされ、 は3.8.0そのサブ依存関係によってインポートされますAkka-remote

すべてのサブ依存関係から netty 依存関係を除外し、excludeAll( ExclusionRule(organization = "io.netty"))各 netty バージョンを 1 つずつ追加しようとしました。しかし、それは問題を解決しませんでした。com.typesafe.akkaまた、使用するすべての依存関係を除外しようとしましAkka-remote 2.4.0たが、同じ問題が発生しました。

が必要とする netty バージョンAkka-remoteは3.8.0. そして、これを強制しても機能しません。Akka-remote:3.8.0-sparkまた、プロジェクトで、何も変更しない空間スパーク Akka バージョンを使用するように強制しました。

情報のために私のbuild.sbt

ご覧のとおり、試行から最大のものを除外しようとしています

サブプロジェクトの小屋には含まれています

リモート アクターにセキュリティを追加しようとしています。untrusted-mode を設定しました: http://doc.akka.io/docs/akka/snapshot/scala/remoting.html

IP フィルタリングを追加して、特定のサーバーからの接続のみを許可することはできますか? たとえば、1 つのマスターと 10 のスレーブがあり、マスター (特定の IP) のみがスレーブに接続できるようにしたいと考えています。

オープンソースでは、誰もがマスターの新しいインスタンスを作成し、実際のスレーブに接続できました。どうすれば安全にできますか？

私のプロジェクトには 2 つの部分が含まれています。1 つは akka server で、もう 1 つは play フレームワークです。どちらも時々再起動できます。akkaサーバーからログを受信するために、Websocketハンドラーを使用しています

一部のリモート アクターの変更をサブスクライブするアクターと。

リモート ロガー アクターは、subscribe() unsubscribe() イベントに反応し、サブスクライブしたクライアントにログ メッセージを送信します。リモートサーバーがハングアップしないか、再起動するまでは正常に動作します。リモート akka サーバーが接続を切断したことを検出する最も安価な方法は何ですか (その後、新しく開始したロガーに再度サブスクリプションを作成できます)。ピンガーアクターを構築できます。タイムアウトを受け取った場合は、再サブスクリプションを再度試みますが、単純なpingでは、それらの間で再起動が発生したことを保証できず、システムがより複雑になります。他の解決策が存在する可能性があります。

同じホスト上に複数のアクター システムをセットアップしたいと考えています。将来的には、一部のアクター システムが別のホストに移動される可能性があります。アクター システム内のアクターは、相互に通信します。

私の考えでは、すべてのアクター システム (同じホスト上) が、システム プロパティ config.resource として定義できる 1 つの構成ファイルを共有するので、異なる構成ファイルで混乱することはありません。

しかし、構成ファイルがどのように見えるのが最適かはわかりません。アクター パス ("akka.tcp://actorSystemName@10.0.0.1:2552/user/actorName" など) を定義できますが、これはアクターの作成には役立ちません。リモート アクターとしてアクセスする場合にのみ役立ちます。作成用に別の変数actorNameを定義できます。しかし、1 つのactorName に対して 2 つの変数があります。

最善の方法は、各システムのactorSystemName、ホスト、ポート、および各アクターのactorNamesを定義し、これらすべての変数からパスを作成することです。しかし、このアプローチでは、childactors にアクセスすることはできないと思います。

アクター システムをどのように構成しますか? 1 つまたは複数の構成を使用しますか?

ネットで検索することで、私は一方通行を行うことができますが、受信者がコンソールに何かを入力すると、次のようなエラーが表示され、分散 akka システムが Java でどのように機能するかを知りたいので、[ https ://github.com/petabridge/akkadotnet-code-samples] しかし、それは .net にありました。

Java ベースのディストリビュート akka システムの作成を手伝ってください。