Akka protobuf シリアライザーで動作する Scala Protobuf メッセージを取得しようとしていますが、リモーティング経由でメッセージを送信すると、この応答が返され続けます

アプリケーション構成では、このセットアップがあります

メッセージは、別のプロジェクトで proto ファイルの下src/main/protobufにコンパイルされ、sbt と ScalaPB ( "com.trueaccord.scalapb" % "sbt-scalapb" % "0.4.20") プラグインでコンパイルされます。

手がかりはありますか？

回線 A を無効にすると、HelloRemote アプリは「hello world」というメッセージを受信できません。ローカルのアクター システムをあまりにも早くシャットダウンすると、メッセージがリモートに送信されないようです。

もちろん、ローカルのアクターは、リモートからのメッセージを待ってメッセージが既に受信されていることを確認することもできますが、そのようなコードを追加すると、プロセスは同期的になり、RPC のようなものにはなりたくありません。

非同期にしたいだけでなく、「Thread.sleep(3000)」で時間を無駄にしたくないので、クライアントをできるだけ早く終了させたいのですが、何か提案はありますか?

HelloRemote.scala

Local.scala

また、簡単に試すために application.conf を貼り付けます。

リモート部分:

ローカル部分:

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

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

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

**

**

クライアント構成:

サーバー構成:

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

私は Akka Cluster (バージョン 2.4.10) を使用しており、「フロントエンド」の役割に指定されたいくつかのノードと、「ワーカー」として指定されたいくつかのノードがあります。ワーカーはリモート マシン上にあります。着信作業は、フロントエンド アクターによってラウンド ロビン ルーティングによってワーカーに分散されます。問題は、「ワーカー」からの応答をフロントエンド アクターに送り返すことです。作業員が作業を完了しているのがわかります。しかし、ワーカーからフロントエンドに送信されたメッセージは届かず、配信不能になります。ログに以下のエラーが表示されます。

私はこれを見て、コードで同じことに従っています。これも見ましたが、事前にルートがわからないため、提案された解決策はこの場合には適用されません。それは構成を通じてもたらされ、変更される可能性があります。ラウンドロビン ルーターの構成は次のとおりです。

ルーターは、以下のようにフロントエンド アクターでインスタンス化されます。

コントローラーとワーカー コードは次のとおりです。

ここで私が間違っていることを教えてください。あなたの助けに感謝。

I have a remote actor, Bar and a local actor, Foo. I want to use Foo to pass messages to Bar on each invocation of a CLI.

Bar can be passed messages successfully, but Foo hangs while waiting for a message. To fix this, I added a sys.exit(0) at the end of Foo's main. This causes an association issue with Foo's system.

How can I shut down my local actor between successive CLI issuances without killing my local actor manually?

Shut up and give me the code!

Foo:

build.sbt

Main.scala

application.conf

Bar:

build.sbt

Main.scala

application.conf

Run Foo with sbt 'run-main Main -m hello', and run Bar with sbt 'run-main Main'.

Sorry for the long code, but it's the MVCE for my problem.

How can I achieve my desired behavior -- the CLI actor dies between successive CLI invocations with the remote actor waiting for new messages.