akka-cluster

2熱

2答えて

クラスタ内でAkkaスケジューラの1つのインスタンスを実行したいとします。現在のところ私のスケジューラはローカルで正常に動作していますが、予想どおりではありません。スケジューラはDBから注文を取り出し、カフカのトピックにプッシュします。私はakka 2.5.6（Java）を使用しています。私はofficial Docを通過しましたが、それほど助けはありませんでした。ご協力いただければ幸いです。

3熱

1答えて

Akka Distributed Pub/Subバックプレッシャー

私はAkka Distributed Pub/Subを使用しており、出版社とサブスクライバは1つです。私の出版社は加入者よりもずっと高速です。ある時点後に出版社を遅らせる方法はありますか？出版社コード： public class Publisher extends AbstractActor { private ActorRef mediator; static publi

0熱

1答えて

akka-cluster：ジョブを実行しているリモートアクタ

akka-clusterでわかっているように、フロントエンドノードは要求を受け取り、それを実行するバックエンドノードの1つにジョブを送ります。私はどのバックエンドノードがジョブを実行しているかを知る方法をデバッグ目的で知りたいのですか？ akkaには、バックエンドで実行中のジョブの実行状況を確認できるUIもありますか？

0熱

1答えて

Akkaクラスターノードのバージョン互換性

akkaクラスターの互換性の間に何がありますか？など。異なったアクターを使ってクラスターの異なるノードを始めることは安全ですか？

0熱

1答えて

akkaシャードされたアクターの状態を外部化または発火させる方法を教えてください。

私はAkkaクラスタリングと概念実証に取り組んでいて非常に新しいです。私の場合、私はクラスター上で実行されている俳優を持っており、俳優はMap [String、Any]のような状態を持っています。そのため、任意の要求に対して、アクターは受信メッセージに基づいてそれを受け取り、新しいエンティティアクターとデータマップを作成します。ここで問題となっているのは、マップが現在メモリに入っていることです。赤

0熱

1答えて

Akka Clusterメンバーをスーパーバイザから正常に停止する方法

私は、スーパーバイザ（http://supervisord.org/）によって制御されるものをAkkaクラスタ（バージョン2.5.0）で実行します。私の問題は、supervisorctl stop my-serviceでakkaノードを停止すると、akkaノードは停止しますが、akkaクラスタから自分自身を登録解除するのに十分な時間がなく、さらに他のノードは（つまり）シングルトンアクターを制御でき

1熱

1答えて

Akkaクラスタシャーディング：通信パターンに基づいて移動するアクターシャード

私は、Akka（特にリモートおよびクラスターパッケージ）を使用してオープンソース分散経済シミュレーションプラットフォームを構築しています。このようなシミュレーションの主要なボトルネックは、アクター間のコミュニケーションパターンがシミュレーションの過程で進化し、アクターが多くのメッセージをクラスター内のノード間でワイヤーを介して送信することです。他のノードのアクターと大きく通信しているノード上のア

0熱

1答えて

シードノードの再起動後にクラスタノードを再結合する

このようなシナリオを想像してみましょう。私はakkaクラスター内に3つのノードを持っています（ノードA、B、C）。各ノードは、ネットワーク内の別の物理デバイスに配置されます。これらのノードはすべて、Topshelfウィンドウサービス内にラップされています。ノードAは自分のシードノードであり、他のノードはポートが指定された単純な「ワーカー」ノードです。クラスタを実行してノード（サービス）Bまた