問題タブ [nanomsg]

複数のソースからのメッセージを待っている間にブロックするメイン ループを作成するにはどうすればよいですか? 私が理解しているように、イベント処理ループを記述する好ましい方法は、イベントを待っている間にブロックすることです。

ただし、メッセージが複数のソースから送信される可能性がある場合、ブロックを正しく処理するにはどうすればよいでしょうか?

ユーザー入力イベントと nanomsg 経由で送信されたメッセージの両方に応答する GTK GUI を書きたいと思います。

GTK では、 を呼び出すgtk_main()か、ブロックしない方法で を使用して、そのイベントを処理できますgtk_main_iteration_do (FALSE)。

Nanomsg は、メッセージをポーリングするだけでなく、ブロッキング モードまたは非ブロッキング モードでメッセージを受信できます。

ソースが最初に利用可能な「ブロック解除」を入力するまで、何らかの方法でブロックすることは可能ですか? sleepつまり、すべてのイベントに応答し続けるものを使用する代替手段はありますか?

調査員の回答パターンを書こうとしています。しかし、それはエラーをスローします:

nanomsg.NanoMsgAPIError: この状態では操作を実行できません

このパターンを Python で実装するにはどうすればよいですか?

一種のインスタント メッセージング システムを構築する必要があります。私の簡単な調査によると、ZeroMQ と nanomsg は、100K を超えるエンド ユーザー クライアント接続を同時に管理するのではなく、バックエンド分散システムでのサーバー間通信を目的としています。それは正確ですか？もしそうなら、クライアントの数に応じて適切に拡張できる、C の優れたメッセージ パッシング ライブラリはありますか? メッセージは、サーバー -> クライアントのプッシュとクライアント -> サーバーの要求/応答の混合になります。

要求/受信に nanomsg を使用していますが、Makefile を使用してコンパイルすると、コードは正常に動作します。ただし、cmake を使用しようとすると、問題なくコンパイルされますが、メッセージを送信しようとするとセグメンテーション違反が発生します。

誰が何が起こっているのか知っていますか？問題が私の cmake ファイルにあるのか、.cc ファイルにあるのかもわかりません。

これは最小限の作業例です。

request.cc (その .h ファイルはここでは省略されています)

request_test.cc

受信機.cc

動作する Makefile:

動作しない CMakeLists.txt:

Q1:ここで説明されているデフォルトのプロセス間通信と比較して、子プロセスにメッセージを送信するために使用することの違いは何ですか?ZeroMQ

Q2: プロセスから子への直接的なコミュニケーションとして、どちらがより適切ですか? (より速く)

Q3: ドキュメントには次Creates an IPC channelのように書かIPCれています。TCP? ソケット？

単一のサーバーと複数のクライアントを持つネットワーク アーキテクチャを作成しようとしています。クライアントはいつでも接続および切断できるため、クライアントの存在またはシャットダウンをサーバーにアナウンスする必要があります。サーバーは、特定のクライアントにデータを送信できなければなりません。

これに使用する最適なスケーラビリティ プロトコル/アーキテクチャは何ですか?

現在、クライアントが「ログイン」および「ログアウト」できるようにREQ/を使用し、サーバーがすべてのクライアントにデータを送信できるようにソケットを使用しています。送信されるメッセージには、メッセージを処理する特定のクライアントの ID が含まれています。REPSURVEY

これでいいですか、それとももっといいものがありますか？

不必要な雑談を発生させずに水平方向にスケーリングする能力について、さまざまな pub/sub メッセージング プロトコルを評価しようとしています。

私のアーキテクチャには、Web ソケット クライアントが接続された NodeJS サーバーがあります。一貫性のあるハッシング ベースのルーターを使用して、クライアントがサブスクライブすることに関心のあるトピックに基づいて、クライアントをサーバーに誘導することを計画しています。これは、特定のトピックについて、サーバーのサブセットのみがそのトピックにサブスクライブするクライアントを持つことを意味します。その後、メッセージは pub/sub ブローカーにパブリッシュされます。pub/sub ブローカーは、そのデータをサブスクライバーを持つサーバーにファンアウトする役割を果たします。

私が避けたい状況は、すべてのブローカーがすべてのリクエストを受け取り、ネットワークが飽和状態になる状況です。これは、Redis Pub/Sub のスケーリングに関する明らかな問題です。サーバーを追加しても、n 個の正方形の問題が発生することはありません。

pub/sub プロトコル上のクライアントの数は、サーバーの数になります。理想的には、不要なネットワーク帯域幅を回避するために、各サーバーが複数の NodeJS プロセスにデータを効率的にファンアウトするローカル ブローカーを持つことができます。ほとんどの場合、特定のトピックについて、すべてのサブスクライバーが同じサーバー上に存在します。

この種のトピックベースのデータ伝播を提供する pub/sub プロトコルはどれですか?

私が評価しているプロトコルは、MQTT、RabbitMQ、ZMQ、nanomsg です。これは包括的ではなく、SAAS オプションは受け入れられます。

品質保証の制約は簡単です。多くても 1 回、または少なくとも 1 回で十分です。承認は重要ではありません。イベントの順序は重要ではありません。私たちは、水平方向のスケーラビリティに重点を置いて、ファイア アンド フォーゲットを探しています。