問題タブ [akka-cluster]

私は 3 つのアクターの階層を持っています: SM -> R -> W SM - サービス マネージャー R - ルーター W - ワーカー

SM は、リモート ノードに展開されるアクター W を作成した R アクターを作成します。

外部サービスから情報を収集するため、Actor W の作成には時間がかかるため、数秒の遅延は正常です。したがって、preStart()W から SM に、init が完了し、完全に機能するというメッセージを送信したいと考えています。

この方法で W から SM アクターに到達しようとしました。

これらのメッセージはすべて、deadLetter の受信トレイに送られます。間違っている場合は訂正してください。ただし、ローカリゼーションは透過的であるべきではありませんか? SM男優への正しい連絡方法は？

ここで役立つ場合は、dead-letter-log です

正確な node を指定すると、プログラムでリモート ノードにアクターを作成できます。

しかし、単純にアクター システムにランダムなノード、またはおそらく最も使用率の低いノードにアクターを作成するように依頼したいと思います。

オプションのノード ロールを指定して、任意のリモート ノードにアクターを作成することは可能ですか?

測定を開始した時点を超えてメンバーシップが変更されないと仮定して、Akka クラスター全体でクラスター メンバーシップの状態が一貫していない最大時間をどのように判断できますか?

これはいくつかの要因に依存することを認識しているため、必要なすべての変数を考慮して最悪のケースを計算する方法を探しています。

私は 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 を取り、これに変更しました

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

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

そして反対側に

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

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

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

タスクを並列化する場合、私は通常 Spark を使用します。http://blog.knoldus.com/2011/09/19/power-of-parallel-processing-in-akka/などの Akka での並列処理に関する記事を読むと、Akka を使用して並列化することは、より低いレベルにあるようです。Spark は、map reduce などの下位レベルの概念の一部をユーザーから抽象化しているようです。Spark は、データのグループ化とフィルタリングのための高レベルの抽象化を提供します。Akka はタスクの並列化に関して Spark の競合相手ですか、それとも別の問題を解決していますか?

どちらを使用するかを決定する前に、どのような考慮事項を作成する必要がありますか?

Akka のランディング ページで提供されている Akka リモーティングの入門的な例は、入門として理解するのが少し難しいと思います。また、リモーティングの内外を学習するために必要なドキュメントの長さは、入門用としては不適切な構造になっています。

以下は、前述の例のコードです。アクターがローカルであるかのようにリモートでメッセージを送信できるかどうかという問題に関連して、公平なコンテキストでそのコードが何を意味するかを説明してください。単なる構成の変更。この最後のビットに関する以前の回答は、現在の Akka のドキュメントと多少矛盾しているように見えるかもしれませんが、ドキュメント自体は、まさにこの点についてやや決定的ではありません。

したがって、上記の重要な側面も処理するこのサンプル コードの紹介的な説明は非常に役立ちます。何日も実験モードに入るのではなく、単一の JVM 内および JVM とサーバーの境界を越えて簡単にスケーリングできるアクター アーキテクチャを選択できるようになることを願っています。

ありがとう！

私はAkkaのソースコードを見ていました。メンバーの役割を取得する方法 ( .getRoles) はありますが、既存のメンバーに新しい役割を追加する方法はありますか? 構成ではなく、コードを使用して動的に追加したいと思います。

私は分散ワーカー パターンで遊んでいて、Web リクエストから作業をプッシュする問題に遭遇しています。

サンプル プロジェクトにはフロントエンドがあります。

そして WorkProducer:

Play Framework コントローラーからフロントエンドに直接送信すると、これはすべて正常に機能します。

メッセージは失われているようです。フロントエンドはメッセージを受け取りますが、下流のアクターは受け取っていないようです。

ClusterActorRefProvider を使用するように play 構成を変更しました

しかし、役に立たない。