jeromq

0熱度

2回答

考慮以下幾點：一組3個邏輯服務：S1，S2和每個服務正在運行的S3 兩個實例，所以我們有以下進程：S1P1，S1P2，S2P1，S2P2，S3P1，S3P2 一個ZeroMQ經紀人在單個進程中運行，並且可通過所有服務流程一個合乎邏輯的服務，讓我們說S1，發佈消息M1是感興趣的邏輯服務S2和S3。每個邏輯服務只有一個進程必須接收M1，所以我們假設S2P1和S3P2。我曾嘗試以下，但沒有成功：

0熱度

1回答

如何在Android應用程序中創建ZMQ上下文

我想在Android應用程序中使用ZMQ。理想情況下，我應該在應用程序關閉時創建一次和定義上下文（）。但不同的是C++應用程序。 android上沒有main（）函數。基於有關activity life cycle的Google文檔。函數onCreate（），onStop（）可以被多次調用，函數onDestroy（）只能被系統調用。解決方法1：創建/銷燬ZMQ上下文中一個的AsyncTask（

0熱度

1回答

什麼是JeroMQ

使用ZMQueue類的我檢查ZMQueue類的源代碼JeroMQ它實現Runnable接口的樣子： private final Socket inSocket; private final Socket outSocket; public ZMQQueue(Context context, Socket inSocket, Socket outSocket){ this.inSoc

4熱度

1回答

Apache駝峯：連接到ZeroMQ服務器

我試圖連接到ZeroMQ服務器使用apache camel。我正在使用camel-extra項目提供的camel-zeromq組件，但似乎這需要在系統上安裝本地ZeroMQ庫。是否有人知道使用camel-zeromq組件的方法，即不需要安裝這些本機庫？我想這幾乎是不可能的。如果是這樣的話：是否有可能以某種方式這些庫添加到項目中，以避免直接在系統上安裝它們？我看到camel組件的另一個缺點

1熱度

3回答

當socket.bind（）被調用時，應用程序關閉 - Android上的JeroMQ

我是新來的編程與消息隊列一般，我一直在嘗試使用ZeroMQ簡單的Android應用程序。我在單獨的線程中在同一設備上運行服務器和客戶端程序。這是我的Server類： public class ZeroMQServer implements Runnable{ private Handler uiThreadHandler; public ZeroMQServer(Handler uiThre

1熱度

1回答

Jeromq/ZeroMQ服務器（Windows） - 客戶端（安卓）測試

我想用一個簡單的應用程序不工作與Jeromq庫測試。這裏的服務器：進口org.zeromq.ZMQ; public class Server { public static void main(String[] args) throws Exception { ZMQ.Context ctx = ZMQ.context(1); ZMQ.Socket

2熱度

1回答

使用java的異步客戶機/服務器jeromq

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

0熱度

1回答

路由器/代理商代理不傳遞消息

我正在處理分佈式應用程序。該網絡是基於ZMQ（jeromq），這裏是我的架構： N Clients (Dealer socket) <---> (Router) Proxy (Dealer) <---> 1 (Dealer) Reciving Worker <---> N (Dealer) Processing Workers 所以我接收職工在一個單獨的線程

1熱度

2回答

如何在MATLAB中使用jeromq

jeromq是libzmq的Java實現。我有一個從jeromq源創建的.jar文件。但是，我無法從MATLAB中調用jeromq中的類。我用addjavaclasspath和addjavalibrarypath，但我仍然無法使它工作。有沒有人在MATLAB中有一個簡單的工作示例？

0熱度

1回答

Android應用程序掛在subscriber.recv（）

我正在編寫一個接收連續數據流的Android應用程序。我已經成立了像這樣內可運行的連接：現在 Runnable runnable = new Runnable() { public void run() { ZMQ.Context context = ZMQ.context(1); ZMQ.Socket subscriber = cont