actor

1熱

1答えて

私は俳優ベースのアプリケーション用のテストケースを作成しています。今 class MyActor(a: ActorRef, b: ActorRef) extends Actor { override def receive: Receive = { case _ => a ! "Got message!" b ! "Hello!" }

0熱

1答えて

Akka Actorライブラリーのカスタマイズ

akkaアクターを使用して、他の人が使用したり設定したりするライブラリーを作りたいと思っています。 "MemoryDatabase"や "FileDatabase"や定義されたクラスやアクタを拡張するもの（質問2を参照）のような、ライブラリユーザーがストレージのタイプを注入するリポジトリアクタを作りたいと思っています。 1）ユーザーがオプションを指定する最も良い方法は何ですか（作成したオプションを

0熱

2答えて

アクターとメールボックス - メッセージを配信するのは誰ですか？

私は俳優のメールボックスに行くメッセージに質問があります。私は俳優がメールボックスを持っているが、その一部ではないことを認識しています。メールボックスは、俳優システムによって提供されます。質問：私はその後、ID 10 myActとスレッド上で実行されている俳優のmyActを持っています！他の俳優にメッセージを送る。スレッド10がyourActのメールボックスにメッセージを送信するのは責任である

0熱

3答えて

UUIDで名前を付けるとakkaアクターのディスパッチャーが定義される

Akkaアクターを使用してJavaで構築されたプレイアプリケーションがあります。最近、並列性に関するパフォーマンス上の問題が発生しました。 Googleを経由して、カスタム/固定のディスパッチャ/エグゼクティブを俳優に割り当てることができることがわかりました。俳優の作成時に、俳優の名前に一意のIDが付けられた俳優の名前を付けました。アクター名に一意のIDが付加されている場合、固定ディスパッチャー

0熱

1答えて

シャープな俳優に送るときにReactiveKafkaへの背圧

私はKafkaからの入力を受け取り、シャードされた俳優とのデータを処理してKafkaに出力するAkkaアプリケーションを作成しました。しかし、いくつかの場面でシャードの領域は、負荷を処理することができない、と私は得る：おそらくリモート接続をフラッディングを回避するためにフロー制御を実装する必要があります。このチェーン/フローにどのようにバックプレッシャーを実装できますか？カフカ消費者 -

0熱

2答えて

は「この」

からActorRefを取得するにはどのように俳優のクラスを考えてみましょう。しかし、ActorRefとして "this"が必要です。 "this"はActor型であるため、ActorRefが必要な場所に渡すことはできません。これは、Actor（ "this"）がActorRefとして自分自身への参照を取得するにはどうしたらいいですか？これは、ことも可能である、または私は完全に誤解何かだ...

0熱

1答えて

initへの2つの方法の違いAkka Router

私のシステムは、Playフレームワーク2.5とAkkaビルドインで動作します。ルータを初期化するには2つの方法があると思います。 1： ActorRef router = akkaService.getActorSystem() .actorOf(new RoundRobinPool(poolSize) .props(Props.create(ProfileActor.clas

0熱

1答えて

アクタのサイズが変更されたときのリスナーはありますか？

以下のコードスニペットで書かれたものよりも、リサイズで特定のメソッドを実行する簡単な方法があるのだろうかと思っていました。 @Override public void resize(int width, int height) { stage.getViewport().update(width, height, true); for (Table t : tab

1熱

2答えて

の.propertiesにアッカ.confファイルの設定は私のTest.confをファイルで

ファイル私は、次のような構成 akka { actor { provider = "akka.cluster.ClusterActorRefProvider" serializers { java = "akka.serialization.JavaSerializer" } serialization-bindings {