netmq

2熱度

1回答

什麼是NetMQ API在自定義緩衝區中接收以避免在每個幀/消息上創建新的字節數組？

我有以下代碼： while (!isCancellationRequested) { byte[] frameBytes = socket.ReceiveFrameBytes(); MyData data = new MyData(); data.Deserialize(frameBytes); // send the data somewhere som

0熱度

1回答

IQbservable <>需要組裝已經在項目

使用面向.NET 4.5的項目，我有一段代碼，這是否 public static IObservable<string> Receive(SubscriberSocket subp) { return Observable .Create<string>(o => Observable.Using<string, SubscriberSocket>(() =>

1熱度

1回答

netMQ或者zeroMQ如何決定發送

其客戶端的代碼是在這裏： using (var server = new ResponseSocket()) { server.Bind("tcp://*:5555"); while (true) { var message = server.ReceiveFrameString(); Con

0熱度

1回答

如何確定客戶端套接字的連接狀態？

我正在使用NetMQ套接字來執行客戶端 - 服務器通信。我有一臺監聽端口5555和一臺客戶端的服務器，即.bind() -s。這裏是我的代碼示例： using (NetMQContext ctx = NetMQContext.Create()) { using (var client = ctx.CreateRequestSocket()) {

0熱度

2回答

如何同步客戶端的發送幀和接收幀？

如果我發送請求（幀）B並接收響應，同時我已經在等待前一個請求（A）的響應，那麼B任務中接收到的響應實際上是A請求的響應： request A sent request B sent request B processed (quick) response B sent response B received (*) ... request A processed (slow) res

1熱度

1回答

REQ/REP模式中的ZeroMQ FiniteStateMachineException

我有兩個簡單的組件，它們應該使用REQ/REP ZeroMQ模式相互通信。服務器（REP插座）使用pyzmq用Python實現： import zmq def launch_server(): print "Launching server" with zmq.Context.instance() as ctx: socket = ctx.socket(zmq

0熱度

1回答

NetMQ接收/響應循環不工作

我拿了https://netmq.readthedocs.io/上的一個簡單的接收/請求套接字示例，並希望使它在無限循環中與parametrizedThread一起工作。代碼工作正常幾圈後，它拋出非阻塞套接字操作無法立即完成了什麼，我得到了上面應該在第一循環結束後立即發生而不是隨機的。這裏有什麼問題？這聽起來像是必須刷新才能再次獲得乾淨的連接（不確定）。 class Program {

1熱度

1回答

有沒有辦法將TCP keepalive用作事件？

由於我使用TCP進行連接，我不知道是否可以使用保持活動信號作爲我的應用程序的通知源。即我想在客戶端和服務器端檢測斷開狀態（對於給定的套接字）。可能嗎？如果是 - 如何做？到目前爲止，我找到了設置保持活動時間間隔和Monitor方法的選項，但我沒有看到如何通知它的方法。在服務器端，我想知道哪個客戶端死了當然。

0熱度

2回答

如何在ZeroMQ或NetMQ中從路由器套接字發送和接收數據？

我有一個經銷商< - >路由器設置在NetMQ v4我可以在任何方向異步發送和接收消息，沒有問題。我現在要正式到這一點抽象，其中服務器（路由器）監聽任何進入的消息，但它也需要按需廣播消息到任何連接的客戶端（經銷商）的。我試圖避免使用Pub < - >子套接字，因爲我需要訂戶也發送消息到服務器。我試圖實現的最接近的模式是WebSocket客戶端 - 服務器通信。聽取客戶端的消息的第一部分是在像

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)).Start(); } //... pri