問題タブ [akka-remoting]

アクター間でネットワーク経由でメッセージを交換するために Akka Remoting を使用したいのですが、大きな文字列メッセージの場合、次のエラーが発生しました。

この制限を修正するにはどうすればよいですか?

SMS、電子メール、およびプッシュ通知用の Akka クラスター インフラストラクチャを作成しました。システムには、クライアント、送信者、灯台の 3 種類のノードが存在します。クライアント ロールは、Web アプリケーションと API アプリケーションによって使用されています (Web と API は IIS でホストされています)。Lighthouse と Sender の役割は、Windows サービスとしてホストされています。IIS によって Web アプリと API アプリの AppPools がリサイクルされることを考慮して、global.asax.cs の Start および Stop イベントで、Client ロールでアクター システムをシャットダウンし、再度開始します。ログから、システムが正常にシャットダウンしてクラスターに参加したことを確認できます。

しかし、AppPool がリサイクルされると、クライアントの ActorSystem は起動しますが、クラスターに参加できず、通知が機能しなくなることがあります (これは私たちにとって大きな問題です)。ActorSystem を手動で停止し、再度手動で動作させると、クラスターに参加します。この状況は、約 2 日ごとに発生します。

クライアントがエラーの前にクラスターに参加していることを確認できます。

ノード [akka.tcp://NotificationSystem@ . . . :41350] は JOINING、ロール [クライアント]
リーダーはノード [akka.tcp://NotificationSystem@ を移動中です。. . :41350] から [上へ]

ログを見ると、クライアントがクラスターに参加した後に次のエラーが表示されます。

シャットダウン アドレス: akka.tcp://NotificationSystem@ 。. . :41350Akka.Remote.ShutDownAssociation: シャットダウンアドレス: akka.tcp://NotificationSystem@ . . .:41350 ---> Akka.Remote.Transport.InvalidAssociationException: シャットダウン中のため、リモート システムがアソシエーションを終了しました。--- 内部例外スタック トレースの終了 --- Akka.Remote.EndpointWriter.PublishAndThrow(例外の理由、LogLevel レベル) で Akka.Remote.EndpointWriter.b__20_0(例外の例) で Akka.Actor.LocalOnlyDecider.Decide(例外の原因) で) at Akka.Actor.OneForOneStrategy.Handle(IActorRef child, Exception x) at Akka.Actor.SupervisorStrategy.HandleFailure(ActorCell actorCell, Exception cause, ChildRestartStats failedChildStats, IReadOnlyCollection1 allChildren) at Akka.Actor.ActorCell.HandleFailed(Failed f) at Akka.Actor.ActorCell.SystemInvoke(エンベロープ エンベロープ)--- 例外がスローされた前の場所からのスタック トレースの終わり --- Akka.Actor で Akka.Actor.ActorCell.HandleFailed(Failed f) で。. . .:41350 ---> Akka.Remote.Transport.InvalidAssociationException: シャットダウン中のため、リモート システムがアソシエーションを終了しました。--- 内部例外スタック トレースの終了 --- Akka.Remote.EndpointWriter.PublishAndThrow(例外の理由、LogLevel レベル) で Akka.Remote.EndpointWriter.b__20_0(例外の例) で Akka.Actor.LocalOnlyDecider.Decide(例外の原因) で) at Akka.Actor.OneForOneStrategy.Handle(IActorRef child, Exception x) at Akka.Actor.SupervisorStrategy.HandleFailure(ActorCell actorCell, Exception cause, ChildRestartStats failedChildStats, IReadOnlyCollection`1 allChildren) at Akka.Actor.ActorCell.HandleFailed(Failed f) ) Akka.Actor.ActorCell.SystemInvoke(エンベロープ エンベロープ) で --- 例外がスローされた前の場所からのスタック トレースの終わり --- Akka.Actor で Akka.Actor.ActorCell.HandleFailed(Failed f) で。

エラーの後、次のエラー メッセージが表示されます。

[akka.tcp://NotificationSystem@ への関連付け。. . :41350] が UID [226948907] を持つことは回復不能に失敗しました。UID は隔離され、この UID へのすべてのメッセージはデッド レターに配信されます。この状況から回復するには、リモート アクター システムを再起動する必要があります。

クライアント アクターを再起動しないと、システムはそれ自体を修正しません。

クライアント ロールの構成は次のとおりです。

送信者の役割の構成は次のとおりです。

どうすればこの問題を解決できますか? ありがとうございました。

パフォーマンスを向上させるためにシリアライザーを定義するという提案を満たす方法を知りたいので、警告メッセージを無効にしたくありませんか?

Akka.net を使用して、簡単なシナリオを実装しようとしています。サーバーがクライアントから送信されたメッセージを受信して​​処理する 2 つのサーバーと 1 つのクライアントを作成しました。

セットアップが正常に動作することもあれば、次のエラーが表示されることもあります。原因を突き止めることができません。

**

**

クライアント構成:

サーバー構成:

また、次のようにシリアル化に Newtonsoft.Json を使用しています。

私は Akka を学んでおり、Akka リモーティングを試しています。私は intellij IDE を使用しており、使用されている言語は Java です。AKKAのリモート例(電卓)を動かしてみました。私はsbtツールを使用していません。アプリケーションをビルドして実行するにはどうすればよいですか。サンプルを実行してみましたが、構成ファイルを正しく読み取っているとは思えず、リモート アクターが作成されていません。プロジェクトにakka jarファイルを含めました。プログラムを実行するために、intellij で単純な Java プロジェクトを作成しました。

私はそれを正しい方法でやっていますか？同じものをビルドして実行する別の方法は何ですか。Java で sbt を使用する方法。

1 つのマスター アクターと複数のワーカー アクターで akka クラスター (akka ライブラリ バージョン 2.3.9 を使用) を設定しています。マスター アクターは、プール クラスター対応ルーターで構成されます。

4 つのクラスタ ノードを形成してアプリケーションをデプロイします。最初はすべてのノードが適切にクラスターに参加していますが、数分後にノードがクラスターとの関連付けを解除し、独自のクラスターを形成しています。