netmq

0熱

1答えて

ZeroMQパブリッシャーソケット - たとえば、パブリッシャソケット</p> <p>に新しいサブスクリプションのイベントを上げる方法がある場合、私は思っていたサブスクリプション

にイベントを発生させる：もちろん PublisherSocket publisher = new PublisherSocket(); publisher.Bind("tcp://*:5555"); NetMQPoller poller = new NetMQPoller { publisher }; poller.RunAsync(); p

0熱

1答えて

NetMQは、私は簡単なの一つ<a href="https://netmq.readthedocs.io/" rel="nofollow noreferrer">https://netmq.readthedocs.io/</a>に/リクエストソケットの例を受け取り、それが無限ループにparametrizedThreadで作業したかったを取っ

をループしたときに動作していない/レスポンスを受信します。コードは、それが非ブロックソケット操作は、私は上記の最初のループの直後に起こるべきだ何のためにすぐに完了することができませんでした投げた後、いくつかのループのために正常に動作しますランダムではありません。ここの問題は何ですか？クリーンな接続を再開するために、何かを洗い流す必要があるように思えます（わからない）。 class Progr

1熱

1答えて

TCPキープアライブをイベントとして使用する方法はありますか？

接続にTCPを使用しているので、私のアプリケーションの通知ソースとしてキープアライブ信号を使用できるのだろうかと思います。つまり、クライアント側とサーバ側で切断状態（特定のソケット）を検出したいと思います。可能ですか？はいの場合 - それを行う方法？これまでのところ、キープアライブ間隔とMonitorメソッドを設定するオプションが見つかりましたが、通知方法を見当たりません。サーバー側では、クラ

0熱

2答えて

ZeroMQまたはNetMQのルータソケットから送受信するにはどうしたらいいですか？

私はディーラー< - >ルーターの設定でNetMQ v4を使用しています。問題のない方向にメッセージを非同期で送受信できます。私は今、サーバ（ルータ）はすべての着信メッセージをリッスンするが、それはまた、接続されたクライアント（ディーラー）のいずれかに需要ブロードキャストメッセージにする必要があります。抽象化の中にこれを正式なものにしたいです私はサブスクライバがサーバーにもメッセージを送信する

1熱

2答えて

netMQ 4.0マルチスレッド

netMQ 4.0に基づいてマルチスレッドサーバに問題があります。 http://zguide.zeromq.org/cs:mtserverを使用しようとしましたが、netMQ 4.0にはコンテキストがありません。は、私が試した： for (var i = 0; i < workerCount; ++i) { new Thread(() => Worker(connStr.Value

3熱

1答えて

ZeroMQを使用して 'NetMQ.AddressAlreadyInUseException'を解決する方法

このような単純なコードからこの例外がどのように得られたかを説明しましょう。NetMQサーバーを実行しようとしたcAlgoという取引プログラムを使用しました。正しく終了しないため、コンピュータを再起動するまでポートを使用できなくなります。私はこのポートを回復して再び使用できるようにしたいと思います。私はそれをきちんと掃除しようとしました。私はZeroMQから始まっています。私はそれに熟練していませ

0熱

1答えて

ReadyReceive pub-subをNetMQ 4.xを使用して動作させることができません

2つのシンプルなC＃コンソールプロジェクト（.net 4.5.2）を作成し、それぞれにv4.0.0.1 NetMQ Nugetパッケージを追加し、 Visual Studio 2017 Community Editionでは、OnReceiveReadyコールバックメソッドに含まれる1行にブレークポイントを設定し、最初にサブスクライバプログラムを起動し、次にパブリッシャプログラムを開始しました。

0熱

1答えて

NetMQ pub-subパターンがReceiveReadyで動作するようにすることができません

私はNetMQ（3.3.3.4）で手を加え、パブサブパターンを作成しています。 1つのポート（9000）のすべての受信データをリッスンし、別のポート（9001）のすべてのクライアント/サブスクライバにデータを転送する必要があります。クライアントはその後、9000でデータを送信し、私は以下のコードのようなものを作成したドキュメントに続き9001 に（誰で）送信されたすべてのメッセージを受け取り、私

2熱

1答えて

各フレーム/メッセージに新しいバイト配列を作成しないようにカスタムバッファで受信するNetMQ APIとは何ですか？

私は次のコードを持っている：私は何をしたいか while (!isCancellationRequested) { byte[] frameBytes = socket.ReceiveFrameBytes(); MyData data = new MyData(); data.Deserialize(frameBytes); // send the dat

1熱

1答えて

MonoのNetMQ DealerSocketがDebian Wheezyのサーバにメッセージを送信しないのはなぜですか？Windowsではですか？

Debian WheezyのMono 4.8でNetMQ 4.0.0.1に問題があります。ここでディーラーソケットは新しいメッセージを送信するための呼び出しを停止しない限り、メッセージを送信しません。私が置くときThread.Sleep(1000)の間にすべてよりもタスクを作成することはOKです。私はすべてがThread.Sleep()なしで.Net Framework 4.5と.Net Cor