問題タブ [akka-zeromq]

アクター モデルと zeromq を使用するアプリケーションのスケールアップに問題があります。簡単に言えば、ソケットを介して通信する何千ものスレッドを作成しようとしています。Erlang 型のメッセージ パッシングで行うことと同様です。マルチコア/パフォーマンスの理由でそれを行っているわけではありませんが、このようにフレーミングすると非常にクリーンなコードが得られるからです。

哲学的な観点からは、これが zmq 開発者が達成したいことのように思えます。たとえば、http://zeromq.org/whitepapers:multithreading- magic

ただし、実際にはいくつかの制限があるようです。1024 インプロセス ソケットで、「ZMQError: 開いているファイルが多すぎます」というエラーが発生し始めます。TCP では、典型的な「Assertion failed: fds.size () <= FD_SETSIZE」クラッシュが発生します。

inproc ソケットにこの制限があるのはなぜですか? それを機能させるには、アイテムをグループ化してソケットを共有する必要がありました。より良い方法はありますか？

zmq は、この種の仕事には不適切なツールなのでしょうか? つまり、アクターのメッセージ パッシング ライブラリというよりもネットワーク ライブラリでしょうか?

Akka アクターに構造化データを送信する必要がある C++ アプリケーションがあります。私が見つけた最良のオプション (Google、stackoverflow...) は、プロトコル バッファーと ZeroMQ を使用することです。しかし、Scala アクター コードにさまざまなクラッシュ (奇妙な Windows ソケット エラー) が発生し、それを機能させるために 1 日中苦労しました。さらに詳しく調べてみると、少し前に Akka の公式ドキュメントから zeromq が消えたように見え、それについて読んだ最新のドキュメントでは、ZeroMQ 3 はその下の zeromq-scala-bindings によってまだサポートされていないと書かれていました。 （バージョン4はすでに出ていますが）。

Camel-netty 拡張機能を使用し、JSON を介して情報を渡す方が良いオプションでしょうか?

ありがとう ！

次の制御フローがあります。for ループで、文字列の配列を作成します。配列 (文字列) の各行をパブリッシャー関数に送信します。パブリッシャー関数は、文字列を送信することになっています。パブリッシャーが無限ループでパブリッシュしている場合、サブスクライバーがメッセージしか受信しないという問題があります。パブリッシャー関数を継続的に呼び出してデータを送信させることができないのはなぜですか? 無限ループでしか機能しないのはなぜですか?

ここに私のパブリッシャー機能があります:

ここに私のサブスクライバー関数があります:

while(1) ステートメントを削除すると、何も受信されないのはなぜですか?