akka.net

4熱

2答えて

私は現在、コマンド/メッセージを受け付けるアクターシステムを持っています。これらの俳優の状態はAkka.Persistanceを維持しています。このアクターシステムのクエリシステムを構築したいと考えています。基本的に私たちの問題は、これらの特定のアクターのすべての状態の集合体/リストを取得する方法が必要なことです。私は厳密にCQRSのパターンを購読しているわけではありませんが、私はそれが賢明な方法

1熱

1答えて

設定のデフォルトのディスパッチャ

はそれだけでHOCONの設定を使用して、システム内のすべての俳優のためのデフォルトのディスパッチャを設定することは可能ですか私は何をする必要があります： Context.ActorOf(Props.Create<TActor>(propsArgs) .WithDispatcher("my-fork-join-dispatcher"), actorName); 理想的には私は避

0熱

2答えて

Akka.netとAkka.PersistenceでCQRSのEventBusを適用する方法

私はAkka.netでCQRSとEvent Sourcingを適用する方法に興味があります。私はすでにAkka.PersistenceにES部分を配達していることに気づいた。私が理解している限り、コマンドハンドラとAggergateRootは、単一クラスのReceivePersistentActorで表すことができます。私は public abstract class AggregateRoot

0熱

1答えて

最後の俳優の集計結果を返す方法は？

私は、データ収集でMapReduceを実行するためにActorSystemをセットアップしました。私は今、すべての結果を照合する最後のActorを取得しました。どのように私はこの俳優システムを開始した "サービス"に結果を戻すことができますか？ //in below call i wire up all Actors var getActorSystem = CreateActorSystem(

3熱

1答えて

Akka.netでTestKitを使ってDistributedPubSubをテストするには？

私はクラスタツールDistributedPubSubを使用するアクタをユニットテストしています。テストのために私はAkka.netのTestKitを使用しています。明らかに、TestKitでは、システムアクタSysにDistributedPubSubツールがなく、アクセス時にNullポインタ例外がスローされます。これで役者はのSysの子として作成されたときに失敗コード： var mediado

1熱

2答えて

古いakka.netリモートiactorrefを処理する方法

私は長期間滞在しているWindowsサービスでakka.netのリモートアクターを使用しています。私はActorSelectionを使用してリモートアクターのIActorRefを取得し、このIActorRefを長時間アクティブに保ちます。 IActorRefは、別のWindowsサービスで実行されているアクターシステムを指します。私は、リモートアクタを再起動しても、リモートアクタrefは無効にな

5熱

1答えて

Akka.netとOrleansのパフォーマンス

こんにちは私は始めようとしているプロジェクトのアクターフレームワークを選択する初期段階にあります。私が知る限り、オルレアンは開発者をできるだけ多くの苦痛から解放することを意図していましたが、パフォーマンスを犠牲にしました。 Akka.netで私は俳優のサイズが400バイトだと分かっています。私が正しいとすれば、あなたはオルレアンで管理されているクラスタ接続やものを処理するために低レベルに行かなけれ

0熱

1答えて

Xamarin ClientをAkka.netに接続する方法

私はXamarinまたはUniversalアプリをAkka.netに接続する方法を見つけようとしています。 Orleans doesのようなクライアントに直接俳優からの通知を受けたいと思います。私はgetakkaのWebページでこのようなものは見つかりませんでした。フレームワークでカバーされていないもの、またはXamarinやUniversalアプリのための.net Coreライブラリがないためで

4熱

2答えて

アクタが完全に停止するのを待つ方法はありますか？

私が知っているように、Akka.Netのすべてのオペレーションは非同期であり、は単にStopメッセージをアクタに送信するだけです。それは、俳優が完全にシャットダウンする前に、ある時間生きていることを意味します。 Context.Child()の直後にContext.Stop()の後に私が停止した俳優の名前を呼ぶと、私は同じ俳優を迎えます。ここは var actor = context.Child