問題タブ [akka]

Akka で金融データ配信サーバーを開発しましたが、アプリケーションのログレベルを設定したいと考えています。akka.io のドキュメントはせいぜい大ざっぱです。彼らは、Akka にはもはや「ロギング」がなく、ロギングはイベント ハンドラを通じて定義されていると言っています。ログレベルを含むイベントハンドラー構成の例もあります。

私はそれを行いましたが、akka.conf は正常に読み込まれましたが、ログはまだ「DEBUG」レベルにあるようです。そこで何が問題になる可能性がありますか？

Akkaでは、RPCスタイルのプログラミングモデルを使用する「型付きアクター」APIを使用する以外に、アクターへのメッセージを特定の静的タイプに制限する方法はありますか？

アクターの境界で静的型の安全性を捨てることなく、Akkaでメッセージパッシングスタイルを使用できますか？

たとえば、次のようなコードを使用したいと思います。

おそらく、いくつかの基本特性を拡張するかEither、システムレベルのメッセージ（Exitなど）を許可するような構造を持たなければならないでしょう。

Akkaに相当するものはありますが、.NET用ですか？

http://doc.akka.io/use-cases

エンドレス ストリームからアイテムを消費するアクターを設計しており、メッセージの使用を開始および停止するタイミングを制御する方法が必要です。このような中断可能なループをアクターで実装するための一般的なパターンはありますか? アクターに自分自身にメッセージを送信させることだけを考えていました。（疑似Scala）のようなもの：

これは物事を進めるための最良の方法ですか？

ありがとう！

私はアクター ベースのプログラミング モデルを、Microsoft のC++ 用非同期エージェント ライブラリで使用しています。Scala の実験を始めたので、そのモデルは非同期エージェントほどリッチではないように思えます。たとえば、非同期エージェントは、エージェントのネットワークを作成するためにさまざまな方法で組み合わせることができる、さまざまな非同期メッセージ ブロックを多数提供します。これは、Scala のネイティブ アクター、または Akka を使用するアクターにどのようにマッピングされますか?

JMS の代わりに Scala のアクターを優先する設計上の決定は何ですか?の質問と回答を既に読みました。.

通常、私たちは何年も前から存在するメッセージング ソリューションを使用します。WebSphere MQ や Apache ActiveMQ などの JMS 実装がポイント ツー ポイント通信に使用されるか、Tibco Rendevous がマルチキャスト メッセージングに使用されます。

それらは非常に安定しており、実績があり、高い可用性とパフォーマンスを提供します。それにもかかわらず、構成とセットアップは Akka よりもはるかに複雑に見えます。

前述の製品 (WebSphere MQ または ActiveMQ) がこれまで正常に使用されてきた場合に、いつ、どのような理由で Akka を使用する必要がありますか? 今後のプロジェクトで WebSphere MQ や Tibco RV の代わりに Akka の使用を検討する必要があるのはなぜですか?

そして、いつAkkaを避けるべきですか？他のソリューションと同じ高可用性とパフォーマンスを提供しますか? それとも、Akka を他のメッセージング ミドルウェアと比較することさえ悪い考えですか?

JVM 環境には、JMS (ポイントツーポイント)、TibcoRV (マルチキャスト)、Akka 以外に検討すべき別のメッセージング ソリューションがあるのではないでしょうか?

CorePoolSizeが100に設定されたワークスティーリングディスパッチャーを共有する100の実行中のアクターのアクタープールがあります。しかし、アクターの1つに19のメッセージを送信すると、19のメッセージが19のアクターに並列化されず、実行中のメッセージは5つだけになります。並行して。これらの5つのメッセージが終了すると、次の5つのメッセージはこれらの同じ5つのアクターによって再度処理されます。19個のメッセージが並行して実行されないのはなぜですか、ここで何が欠けていますか？

私のコードは基本的に次のようになります。

出力：

編集：私はAkka1.0を使用しています

Typed Actors（Java）TypedActorの例に従って、Javaでを実装しようとしています。しかし、私は苦労しています。、を追加しましたが、それだけでは不十分でした。Eclipseでエラーが発生したので、ビルドパスにも追加しました。akka-actor-1.1-M1.jarakka-typed-actor-1.1-M1.jarscala-library.jaraspectwerkz-2.0.jaraspectwerkz-core-2.0.jar

TypedActorをカスタムコンストラクターで使用しようとしています。

しかし、コンパイル時にエラーが発生します。

これが私のコードですBaseActor：

私interfaceのサービス：

そしてテストクラス：

例では、彼らは次のように書いています。

しかし、それはJavaではないと思いますclassOf[Service]。Scalaのように見えます。

TypedActorカスタムコンストラクターを使用してを実装するにはどうすればよいですか？

ここに隠された Akka を使用したアプリケーション設計に関するより広範な問題があると思いますが、「カーネル」または「トップ」スーパーバイザーが他のスーパーバイザーである子を監督するスーパーバイザー ツリーをどのようにセットアップするかをお尋ねします。

AKKA永続性モジュールは非推奨になっているため、Java APIを使用してMySQLでAKKAを使用するにはどうすればよいですか？