akka-cluster

0熱

2答えて

最近の調査とStack over flow questionの後、クラスタシャーディングはクラスタ整合型ハッシュルータよりも優れた選択肢です。しかし、私は、2つのプロセスクラスタを稼働させることに問題があります。 1つのプロセスはシードで、もう1つはクライアントです。 Seedノードは、デッド・レター・メッセージを連続的に投射しているようです（この質問の最後を参照）。この種HOCONは次のとおり

0熱

1答えて

DockerのElkaBeanstalkのAkkaクラスター

私はElockBeanstalkのdockerでAkkaクラスターを設定しようとしています。ノードは、そのように相互に通信する必要があります。 +-------------------------------------------------------+ | ElasticBeanstalk/ECS | | | | +--------------

0熱

1答えて

アッカデザイン：追加する方法/クラスタ対応ルータからrouteeを削除する動的

I次のユースケースを持っており、アッカのツールキットは、箱から出して、これを提供する場合、私はわからない：私は数を持っていますバックグラウンドで有限の長時間実行されるタスクを実行できるノード（インスタンス/マシン）であり、最大容量でより多くの作業を受け入れることはできません。各インスタンスは、50個のタスクしか処理できません。すべてのインスタンスがロードバランサの背後にあります。クライアン

0熱

2答えて

SBTがAkkaと依存関係を解決していません

私はScala、Akka、SBTの新機能ですから、この問題が頭痛になります！私はこの本の著者は、GitHubの上の例を提供してアクションでアッカ、で働いている：リポジトリのクリーンなクローンで https://github.com/RayRoestenburg/akka-in-action 、私は章クラスタに例を見てしようとしていました。ブックに記載されているように、最初に行うべきことはしてロー

0熱

2答えて

キー 'akka.remote.artery'の設定が見つかりません

nettyを使用してClusterActorRefProviderを使用して簡単なakkaクラスタを作成しています。アイデアからコードを実行すると、すべてうまく動作しています。しかし、アプリケーションをjarファイルとして実行すると、突然すべてが失敗します。「キー 'akka.remote.artery'の設定が見つかりません」というエラーが表示されます。私はsbtアセンブリを使用してjarファ

0熱

1答えて

Akka Messagingを追跡する方法

マスタワーカーパターンのAkkaクラスタを使用して、ジョブをワーカーノードに配布しています。 KafkaとJMSメッセージには、キュー内のメッセージを参照するためのAPIがあります。すべての送信者と受信者の間でAkkaシステムのメッセージを追跡するベストプラクティスは何か分かりますか？それを行うAkka上に構築されたフレームワークはありますか？それが機能するためには akka { log

1熱

1答えて

SBT：sbt.InvalidComponent：必要なコンポーネントが見つかりませんでした： 'compiler-interface-src'

クラスタ内でAkkaアプリケーションを実行しようとしています。実際には私はLinuxマシンが必要です。両方とも、同じJava、同じカーネルバージョンであっても、sbt 0.13.13とscala 2.10.4で同じ設定をしています。アプリケーションをテストするために、私は両方のマシンでプロジェクトの正確なコピーを持っています。最初のマシンでコンパイルすると、すべて正常に動作します。しかし、すぐに

0熱

1答えて

Akka.NET - AtLeastOnceDeliveryReceiveActorとPublish/Subscribeパターンを混在させることは可能ですか？

私はそれが原因というAtLeastOnceDeliveryReceiveActor実際に作業することはできませんAtLeastOnceDeliveryReceiveActor加入者がです（http://getakka.net/articles/clustering/distributed-publish-subscribe.html）パブリッシュ/サブスクライブ・パターンを実装することが可能ですか

0熱

1答えて

シンプルなシングルトンクラスタを作成し、リモートノードからメッセージを送信したい

ここではシングルトンアクタを作成しました。マスターノードとシードノードは同じです。私はクラスタに追加しようとしている別のプロジェクトから、メッセージを送信したい。クラスタに参加することはできますが、メッセージを送信することはできません。私のマスターとシードノード： package Demo import akka.actor._ import akka.cluster.si

0熱

1答えて

Akka ShardRegion.StartEntityメッセージはエンティティアクタに伝播されますか？

私はScala 2.12.2でAkka 2.5.2を使用しています。 sharding docには、クラッシュ/リバランスされた断片をエンティティを回復するために、がShardRegion.StartEntityメッセージを処理する必要があることが記載されています。エンティティ自体が内部状態を回復する必要がある場合は、PersistenceActorを実装する必要があります。これを機能させるには