問題タブ [netmq]

典型的な pub sub パターンでは、イベントを発行するサーバーにサブスクライブするクライアントがいます。私のアプリケーションでは、パブリッシャーは非同期的に発生するイベントを継続的にパブリッシュします。私のクライアントでは、これらのイベントの処理が遅れることがあります。私の質問は、受信したすべてのイベントを順番に処理するのではなく、クライアントがパブリッシャーから送信された最新のイベントを常に取得するという回避策があるかどうかです。

F# のドキュメントがなく、C# のみのライブラリを使用しています。C# に慣れていないので、少し問題があります。NetMQのドキュメントを読んでいると、翻訳に問題がある行が 1 つあります。

コンテキストについては、完全な例を次に示します。

rep1.ReceiveReady += (s, a) =>具体的には、C# のコンテキストで何を意味するのか、F# に翻訳する方法がわかりません。何か案は？ありがとう。

数か月前、ZeroMQ 通信の実装に使用する .NET ライブラリを選択していましたが、zeromq.orgで提案されているライブラリがほとんどないという事実にかなり混乱しました。

その間、私はいくつかのことを学んだので、ここで共有します。誰かがこれが役立つと思うかもしれません。では、次のように自問してみましょう。

NetMQ と clrzmq の違いは何ですか?

（私はこれに自分で答えますが、他の誰かがこの件について何らかの経験を持っている場合-別の答えは大歓迎です！）

XPUB/XSUB パターンのハブを NetMQ + コントロール ソケット (ハブの動作を制御するため) で実装しようとしています。プロキシ、NetMqPoller を使用しており、制御ソケットを使用したい。しかし、私が何をしようとしても、うまくいきません。ここに私のコードがありますが、それが機能しない理由はありますか?

また、ctrlIn ソケットがデータを受信するたびに実行されるメソッドもあります。

簡単な説明: ハブ (XPUB/XSUB) は完全に機能します。つまり、パブリッシャーとサブスクライバーを開始すると、メッセージが流れるのがわかります。しかし、制御ソケットは機能しません。2 つのメッセージしか表示されません。

その後、制御ソケットはサイレントのままになり、それ以上のバイトフローはありません。誰かが私がどこで間違っているか知っていますか? または、誰かが実際の例を指摘できますか? 例を探していましたが、制御ソケットが機能しているものは見つかりませんでした。

簡単な要求と応答を使用して、c# (クライアント) と python (サーバー) を相互に通信させることができます。ただし、c# asp.net で構築した Web アプリケーションを安定させ、より多くのクライアントとサーバーを必要とするため、Extended REQ-REP 接続を使用して c# と python を接続してみました。

しかし、以下のコードを実行すると、ブローカーとしての役割を果たさず、何も出力しません。ここで何が間違っていますか？

5600 = C# クライアント

5601 = Python サーバー

C++ のサーバーと C# クライアントの 2 つのアプリケーションを通信する必要があります。

サーバーで 0MQ とバインダー C# NetMq を使用しようとしています。クライアントから接続して、クライアントからサーバーにメッセージを送信できますが、他のサーバーには送信できません。クライアントは待機し、サーバーによる送信を受信しません。

いくつかの例？

サーバ：

クライアント：

これは、実装してから拡張しようとしている送信と応答の簡単な例です。

私は次のパターンを持っています:

複数のスレッドが、メッセージをRouterに送信するために単一のスレッド化されたDealerによってポーリングされる ConcurrentQueue にメッセージを送信しています。

複数のメッセージが送信されると、次の例外が発生します。

「SocketException - 非ブロッキング ソケット操作を完了できませんでした」

メッセージをデキューしてディーラーに送信するスレッドのコードは次のとおりです。

MultipartMessage の送信時に SocketException が発生しました

SendBuffer のサイズや SendHighWatermark のサイズを大きくしようとしましたが、それでも同じエラーが発生します。

この例外を処理してソケットをリセットする必要がありますか?

クライアント - サーバー通信を実行するために NetMQ ソケットを使用しています。ポート5555をリッスンする単一のサーバーと、.bind()それに-sするクライアントがあります。

これが私のコードサンプルです:

私がやりたいことは、クライアントがそのポートをリッスンしているサーバーを見つけられない場合にユーザーに通信することです。

実際に起こっていることは、そのポートをリッスンしているサーバーがない場合、例外は発生せず、.sendFrame()が呼び出されてアプリケーションがクラッシュするということです。

例外や状態コードなど、接続が成功したかどうかを通知できる方法はありますか?

要求 (フレーム) B を送信して応答を受信すると同時に、前の要求 (A) に対する応答を既に待機している場合、B タスクで受信した応答は、実際には要求 A に対する応答です。

単純なマッチングでは、ポイント (*) でマッチング リクエスト A--レスポンス B を取得します。

では、それらを同期させる方法は? つまり、リクエスト A をレスポンス A で終了させ、リクエスト B をレスポンス B で終了させたいと考えています。記録のために、私はディーラールーターソケットを使用しています。

Dictionary送信された各リクエストにタスク完了トークンがバインドされたプール リクエスト ( ) を作成することを考えています。タスクはプールに新しいスロットを作成し、リクエストを送信して完了を待ちます。バックグラウンドでは、常に実行されているタスク (レシーバー) があります。これは単に応答を受信し、各応答を適切なスロットに配置し、指定されたタスク トークンを完了として設定します。私は正しい道を進んでいますか、それとも間違っていますか、それともすでに NetMQ に実装されていますか?