問題タブ [akka.net-cluster]

現時点で、コンシステント ハッシュ グループ ルーターを介して別のアクター (コンサート) を呼び出すアクター (ユーザー) を持つプロジェクトを作成しています。すべて正常に動作しますが、私の問題は、コンサート アクターからの質問メッセージに応答できないことです。どういうわけかメッセージが失われ、クライアントで何も起こりません。私は運がないすべてを試しました：

• Sender.Tell <-- 一時的な? 差出人
• メッセージ内で User IActorRef を参照渡しし、それを使用します。

完全なコードは次のとおりです: https://github.com/pablocastilla/AkkaConcert

主な詳細は次のとおりです。

ユーザー アクター:

クライアント HOCON 構成:

バックエンド側:

アクターが作成されます

コンサート アクターのメッセージ処理

バックエンド側の HOCON 設定:

ありがとう！

クラスター内のアクター間の通信に問題があります。

私のテストプロジェクトには、以下の構造があります。

TestJob [C# コンソール プロジェクト]

• TestJobService.cs
• TestJobActor

MainProject [C# コンソール プロジェクト] //注: このサービスをシード ノードとして構成しました。灯台は使いませんでした。

• MainService
• JobManagerActor

注: アクターを共有プロジェクトまたはメイン プロジェクトに配置したくありません。テスト ジョブを実行することになっているアクターは、「TestJob」プロジェクトの下にある必要があります。

私はすでにこの記事http://getakka.net/docs/clustering/cluster-overviewとビデオをフォローしています。記事に基づいて Akka.Cluster を有効にしました。両方のコンソール プロジェクトを実行できますが、JobManagerActor から TestJobActor に「指示」しようとすると、機能しません。エラーはありませんが、動作しません。

MainProject にこの構成があります。

メッセージの送信に使用するコードは次のとおりです。

私は何が欠けていますか？前もって感謝します。

注: 同様の構造を持つ私のテスト プロジェクトは、https://github.com/michaelsync/APMDemoにあります。(VS2015 プロジェクト)

もう 1 つ質問があります。クラスターを使用している場合でも、アクターの選択を使用できますか?

I am currently looking for a visualizer for akka.net (.NET version). I found none so I am wondering if there is any way to make akka-tree (scale) and akka.net cluster work together. I guess if both framework are following the same spec then it should work. is it?

I tried asking this question in akka-tree but no response so I am trying my luck here.

https://github.com/nraychaudhuri/akka-tree/issues/15

I am not familiar with scale but I did the following changes.

I tried adding the UDP configuration in my akka.net sample because I think this visualizer is using UDP.

And then, I tried to change the IP address in this file akka-tree\visualizer\app\controllers\Application.scala

But, doesn't work.. Any idea how to make it work? Thanks!

Update:

I tried using TCP but doesn't work.

I am getting the exception below when I access the webpage "localhost:90000". I am not familiar with Scale but I think it has something to do with scale installation. I did install scale and java on my machine tho..

[info] Compiling 1 Scala source to D:\git\akka-tree\visualizer\target\scala-2.11 \classes... [info] play - Application started (Dev) [error] application -

! Internal server error, for (GET) [/] ->

java.lang.ExceptionInInitializerError: null at Routes$$anonfun$routes$1$$anonfun$applyOrElse$1$$anonfun$apply$1.appl y(routes_routing.scala:72) ~[na:na] at Routes$$anonfun$routes$1$$anonfun$applyOrElse$1$$anonfun$apply$1.appl y(routes_routing.scala:72) ~[na:na] at play.core.Router$HandlerInvokerFactory$$anon$13$$anon$14.call(Router. scala:217) ~[play_2.11-2.3.7.jar:2.3.7] at play.core.Router$Routes$TaggingInvoker.call(Router.scala:464) ~[play_ 2.11-2.3.7.jar:2.3.7] at Routes$$anonfun$routes$1$$anonfun$applyOrElse$1.apply(routes_routing. scala:72) ~[na:na] Caused by: java.net.SocketException: Not a multicast address at java.net.MulticastSocket.joinGroup(Unknown Source) ~[na:1.8.0_51] at controllers.Application$.(Application.scala:16) ~[na:na] at controllers.Application$.(Application.scala) ~[na:na] at Routes$$anonfun$routes$1$$anonfun$applyOrElse$1$$anonfun$apply$1.appl y(routes_routing.scala:72) ~[na:na] at Routes$$anonfun$routes$1$$anonfun$applyOrElse$1$$anonfun$apply$1.appl y(routes_routing.scala:72) ~[na:na] [error] application - Error while rendering default error page scala.MatchError: java.lang.ExceptionInInitializerError (of class java.lang.Exce ptionInInitializerError) at play.api.GlobalSettings$class.onError(GlobalSettings.scala:148) ~[pla y_2.11-2.3.7.jar:2.3.7] at play.api.DefaultGlobal$.onError(GlobalSettings.scala:206) [play_2.11- 2.3.7.jar:2.3.7] at play.core.server.Server$class.logExceptionAndGetResult$1(Server.scala :63) [play_2.11-2.3.7.jar:2.3.7] at play.core.server.Server$$anonfun$getHandlerFor$4.apply(Server.scala:7 3) [play_2.11-2.3.7.jar:2.3.7] at play.core.server.Server$$anonfun$getHandlerFor$4.apply(Server.scala:7 1) [play_2.11-2.3.7.jar:2.3.7] [error] application -

! Internal server error, for (HEAD) [/] ->

java.lang.NoClassDefFoundError: Could not initialize class controllers.Applicati on$ at Routes$$anonfun$routes$1$$anonfun$applyOrElse$1$$anonfun$apply$1.appl y(routes_routing.scala:72) ~[na:na] at Routes$$anonfun$routes$1$$anonfun$applyOrElse$1$$anonfun$apply$1.appl y(routes_routing.scala:72) ~[na:na] at play.core.Router$HandlerInvokerFactory$$anon$13$$anon$14.call(Router. scala:217) ~[play_2.11-2.3.7.jar:2.3.7] at play.core.Router$Routes$TaggingInvoker.call(Router.scala:464) ~[play_ 2.11-2.3.7.jar:2.3.7] at Routes$$anonfun$routes$1$$anonfun$applyOrElse$1.apply(routes_routing. scala:72) ~[na:na] [error] application - Error while rendering default error page scala.MatchError: java.lang.NoClassDefFoundError: Could not initialize class con trollers.Application$ (of class java.lang.NoClassDefFoundError) at play.api.GlobalSettings$class.onError(GlobalSettings.scala:148) ~[pla y_2.11-2.3.7.jar:2.3.7] at play.api.DefaultGlobal$.onError(GlobalSettings.scala:206) [play_2.11- 2.3.7.jar:2.3.7] at play.core.server.Server$class.logExceptionAndGetResult$1(Server.scala :63) [play_2.11-2.3.7.jar:2.3.7] at play.core.server.Server$$anonfun$getHandlerFor$4.apply(Server.scala:7 3) [play_2.11-2.3.7.jar:2.3.7] at play.core.server.Server$$anonfun$getHandlerFor$4.apply(Server.scala:7 1) [play_2.11-2.3.7.jar:2.3.7]

クラスター グループ ルーターを構成しようとしていますが、これがどのように機能するかについての前提を確認したいと考えていました。

クラスター内に 2 つの個別のノードがあり、これらには次のロール「mainservice」と「secondservice」があります。「mainservice」内で、ラウンド ロビン グループ ルーターを使用して「secondservice」内のアクターにメッセージを送信したいと考えています。

akka hocon 構成では、 akka.actor.deployment セクション内に次のものがあります。

ドキュメントに基づく私の仮定は、「mainservice」に「secondserviceproxy」アクターを作成できるということです。これは、「secondservice」の実行中のインスタンスへのメッセージのルーティングをラウンドロビン ベースで処理します。

また、routees.path プロパティは、"/user/gateway" のようなアクター階層にある "secondservice" 内のアクターにメッセージが送信されることを意味すると仮定しました。

私の作業仮定は正しいですか？この実装では、「secondservice」で結果が得られないためです。

私は akka.net を学んでおり、従来のメッセージ駆動型アプリの一部を置き換えるために使用する可能性があります。

基本的に、 X 個のノードをクラスターに参加させようとしています。これはピア ツー ピアタイプで、ノード上で X 個のアクター (同じアクター) を実行する場合があります。

10 個のジョブ (SendEmailActor など) がある場合、理想的には、10 個のジョブのそれぞれを異なるノードで実行します (負荷を均等に分散します)。

デモ用の非常に単純なコンソール アプリがあります。

そして、私のapp.configは次のようになります

HOCON を使用して akka.actor.deployment をセットアップしたいのですが、うまくいきませんでした。routees.paths と、 actor.deployment/workerとの関係、およびroutees.pathsが C# で作成されたアクターにどのようにマップされるかがよくわかりません。

別の質問: aka.net.cluster を使用して、ノードを「ミラーリング」して冗長性を提供することは可能ですか? それとも、GuaranteedDeliveryActor (AtLeastOnceDelivery に名前が変更されたと思います) が進むべき道ですか?

以下のようなセットアップがある場合、3 つのノードをクラスターに参加させ、ラウンド ロビン プールを使用するとします。

「ワーカー」は、以下のように処理したメッセージの数を単純に覚えています

異なるクラスタ ノード上の異なるアクター間で「処理済みリスト」を同期する方法はありますか? これは akka.net.cluster.sharding が最終的に行うことですか? それとも、まったく意味のないことをしていますか?

akka.net クラスターを形成する複数のワーカー ロールを含む Azure クラウド サービスを開発しています。コンピューティング エミュレーターのコンソール ウィンドウに表示されるクラスターのゴシップやその他のメッセージを取得するにはどうすればよいですか?

私は akka.net クラスターを持っていて、ローカルとリモートの両方のアクターにメッセージを送信したいと考えています。これらのアクターはすべて「/user/foobar」というパスを (少なくともローカルでは) 持っています。ActorSelection を使用する必要がありますか? また、一致するローカル アクターとリモート アクターの両方をターゲットにするには、パスをどのように設定する必要がありますか?