zeromq

1熱度

1回答

我想保持我的服務器和客戶端（android應用程序）之間的持久連接，以便我可以將數據從服務器推送到我的客戶端。經過一番搜索之後，我發現最好的方法就是WEB SOCKET。但在此兩種情況：首先是，我需要一些數據（命令），如廣投送到我的一些客戶（不是全部），然後聽他們的答覆。其次是，我需要向一些客戶發送通知。這就像聊天室，有一個普通的房間，該消息可以在房間每個人都和一些私人房間消息可以只是誰參加聊

0熱度

1回答

爲什麼zmq_stream客戶端需要recv四次才能獲取實際數據？

端口9070是簡單的HTTP服務器（無ZMQ TCP）我有一個問題：爲什麼第二recv的是0？它來自哪裏？感謝您的幫助 void test_stream_to_tcp() { uint8_t id [256]; size_t id_size = 256; uint8_t buffer [256]; void *ctx = zmq_ctx_new();

1熱度

1回答

netMQ或者zeroMQ如何決定發送

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

1熱度

1回答

PHP ZMQ擴展：無法加載動態庫

我正在使用Windows 10上的Wampserver。我正在使用名爲ZMQ的擴展。我從以下網址下載了DLLS： https://pecl.php.net/package/zmq/1.1.3/windows 我以前使用PHP 5.6的擴展版本，它工作。然而，該擴展有一個錯誤，所以我決定升級我的PHP版本到7.0.4並嘗試新版本的擴展。擴展已成功安裝，它出現在phpinfo（）中，但是當我嘗試從

1熱度

1回答

線程「main」中的異常java.lang.UnsatisfiedLinkError：Eclipse中的java.library.path中沒有jzmq

Import org.zeromq.ZMQ; - 對於上面的導入語句，我在由ZMQ.java文件組成的jzmq master文件夾中使用「org文件夾」。所以，編譯沒有問題。當我開始運行程序，它顯示例外下面異常線程「main」 java.lang.UnsatisfiedLinkError中：在java.lang.ClassLoader.loadLibrary（來源不明）在的java.libr

0熱度

1回答

零拷貝接收和郵件大小

當使用零拷貝進行接收時，有沒有一種方法可以查詢接收到的郵件的大小？有了這個，我（努力）實現零拷貝： zmq_recv(sock, buf, sizeof(buf), 0); 我也試過： zmq_msg_t msg; zmq_msg_init_data (&msg, buf, sizeof(buf), nullptr, NULL); zmq_msg_recv(&msg, sock, 0);

0熱度

1回答

瓶頸和ZeroMQ

我正在玩zeromq酒吧/子消息發送到瀏覽器與WebSocket。下面的「作品」中，通過websocket發送消息。然而，試圖重新加載頁面只是掛起，因爲我猜while True循環被阻止。我認爲gevent.sleep()調用將允許上下文切換，但顯然不是。任何想法如何讓所有這些部分一起工作？ import zmq import json import gevent from flask_so

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

3熱度

1回答

ZeroMQ：許多工人和一個主人的負載均衡

假設我有一個主進程將並行處理的數據分開。假設有1000個數據塊和100個節點來運行計算。是否有某種方法可以使REQ/REP保持所有員工的工作繁忙？我試過在指南中使用負載平衡器模式，但使用單個客戶端時，sock.recv()將阻塞，直到它收到工作人員的響應。以下是代碼，稍微修改了zmq指南中的負載均衡器。啓動一名客戶，10名員工，以及中間的負載均衡器/經紀人。我怎樣才能讓所有那些同時工作的員工？

0熱度

2回答

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

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