質問

akka-zeromqを使用してzeromqからメッセージを受信する単純なアクターを実装しようとしています。

システムはちょうど印刷します

追加情報

メッセージの送信は単純なPythonを介して行われます

私が気付いたもう一つの奇妙なことは、Enterキーを押した後もプログラムが終了しないことです。Pythonスクリプトを使用してメッセージを送信すると表示されます。完全な出力は次のとおりです。

使用する

libzmqバージョンです3.2.2（Arch Linuxの場合）

これはapplication.conf

私は Mac を使用しており、homebrew を使用して zeromq をインストールしています。アプリケーションに zeromq を使用したいと考えています。zmq.hpp https://github.com/zeromq/cppzmq/blob/master/zmq.hpp をコンパイルしようとしました

しかし、それは失敗しました。エラーが表示されます

"frameworks/zmq/zmq.hpp:377:35: エラー: 予想される ';' 宣言リストの終わりに socket_t (const socket_t&) ZMQ_DELETED_FUNCTION; ^ ; frameworks/zmq/zmq.hpp:379:42: エラー: 予想される ';' 宣言リストの最後に void operator = (const socket_t&) ZMQ_DELETED_FUNCTION;"

なぜこれが起こったのですか？zmq.hpp コードにはエラーは含まれていません。助けてください。

最後に私はこれを行い、うまくいきました。

どうもありがとう。オードリー。

パブリッシャーとサブスクライバーを作成するために順序は重要ですか？パブリッシャーとして機能するアプリケーションAといくつかのクライアントアプリケーションX1-Xn（アプリケーションAのサブスクライバーとして）がある場合、最初にサブアプリケーションを起動し、サブスクライバーとして登録してから、アプリケーションAを起動できますか？これでうまくいくでしょうか、それともアプリケーションAを起動する必要がありますか？

パブリッシャーは正常に作成されましたが、以下を使用してサブスクライバーを作成できませんでした:

次のエラーが発生しました: ActorSystem[System] java.lang.NoSuchMethodError に対して 'akka.jvm-exit-on-fatal-error' が有効になっているため、スレッド [System-akka.zeromq.socket-dispatcher-7] が JVM をシャットダウンしています。 : org.zeromq.ZMQ$Poller.poll(J)J at akka.zeromq.ConcurrentSocketActor$$anonfun$10.apply(ConcurrentSocketActor.scala:180) at akka.zeromq.ConcurrentSocketActor$$anonfun$10.apply(ConcurrentSocketActor.scala: 179) akka.zeromq.ConcurrentSocketActor.akka$zeromq$ConcurrentSocketActor$$doPoll(ConcurrentSocketActor.scala:197) で akka.zeromq.ConcurrentSocketActor$$anonfun$receive$1.applyOrElse(ConcurrentSocketActor.scala:46) で akka.actor. akka.actor.ActorCell.invoke(ActorCell.scala:386) で ActorCell.receiveMessage(ActorCell.scala:425) akka.dispatch.Mailbox.processMailbox(Mailbox.scala:230) で akka.dispatch.Mailbox.run(Mailbox.scala:212) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) at java.lang.Thread .run(Thread.java:722)

どういう意味ですか？

なぜHerokuに存在しないのですか?

アクターが異なる dyno で通信するために、Akka と分散キュー システムを使用したいと考えています。Akka を使用する場合、RabbitMQ は最適なオプションではないようです。これは、基になるキューを気にせずにアクターとシームレスに連携するには多くのトリックが必要だからです。

それにもかかわらず、最良のオプションはDurable Mailboxesのようですが、RabbitMQ: akka-amqp-mailbox を使用します。ただし、最初に設定する必要があります。

Akka を使用して Heroku でシームレスな基礎となるキュー システムを提供する他のオプションは何だと思いますか?

ありがとう！

私は Akka を初めて使用し、MapReduce、Publish-Subscribe などの複数の分散パターンを可能にする小さなフレームワークを構築したいと考えています。Akka のネットワーク プロバイダーとして ZeroMQ を使用できることを確認しましたが、実際にはそれを好みます。

ただし、いくつかのMapReduce の例を見ると、それらはすべてネットワーク用に netty.io フレームワークに依存しています。単一のネットワーク プロバイダー ZeroMQ を使用するために ... このapplication.confなどの MapReduce のサンプル構成で netty io ネットワークを ZeroMQ に置き換える簡単な方法はありますか?

ここで、SmallestMailboxRouter でルーターを作成しました

for ループで 38 個のアクターを作成しました

各アクターはロジックを処理し、スコアとメッセージを返します。onreceive メソッドをオーバーライドしてリストに追加することで、メッセージを受信して​​います

プログラムを複数回実行すると、異なるスコアが得られます。しかし、同じ入力をしているので、常に同じスコアを返す必要があります。

}

ここで standardActorResponse には message と score が含まれます。akkaフレームワークの代わりにforループを使用するだけで同じロジックを使用している場合、一貫した結果が得られます。しかし、akkaではランダムに異なる結果が得られます。たとえば、loginexistence、navigationexistence、alertsexistence ルールなどのルールがあります。これらのルールに 1 つの HTML ソースを指定して、そのソースにログイン、アラート、ナビゲーション リンクがあるかどうかを確認しました。ログインが存在しない場合、ナビゲーションが存在しない場合、akka ルーターとアクターを使用してアラートが存在しない場合があります。しかし、forループを使用すると、常に同じ結果が得られます

誰でも問題を見つけるのを手伝ってもらえますか。私はakka 2.1.4を使用しています

さまざまなテスト ステーションから python スクリプトを実行し、対応する出力パネルに出力を表示する WPF アプリを作成しています. スクリプトを並行して実行するには、タスクを使用していますが、ステーションからスクリプトを並行して実行する場合は、.他のステーションの出力も最初に開始されたステーションに取得しています。次のコードを使用しています。

テスト目的で、Python スクリプトに保持したテスト メッセージに基づいて、このコードの while ループを中断しています。その後、それぞれのステーションで出力を正しく取得できますが、この方法では同期方式でしか実行できません。テストステーションを並行して実行する必要があり、応答をリッスンする必要があるため while ループが壊れてはならないため、これは望ましくありません。