akka-remoting

1熱

2答えて

アクターシステムの作成時にAkkaがどのような責任を負うのか混乱します。私は、各子が異なるプロセス（したがって異なるノード）に存在する親と2人の子アクターの単純なアプリケーションを作成したいと考えています。リモートの設定でルータを使用することも、リモートアクタを起動することもできますが、このリモートアクタを作成する際に私が間違っていると私を修正することができます。Akkaは、プロセスが既に存在

0熱

1答えて

リモートアクタをプログラムで作成すると動作しない

私はリモートのアクタアクタをプログラムで作成しています。以下はプログラムである - package remoting.programatic.demo import akka.actor.{ActorSystem, Props} import com.typesafe.config.ConfigFactory import remoting.config.demo.RemoteActor

1熱

1答えて

Akka.NETリモーティングの構成設定

私はAkka.NET githubの例を使って基本的なリモーティングを再生しています。 GitHubから入手可能なリモーティングの例では、Akka.NETの構成文字列に次のセクションがあります。 deployment { /localactor { router = round-robin-pool nr-of-instances = 5 }

1熱

1答えて

リモートアドレスに接続するためのAkka.NETの取得

Akka.NETでリモート処理を開始する方法を示すデモは、2つのアクターがlocalhostを使用して同じマシンで実行されている最も単純な使用例です。私はリモートマシンに接続するためにAkka.NETアクタを取得しようとしており、何か難しかったです。コードは非常に簡単です：クライアントコード： var config = ConfigurationFactory.ParseString(@"

0熱

1答えて

RemoteDeadLetterActorRefからのSelectChildNameメッセージ

私はakkaリモーティングで通信する2つのアクターシステムを持っています。 akka.dispatch.EnvelopeのSelectChildNameのメッセージを含む多くのインスタンスが表示されています（akka.remote.RemoteActorRefProvider$RemoteDeadLetterActorRef）。これらのメッセージの保持されたヒープはかなり大きく、メモリに問題があ

3熱

1答えて

複数のJVMを含むAkkaストリームの背圧を維持する方法

Akka 2.4.16以降、Reactive Streamsの「リモート」実装はありません。この仕様では、単一のJVM上で実行されるストリームに焦点を当てています。しかし、背圧を維持しながら、処理のために別のJVMを使用することを考慮してください。アイデアは、ストリームを実行するユーザーインターフェイスを提供するメインアプリケーションを持つことです。たとえば、このストリームには、別のマシンで実行

0熱

1答えて

特定のアクタを見ているアクタにメッセージをブロードキャストしますか？

特定の俳優を見ているすべての俳優にメッセージをブロードキャストするにはどうすればよいですか？コンテキストの場合、多くのAuctionParticipantActorタイプで監視されているAuctionActor（リモートアクタの可能性があります）があるとします。私はAuctionParicipantActorタイプにさまざまなメッセージをブロードキャストするようにAuctionActorを希望し

0熱

2答えて

シリアライザはAkkaメッセージから共有状態を削除するのに適していますか？

私は分散アルゴリズムに取り組んでおり、Akkaを使用してマシン間でスケールすることに決めました。マシンはメッセージを頻繁に交換する必要があり、これらのメッセージはすべてのマシンに存在する不変のオブジェクトを参照します。したがって、共有された複製オブジェクトがメッセージ内で直列化されるべきではないという意味で、メッセージを「圧縮する」ことは賢明であるようです。これによりネットワーク帯域幅が節約される

1熱

1答えて

Akkaクラスター：なぜReachableイベントを受け取らないのですか？

私はAkkaクラスタに2つのノードを持っています。私は、クラスタのすべての ClusterDomainEventに加入：2つのノードのいずれかがダウンしたとき、私はUnreachableイベントを受け取り、私は次のようにいくつかのログに私を警告する数秒ごとに受信を開始 cluster.subscribe( self, InitialStateAsEvents, cla

0熱

2答えて

ドッカー上の動脈にakkaリモーティングを使用するとエラーが発生する

まずは、英語には申し訳ありません。 Google翻訳は私に多くの助けをしてくれます。私の問題はこれです：私はakkaとjavaで開発された2つのサンプル・プロジェクトを持っています。たとえば、リモートclient.jarのと例 - リモート-server.jar 私は動脈のシリアル化を使用しています、そして、私はakka-remoting経由でクライアントからサーバーにメッセージを送信しようと