akka

0熱

2答えて

（https://doc.akka.io/docs/akka/current/general/addressing.html）それぞれの定義は論理俳優パスある：ルートガーディアンは、論理呼ばれ向かって親の監督のリンクをたどることによって得られた固有のパスアクターパス。このパスは、アクタの作成祖先とまったく同じです。したがって、アクタシステムのリモート設定（およびそのパスのアドレスコンポーネント）

0熱

1答えて

GenericHttpCredentialsを使用してHTTP要求ヘッダーからトークンを抽出します

私のHTTP要求の承認ヘッダーからトークンを抽出しようとしています。権限ヘッダの形式はAuthorization: Token token=abcdefg123です。私は次の関数シグニチャを持っていますが、次のコードスニペットを試したとき、コンパイルエラーはCannot resolve symbol Map. Cannot resolve method Map.unapplyです。なぜこれが起こっ

0熱

2答えて

がどのようにScalaの

にフューチャー内のオブジェクトを取得するために、私は以下のような将来の応答のための別のmyActor2を依頼するアッカmyActor1を使用します。 case class Person(name: String, age: Int) ： val future = myActor2 ? request val result = Await.result(future, timeout.dura

1熱

2答えて

複数のシンクが

私はこの二つのシンクなどのストリームを持っているが、一方のみが一度に使用されます。 Source.fromElements(1, 2, 3) .via(flow) .runWith(sink1) または Source.fromElements(1, 2, 3) .via(flow) .runWith(sink2) それは設定可能です我々が使用沈みます両方のシンクを並行して使用すると

0熱

1答えて

AbstractLoggingActorはFile Appenderへの書き込みではなく、Java Akkaのコンソールへの書き込み

AbstractLoggingActorを拡張してアクターを実装しました。しかし、どういうわけかakkaログはコンソールにのみ書き出され、ログファイルには書き込まれず、エラーはスローされません。実際のakkaバージョンと同じバージョンのakka-slf4jを使用していますが、ヘルプはありません。私は最初に使用した元のpom configsを添付しています。 logback.xml <append

1熱

1答えて

Slickストリーミングデータの変換とAkka Httpを使用したチャンクレスポンスの送信

目的は、データベースからデータをストリーミングし、このデータチャンクで何らかの計算を実行することです（この計算は、あるケースクラスの未来を返します）ユーザに提供する。現在、私はデータをストリーミングし、計算を実行せずに応答を送信できます。しかし、私はこの計算を実行できず、結果をストリーミングすることができません。これは私が実装したルートです。 def streamingDB1 = path("

0熱

2答えて

ReactiveとResilientの違いは何ですか？

私はReactiveとResilientの違いを探しています。私はいくつかの記事を通しましたが、それは私にいくらかはっきりしていますが、外交的説明とはかなり混乱しています。私は弾力性の意味理解何は、要求の数が増加したときに同じサービスのインスタンスの数が増加した場合ということです。同様に、要求が少ない場合には減少します。したがって、インスタンスの数が増減しても、それが安定した状態にいかに簡単か

0熱

1答えて

リモートアクタをプログラムで作成すると動作しない

私はリモートのアクタアクタをプログラムで作成しています。以下はプログラムである - package remoting.programatic.demo import akka.actor.{ActorSystem, Props} import com.typesafe.config.ConfigFactory import remoting.config.demo.RemoteActor

0熱

1答えて

コンテキストをモックする方法（ActorContext）？

私はTestKitを使ってAkka Actorsをテストしています。メソッドgetActorRefを持つクラスDemoがあります。このメソッドは文字列として入力を受け取り、ActorRefを返します。 class Demo @Inject()(a: A. b: B, context: ActorContext) { def getActorRef(id: String): ActorRe

0熱

3答えて

2バイトの区切り文字でakka ByteStringを分割する方法

自分自身のWebSocketプロトコルを作成していて、テキストキー/値ヘッダー部分が2つの連続する改行で終わり、その後にバイナリテールが続くと考えています。 2つの改行でByteStringを半分に分割することは本当に面倒です。 1つのための組み込みの.splitメソッドはありません。バイナリフィンガープリントを見つけるためのものは.indexOfではありません。あなたはこれに何を使用しますか？