zeromq

2熱度

1回答

我正在使用0.4.0版本jeromq，我試圖使用下面的示例從這個link，但它給這條線ZMQ.poll(items, 10);編譯錯誤。它看起來像在jeromq的最新版本中發生了變化，但文檔和代碼尚未更新。任何人都可以幫助我瞭解如何使我的下面的代碼適用於jeromq的最新版本。 <dependency> <groupId>org.zeromq</groupId> <arti

0熱度

2回答

帶有zmq的pub-sub的動態主題，那會好嗎？

我讀過我的文檔大多數例子都是基本用例。只需一個進程發佈X事件，另一個進程訂閱X事件。但在我的應用程序中，X是一種變量。所以我們可以說我的X代表我的用戶。所以我可以做一個像user-ID這樣的服務器事件發佈意味着如果我有1000個用戶連接到服務器，那麼可以發佈和訂閱這麼多的動態主題，然後另外20個服務器訂閱這1000個這個服務器上的主題。讓我們看看這個例子。我有10臺服務器。每個服務器連接

1熱度

1回答

ZeroMQ vs OpenMPI

有人可以提供什麼更好，哪些情況？我有一些ZeroMQ的經驗（不是很多），沒有OpenMPI的經驗。我知道這兩個都是消息傳遞的框架。這兩個框架的主要區別是什麼？

2熱度

1回答

與IJulia搭建錯誤

我曾經在Jupyter筆記本中使用Julia。我昨天卸載了.julia目錄，因爲有其他問題，之後Pkg.add(IJulia)我得到了一個與ZMQ相關的建築錯誤。完整的錯誤在下面。 julia> Pkg.build("ZMQ") INFO: Building Homebrew Already up-to-date. INFO: Building ZMQ Warning: staticflo

1熱度

1回答

python3 ASYNCIO ZeroMQ .connect（）塊

我嘗試實現REQ/REP格局，python3 ASYNCIO和ZeroMQ 我的客戶異步功能： import zmq import os from time import time import asyncio import zmq.asyncio print ('Client %i'%os.getpid()) context = zmq.asyncio.Context(1)

0熱度

1回答

ZeroMQ上下文未在Windows Server 2012機器上初始化

我正在使用ZeroMQ與clrzmq和libzmq dll文件的組合。我已將這些文件包含在我的Windows服務項目中，並且它在簡單的Windows PC中工作正常。現在，我將服務移至Windows Server 2012計算機，並在其中安裝了具有管理員權限的服務並嘗試啓動ZMQ服務器。所有嘗試啓動服務器都失敗，出現以下錯誤。我的代碼 public void InitializeServer

1熱度

1回答

高速公路JS訂閱管理

我設立我們的客戶和我們之間的博客，使他們能夠有一個空間說說不同的商業交易（每個商業交易具有參考號碼，有它自己的信息）。現在我能夠與ZeroMQ和高速公路設置棘輪實現這一目標。每當用戶更新博客時，其他訂閱他們的用戶都會將信息推送到他們的瀏覽器中。不過，我有一個鏈接到一個按鈕，在主頁上的訂閱方法。（整個想法是，他們將點擊左側菜單欄上的參考，博客條目將出現在屏幕的右側）。這是什麼引起的，如果用戶

1熱度

1回答

使用ZMQ進行雙向線程間通信

我是ZeroMQ的新手。我花了幾個月的時間閱讀文檔並在圖書館進行實驗。我目前正在開發一個多線程的C++應用程序，並希望使用ZeroMQ而不是互斥體在我的主線程和它的一個子線程之間交換數據。子線程正在處理與外部應用程序的通信。因此，我需要在主線程和它的子進程之間進行排隊/套接字。一個用於傳出消息，另一個用於傳入消息。我應該使用哪個zmq套接字來實現此目的。在此先感謝

0熱度

1回答

ZeroMQ Simple Broker

我正在嘗試做一個簡單的代理（即星型拓撲），它允許任何DEALER節點與其他連接到代理的其他DEALER節點進行通信。這是當前設置： // Simple broker #include <string> #include <zmq.hpp> #include <zhelpers.hpp> using namespace std; int main() { zmq::cont

1熱度

2回答

從無盡的數據循環的Python燒瓶網站？

我已經使用Flask構建了一些網站，其中包括一個使用websockets的網站，但這次我不確定如何開始。我目前在Python中有一個無限循環，它從ZeroMQ套接字獲取傳感器數據。它大致是這樣的： import zeromq socket = zeromq.create_socket() while True: data_dict = socket.receive_json()