akka-cluster

4熱

1答えて

Akkaクラスター内のすべてのノードで、指定されたアクターに存在するランタイムデータがあります。これは、内部イベントまたはAPI呼び出しを介して単一のノードに更新される可能性があります。このデータを共有データベースに保存して永続化することはできましたが、永続化する必要がないため、高速化のためにメモリに格納するだけです。 Akka Cluster Singleton、Distributed Pub

0熱

1答えて

アクターが失敗した場合、リモートアクターに添付されたメールボックスはどうなるでしょうか？

リモートアクターが死んでも、親アクターは通知を受けますが、リモートアクターに接続されたメールボックスはどうなりますか？それを取得する方法がない場合、akaはフォールトトレラントであるとはどういうことができますか？

1熱

1答えて

Akka：単純なローカルクラスタを起動するには？

akka { actor { provider = "akka.cluster.ClusterActorRefProvider" } remote { enabled-transports = ["akka.remote.netty.tcp"] netty.tcp { hostname = "127.0.0.1"

0熱

1答えて

新しいノードをakkaに参加させると、リモートアクターはどのように作成されますか？私アッカクラスタのセットアップを説明する

は：私は、マルチノードAkkaのクラスタ内のリモート俳優を持っています。シングルトンタイプのルータの背後にあるアクター。シングルトンルーターはクラスタシングルトンプロキシの後ろにあります。また、サイドノートには、N種類のアクターがあり、それぞれ異なる種類のタスクを実行し、異なるルーターによって管理されます。コードスニペット（Java）の Config config = ConfigFac

3熱

1答えて

akka.netラウンドロビングループルータ - 1つのルートへのルーティングのみ

クラスタルータに関する質問（戦略=ラウンドロビングループ）。クラスタ化された設定で私のルート間でラウンドロビンすることはできません。設定は次のとおりです。ノードA：ASP.NETのコンテキストでアクタシステムを開始します。そこに私は俳優A1に話すAPIコントローラを持って、この俳優は私のルータに話します。このルータは、メッセージをノードBで作成されたルートにラウンドロビンする必要があります（ワ

1熱

1答えて

ファンアウト機能を備えたリアクティブストリームアクターシステムの設計方法

背圧機能を備えたアクターベースのシステムを実装しようとしています。要件として、マスタープロセスはJSON形式のストリーミングデータを受け取ります。ただし、各JSONイベントには、{ip： '123.43.12.1'、国： 'US'、...など}のようなフィールドがあります。 JSONの構造はあらかじめわかっています。ここで、JSON構造を何らかの形で（キー、値）のペアに平坦化する必要があります。

0熱

1答えて

Akkaクラスタ "接続が拒否されました"混乱

私は、akka-sample-cluster-appチュートリアルとdocumentationでAkkaクラスタを勉強しています。ローカル（127.0.0.1）で動作していますが、静的IP（192.168.0.99）を使用して動作させることはできません。ラズベリーパイをノードとして使用しようとしているときに同様のメッセージが表示されているので、私は迅速な健全性チェックとしてこれをやっています。 [

1熱

2答えて

私はこのような何かやりたい

俳優の内側に未来から「送信者」に戻って - class MyActor extends Actor { .... override def receive = { case msg => .... // do something Future { ... // calculate response sender ! response

0熱

1答えて

分散メールメールボックスのAkkaアクターシステムデザイン

Akkaに基づいて分散メールメールボックスシステムを作成したいと思います。私のアプリが起動すると、すべての受信トレイのアクタを作成し、10秒間隔でメールを受信するスケジューラを起動したいと考えています。これらの受信ボックスアクターを作成する方法に問題がありますか？クラスター上にアクターを作成することも、存在する場合はそれを参照することもできますか？アクター名は、データベース内のメールボックスUU