actor

0熱

1答えて

AkkaライフサイクルとAkkaアクター監督戦略を探そうとしています。私は自分自身の例外を作成し、akkaのライフサイクルとその回復戦略を調べるためにpublic SupervisorStrategy supervisorStrategy()メソッドをオーバーライドしています。私は続けてEsclateExceptionログを投げると俳優を終了していないとき方法で public class Java

2熱

1答えて

オルレアン・キーとデータベース・レコード

私はMicrosoft Orleansを学んでいるだけで、私たちのシナリオの1つをどのように処理するのが最善だろうと思います。要求を受け取るRESTサービスがあり、最終的に外部システムに新しいレコードが作成されます。このレコードは長いId値を持ちます。このIDを呼び出し元に返します。このシナリオの推奨事項は何ですか？外部システムの呼び出しとIDの取得を処理するステートレスなグレインがあるはずです

0熱

1答えて

Akka - メッセージはキューに入れられ、頻繁には消費されません。

大量の作業を行い、メッセージの受け渡しによって進行状況を報告するAkkaベースのアプリケーションがあります。「作業者」は、「マネージャ」に作業を完了したときにレポートを発行し、作業者に作業を送り、「マネージャ」が単に進行状況を記録したアクタrefにメッセージを送信します。 "manager"と "workers"はすべてディスパッチスレッドプールを共有し、 "tracker"アクターは自身の小さ

2熱

1答えて

私は俳優のリストを持っている俳優

のリストに同じメッセージを送信：私はすべてに同じデータを送信したい listeners: Seq[ActorRef] 今私が行います listeners.foreach { l => l ! data } がより効率的にありますこれを行う方法？

0熱

1答えて

分散メールメールボックスのAkkaアクターシステムデザイン

Akkaに基づいて分散メールメールボックスシステムを作成したいと思います。私のアプリが起動すると、すべての受信トレイのアクタを作成し、10秒間隔でメールを受信するスケジューラを起動したいと考えています。これらの受信ボックスアクターを作成する方法に問題がありますか？クラスター上にアクターを作成することも、存在する場合はそれを参照することもできますか？アクター名は、データベース内のメールボックスUU

0熱

1答えて

は、アッカ・メッセージがユニーク/いくつかの属性

でバージョン管理、私は次のユースケースを持っていることを確認します：俳優がkey:valueペアで構成され、いくつかの外部ソースからのデータを消費します。その後、彼らはkeyと最新のvalueでいくつかのアクションを実行する必要がある俳優に渡され、古いものをスキップします。基本的に私はメールボックスを1の容量の "サブトピック"に分割しようとしています。 Akkaでそのようなことは可能ですか？そ

2熱

1答えて

アクタのアクタがデータベースから状態を読み取る

データベースからアクタの状態を初期化する必要がある場合は、パターンを尋ねます。私は将来を返すDAOを持っています... [...]そしてノンブロッキングメッセージがノーマルになることは、将来の完全な俳優に送るべきです。しかし、このケースは異なります。初期化が完了する前に俳優のメールボックスからメッセージを受け取ることができません。データベースの未完了を待っている間にアクタースレッドをブロックする唯

0熱

1答えて

自動Microsoft Orleansの穀粒フェールオーバーで再試行

いくつかのサイロが何らかの理由で応答しない（サーバーがダウンしているなど）場合、Grain Fail-Overの動作をテストしています。現在、我々は2つのサイロを2つの異なるマシン上で実行しており、それぞれにグレインをアクティブにしています。次に、サイロの1つを殺すように進んでいます（予期せず）。私たちはDEADサイロで穀物を呼びそそうとしていますが、タイムアウトしてから（合計3分だと思います）、

4熱

1答えて

Service Fabricは実行時にパーティション間でアクターを移動するAPIを提供しています

Microsoft Researchの非常に面白いpaperを見つけました。ここでは、彼らの近接性に基づいてサーバー/パーティション間でアクターを再配布するアルゴリズムについて説明します。サーバ間のリモートコールを減らすことができます。彼らはプロトタイプをOrleansフレームワークに適用しました。サービスファブリックアクターフレームワークが実行時にアクターを再配布/バランス調整するためのイン

4熱

1答えて

Akka Actor Test：TestProbeを使用した自動返信

メッセージを受信するたびに、確認応答を返すテストプローブを取得しようとしています。私は私のテストでは、次のコードを書きましたが、それは動作しません： val chgtWriter = new TestProbe(system) { def receive: Receive = { case m => println("receive messagereplying