問題タブ [akka-remote-actor]

Play からオブジェクトを送信できるアーキテクチャに取り組んでいます。一連の Akka リモート システムへのアプリケーション。

パッケージはすべてのシステムで共有されmodels.*ますが、モデルは Play! ユーザー入力に基づくアプリケーション。現在、集中的な操作のために、これらのモデル オブジェクトはリモート アクターに渡されて処理されます。リモート アクターは、オブジェクトを永続化するためのものではなく、データに基づいてオブジェクトを操作するためのものです。

したがって、たとえば、サード パーティの API でユーザーを更新する必要がある場合、DB からのオブジェクトはリモート アクターに送信されます。

EbeanPlay!で使用しています。

これに関する障害は、Akka システム側で、Ebean がエラーをスローすることです。

これは、私の意見では、モデル クラスが拡張Modelされているため、Ebean はデータベースへの接続を想定していることを意味します。これは目的を打ち負かします。

これはどのように解決できますか？シリアル化はオプションではありません。

この単純なサーバー クライアント akka プロジェクトをフォークしました: https://github.com/roclas/akka-irc これは IRC のようなチャットで、メッセージをエンコードしようとしています。

私のマスター ブランチで、サーバーを起動し (sbt を実行してからオプション 2 を選択)、次にクライアントを起動し (sbt を実行してからオプション 1 を選択)、クライアントに何かを書き込むと、メッセージはサーバーに正しく送信されます。

Wireshark を起動して、tcp.port==1099 および tcp.len>200 という条件を満たすメッセージを聞くと、

メッセージをプレーンテキストで読むことができます。

SSL を使用してそれらをエンコードするにはどうすればよいですか? 開発ブランチの src/main/resources/application.conf ファイルを変更することで、私が何をしようとしているのかを確認できます。何を変更する必要がありますか? src/main/resources/application.conf ファイルはどのように表示されますか?

ありがとうございました

同じアクター間でイベント バス メカニズムを使用するのActorSystemは簡単ですが、以下のアクター間でこれを行うための認可された方法があるかどうか疑問に思っていました。

• ActorSystems同じ JVM 内の異なるアクター
• 異なる JVM のアクター (リモーティング経由)

アクターへのパスは問題ないことを知っていると仮定しますが、そのようなものを発見するための一般的に使用されるメカニズムがあれば、ぜひ聞きたいです。

app1 と app2 という 2 つのアプリケーションがあります。マシン 1 では app1 と app2 の両方が実行されますが、ほとんどの作業は app2 によって行われるため、マシン 2 では app2 のみが実行されます。アプリは Akka を使用します。

akka remoting を使用して、マシン 1 の app1 からマシン 2 の app2 にメッセージを渡すことができるようにしたいと考えています。 app1 と 2 は、同じマシン上にある場合に相互に対話できます。

ただし、マシン 1 のアプリ 1 がマシン 2 のアプリ 2 に接続しようとすると、エラーが発生します...

EndpointWriter - AssociationError [akka.tcp://deal-rest@127.0.0.1:4242] -> [akka.tcp://deal@:4241]: エラー [無効なアドレス: akka.tcp://deal@:4241] ] [ akka.remote.InvalidAssociation: 無効なアドレス: akka.tcp://deal@:4241 原因: akka.remote.transport.Transport$InvalidAssociationException: 接続が拒否されました: /:4241

netstat -a | を実行すると マシン 2 で egrep 'Proto|LISTEN' を実行すると、応答 tcp6 0 0 localhost:4241 [::]:* LISTEN を下回りました。

これは、app2 が実行中であり、4241 でリッスンできることを示しています。

また、ポート 4241 はマシン 1 と 2 で開いています。

どんな提案も役に立ちます。ありがとう。

akkaでリモートアクターを閉じることは可能ですか、および/または必要ですか?

akka.actor.ActorSystem「サーバー」として（scalaで）起動できます：

そして、別の JVM で実行されている「クライアント」ActorSystem からそれに接続します。

メッセージを送信しremote、応答メッセージを受信できます。

ただし、クライアントをシャットダウンするときは、クライアント JVM が停止した後、サーバー ActorSystem から次のログ メッセージが表示されます。

[警告] [04/01/2015 11:27:27.107] [TestServer-akka.remote.default-remote-dispatcher-5] ... [akka.tcp://ConsoleSystem@localhost:1236] が失敗しました、アドレス[5000] ミリ秒の間ゲートされます。理由: [関連付け解除]

これらの警告は悪いものですか? remote.closeConnection警告メッセージを防ぐために呼び出す必要があるメソッドはありますか?

前もって感謝します。

So I have this segment of code

However, when I send the identify message (which is the right path) it doesn't get an ActorIdentity, it just prints "not ready yet".

When I run the server locally everything works fine. So I'm really confused as to why the server is working as intended.