zeromq

0熱度

1回答

如果您使用PUSH套接字，您會發現連接的第一個PULL套接字將獲取不公平的消息份額。消息的準確旋轉僅在所有PULL套接字成功連接時纔會發生，這可能需要幾毫秒。作爲PUSH/PULL的替代方案，對於較低的數據速率，請考慮使用ROUTER/DEALER和負載平衡模式。因此，在PUSH/PULL中執行同步的一種方法是使用負載平衡模式。對於低於這個特定的情況下，我不知道是否有另一種方式做到同步：我就

0熱度

1回答

ImportError：沒有名爲zmq的模塊

我已經安裝了zeroMQ，但是當我運行gr-ofdm的示例時，仍然存在「ImportError：No module named zmq」錯誤。 ./run_benchmark_gui.sh ------------------------------------------------------------------------------ Traceback (most recent c

1熱度

2回答

ZeroMQ + ReactPHP：多個生產者（推）和多個消費者（拉）

我使用reactphp/zmq。如何在多個拉動員工中擁有多個推動員工，這可能嗎？一個只能有多重拉動和單推，如自述的例子： $push->connect() $pull->bind() 或單拉和多推： $push->bind() $pull->connect() 當我嘗試設置都爲connect的拉不接收消息。否則，試圖與bind它拋出啓動多個進程： ZMQSocketExcepti

1熱度

1回答

EAGAIN在zeromq上收到REQ/REP而沒有阻塞套接字

我正在恢復生成一個基於zeromq的三年期項目。在編寫代碼（在Ubuntu 14.04上）時，代碼正在工作（據我所知）。現在（ubuntu 16.04和libzmq.so.5）代碼編譯，但zeromq通信出了問題，這讓我發瘋。 zeromq部分是我寫的，所以我知道代碼相當好，也許這就是爲什麼我看不到錯誤。服務器端代碼是相當複雜的，但是我試着堅持相關部分： WorkerServer::Worke

0熱度

1回答

是否可以使用ZMQ代理作爲「開關」？

我要實現如下圖： ZMQ-proxy 只是爲了讓所有的「數據發生器」數據發佈到所有的「數據接收器」。數據接收器應該仍然有能力設置subscritions。 // Proxy package main import zmq "github.com/pebbe/zmq4" func main() { publisher, _ := zmq.NewSocket(zmq.XPUB)

0熱度

1回答

ZeroMQ安裝錯誤用PHP 7.0.0

我運行此命令與MAMP安裝ZeroMQ後具有與ZeroMQ安裝的最後步驟的問題... sudo pecl install zmq-beta Build complete. Don't forget to run 'make test'. running: make INSTALL_ROOT="/private/tmp/pear/temp/pear-build-rootIN0Z6M/ins

0熱度

1回答

無法獲取文件描述符從零MQ ZMQ_SERVER套接字

我想將ZeroMQ ZMQ_SERVER套接字集成到Ubuntu上的C++的epoll事件循環中。不幸的是，我不能讓zeromq API給我一個文件描述符。對我來說，他下面的測試方法產生一個無效參數錯誤： void test_create_zmq_socket() { std::string address = "tcp://127.0.0.1:5558"; void* so

1熱度

1回答

回調函數在實例中看不到正確的值

我在使用回調函數和處理程序的Python中出現了一個奇怪的現象。我使用ZMQ來處理我的通信併爲套接字使用流。我有基類： import multiprocessing import zmq from concurrent.futures import ThreadPoolExecutor from zmq.eventloop import ioloop, zmqstream from z

0熱度

1回答

如何發送不包含字節\ x00的不同長度的消息？

20裏面的message()是什麼意思與20之間的message.data(),在下面的代碼中？ zmq::message_t message(20); snprintf ((char *) message.data(), 20 ,"%05d %d %d", zipcode, temperature, relhumidity); publisher.send(message); 通過閱讀文

0熱度

1回答

zmq和express出錯

我試圖創建一個API來發送由套接字獲取的信息。要從我的套接字獲取信息，我正在使用zmq。這個想法是當從套接字獲得信息時，將這些信息作爲響應發送到我的API中。下面的代碼假裝這樣做。 [...] enclaveSocket.on('message', function (message) { res_json.info = message.toString('base64');