zeromq

0熱度

1回答

我正在嘗試編寫網絡傳輸應用程序。數據是二進制數據，每個數據包大小大多爲800KB。客戶端每秒產生1000個數據。我希望儘可能快地傳輸數據。當我使用ZeroMQ時，速度達到每秒350個數據，但提升asio每秒達到400（或更多）。正如你所看到的，兩種方法的表現都不好。用於ZeroMQ的模式是PUSH/PULL模式，boost asio是簡單同步I/O。 Q1：我想問一下，是否ZeroMQ只

0熱度

1回答

C＃在線程之間傳遞數據很容易

我目前正在一個項目中接收幀作爲bytearray並將它們顯示在GUI（WPF）上。現在我不滿意這個表現，因爲這些幀會延遲顯示。所以我想到做多線程，以便套接字和GUI工作彼此獨立。但是，如果我嘗試在一個單獨的線程中運行socketRoutine，我得到一個錯誤，一個線程不能訪問另一個線程的資源。林不知道哪個資源是指。我猜它可能是傳遞給GUI的bytearray或其必須訪問的GUI組件。這些是我

3熱度

1回答

ZeroMQ錯誤：未知類型名稱「zctx_t」

我嘗試按照此鏈接中的教程：http://hintjens.com/blog:49安裝ZeroMQ和運行一個簡單的例子如下： #include <czmq.h> int main (void) { zctx_t *ctx = zctx_new(); void *publisher = zsocket_new (ctx, ZMQ_PUB); zsocket_set_c

1熱度

2回答

ZeroMQ可以計算未完成消息的數量嗎？

我是ZeroMQ新手（在C++上）。？br：寫程序時用PUB/SUB正式通信模式原型，我困住了一個問題。計劃：這是我的項目，在這裏我想給儘可能多的信息發送到PUB。爲此，我曾使用一個ROUTER套接字類型。問題：接收機是緩慢的，由於該消息被排隊得到（直至到達高水印）和在這之後，開始丟棄上SUB側。尋找：我想從ZeroMQ（對C++）的方法，該告訴我了「傑出隊列中的消息計數」。搜索

0熱度

1回答

使用py2exe使用zmq編譯腳本

我有一個使用zmq的python 2.7腳本，我試圖使用py2exe爲它構建一個windows可執行文件。我得到以下錯誤： Traceback (most recent call last): File "console.py", line 4, in <module> File "zmq\__init__.pyc", line 34, in <module> Fil

0熱度

1回答

Python自動查找ZMQ服務器

我正在使用ZMQ來方便一臺服務器和多個客戶端之間的通信。有沒有一種方法讓客戶端自動找到ZMQ服務器，如果他們在同一個內部網絡上？我的目標是讓客戶端能夠自動檢測它應該連接的IP和端口。

3熱度

1回答

只有在訂閱主題時，ZeroMQ Pub/Sub纔會丟棄郵件

僅在訂閱主題時纔會丟失郵件。這裏是場景：用戶訂閱特定的主題，然後在不同的線程（具有相同的上下文和相同的「訂閱的主題」）調用發佈者。發佈者收到「訂閱的主題」併發布它。當我運行兩個過程（意味着2個訂閱者線程和2個發佈者線程）時，我只在其中一個線程（隨機）上收到一條消息。我不知道爲什麼我失去了第二條消息。出版商螺紋： void *publisher = zmq_socket(ptStruct-

2熱度

1回答

Node.js - NPM包zmq vs zeromq

我發現這兩個ZMQ的綁定Node.js.看起來，兩者都提供了一個等效的API。有誰知道優點和/或缺點？ https://www.npmjs.com/package/zmq https://www.npmjs.com/package/zeromq

1熱度

1回答

如何反序列化從Google protobuf以Java接收的字節？

我想反序列化從ZeroMQ收到的谷歌protobuf消息，並試圖轉換爲JSON格式，使用下面的一段代碼。但在最終輸出中，定義爲字節的字段是不可讀的。（例如，"source_id": "\u0000PV\uff98t\uff9e"）。由於它是機器生成的數據，我們沒有從源發送的實際值。 InputStream is = new ByteArrayInputStream(message.getByt

1熱度

1回答

什麼是工作XSUB/XPUB代理的zeromq

一個簡單的例子，我有一個後續How to implement Pub-Sub Network with a Proxy by using XPUB and XSUB in ZeroMQ(C++)? 這個問題請使用XSUB和XPUB一個C++代理。給出的答案基本上是下面引用的代理main（）函數。我將此代理擴展爲包括髮布者和訂閱者的完整工作示例。問題在於我的代碼只適用於經銷商/路由器選項（如下面的