問題タブ [akka]

akka のソース コードを表示したいのですが、0.7.x バージョンの sbt を使用しているようです。
プロジェクト構成を 0.10.x バージョンに変換します。libraray-dependencies に sbteclipse を追加し、eclipse create-src を実行して eclipse プロジェクトを生成すると、eclipse はコマンドではないことがわかりました。これが私の Build.scala です。ライブラリ依存関係を使用してライブラリをリストすると、sbteclipse_2.8.1.jar が実際に存在します。

私は前にばかげた間違いを犯していました。プラグイン定義は、yourproject/build.sbt のライブラリ依存関係としてではなく、project/plugins/build.sbt ファイルで宣言する必要があります。

akka では、各アクターが上流からメッセージを受信し、独自のメッセージを下流に送信し、応答を待ってから上流にメッセージを返すような、アクターの線形チェーンがあるとします。後でアクターに返信する必要がある場合、アクターは上流のアクターのハンドルをどのように覚えていますか?

例えば：

基本的に、B は A のハンドルをどのように覚えていますか? この時点で self.reply を実行すると、C が現在のメッセージを B に送信したため、C が参照されます。

私はscalaの非常に新しい仲間です。そこで、ソースコードAKKAをダウンロードして、eclipse（2.7.7 final）のプラグインをインストールします。プロジェクトを開くと、29個のコンパイルエラーが表示されます。バージョンの不一致またはプラグイン設定の問題である可能性があります。しかし、私はそれをトラブルシューティングする方法がわかりません。

a）'）'が必要ですが、'='が見つかりました。：

b）識別子が必要ですが、「オブジェクト」が見つかりました。

誰かがこの簡単な質問を助けることができますか？

どうもありがとう：）

アップデート：

同様の質問がjilenによって尋ねられます。

sbteclipseプラグインをSBT0.10.xに追加する方法

私の目標は、ウィジェットの並行性の高いバックエンドを構築することです。私は現在、バックエンドをWebサービスとして公開しています。このサービスは、特定のウィジェットを実行する要求を受け取り（Scalatraを使用）、DBからウィジェットのコードをフェッチし、アクターで実行し（Akkaを使用）、結果を返信します。だから私が次のようなことをしていると想像してください：

これは最善の並行ソリューションではないと思います。リクエストのリッスンとウィジェットの実行を1つのアクター実装で組み合わせる必要があります。最大の同時実行性のためにこれをどのように設計しますか？ありがとう。

純粋な Akka を利用した REST ベースの Web API を実装するつもりです。スプレーの使い方がよくわかりません。もしよろしければ、Scalatra を使用することを検討します。基本的に、私は Scala Actor モデルの並行性の利点を利用することに興味があります。その過程でサーブレットコンテナが邪魔になるのは嫌です。

他のオプションは何ですか？

更新 1: Akka バックエンドに基づいて REST を実装するには、どちらのフロントエンドが適していますか? - スプレー、Scalatra、Dropwizard、またはその他?

上記の 3 つのフレームワークは、次の点でどのように比較されますか

1) パフォーマンス 2) 使いやすさ 3) 実際のテスト

およびその他の関連パラメータ?

Akka と Camel の統合について読んでいました。初めてCamelに出会いましたが、素晴らしい音です。Akka と Camel を使用して簡単に REST サービスを構築できますか? その方向に役立つポインタはありますか?

私の現在のアプリケーションは akka 1.1 に基づいています。ProjectAnalysisActors特定のプロジェクトの分析タスクを処理する責任がそれぞれ複数あります。このようなアクターが一般的な開始メッセージを受信すると、分析が開始されます。1 つのステップが終了すると、次のステップが定義されている限り、それ自体にメッセージを送信します。実行コードは基本的に次のようになります

各分析ステップの実行方法のコードを実装する方法に問題があります。現時点では、各実行メソッド内で新しい未来を作成しています。この未来の内部では、すべてのフォローアップ メッセージをさまざまなサブシステムに送信します。それらのいくつかはノンブロッキングのファイアアンドフォーゲットメッセージですが、次の分析ステップが開始される前に保存する必要がある結果を返すものもあります。

現時点では、典型的な実行方法は次のようになります

これらのブロッキングメッセージは避けるべきなので、これが正しい方法かどうか疑問に思っています. このユースケースでそれらを使用することは理にかなっていますか、それとも避けるべきですか? もしそうなら、適切な解決策は何ですか？

先物の作成に関するakka1.1のドキュメントの例では、生成された先物のタイムアウトをプログラムで設定するにはどうすればよいのでしょうか。akka.confでグローバルタイムアウトを調整できることは承知していますが、このコードに対してのみ調整したいと思います。

サンプルコードは次のようになります

この例では、akkaが合計4つのフューチャーを作成するのは正しいですか？

• アクター1、2、および3に送信されるメッセージごとに1つ
• これらの3つの未来を包むもの

最初のケースでは、タイムアウトを変更するのは簡単です。

しかし、どうすればラッピングフューチャーのタイムアウトを設定できますか？何か案は？

通常の Scala マップと flatMap は、flatMap がリストにフラット化されたデータの iterable を返すという点で異なります。しかし、Akka のドキュメントでは、map と flatMap は何か違うことをしているように見えますか?

http://akka.io/docs/akka/1.1/scala/futures.html

「通常、これはクイック関数を実行するためのオーバーヘッドがほとんどないことを意味するため、非常にうまく機能します。関数の処理にかなりの時間がかかる可能性がある場合は、これを同時に実行する方が良いかもしれません.そのために flatMap を使用します:"

ここAkka先物でのmapとflatMapの違いは何ですか?