pyzmq

5熱度

1回答

當在python中搜索IPC的高效解決方案時，我偶然發現了zeromq;我有幾個python進程需要對主進程中的字典中的數據進行一些cpu密集處理。這些工作進程只能從字典中讀取，只有主進程可以改變字典。字典中的數據將會改變，但通過主進程原子化。我理想上有一段共享內存，所有的工作進程都可以讀取字典，不幸的是，這似乎不可能在Python中。使用Redis的一樣或記憶快取緩存聽起來有點小題大做（不想

1熱度

1回答

爲什麼zeromq中推/拉的實現不會返回所有消息

我在zeromq中有一個客戶端服務器對。奇怪的是，拉客戶端只接收其他發送的消息。這是我的實現 ## Push Server import zmq def post(): context = zmq.Context() socket = context.socket(zmq.PUSH) socket.bind("tcp://127.0.0.1:3333")

0熱度

2回答

如何關閉被死亡程序打開的套接字？

我對套接字很陌生，對我很裸露。我有一個程序（蟒蛇），在某些點使用 zmq.Context.socket(zmq.REP) 和 zmq.Context.socket(zmq.PAIR) 插座，但問題是，當程序被殺害插座仍然可以使用發現： 'ps aux | grep zmq' 命令。那麼在程序被殺之後我能做些什麼來讓它們消失？

1熱度

1回答

在virtualenv中設置ipython筆記本

我使用的是Ubuntu 12.04 LTS。我嘗試了很多次從virtualenv運行ipython筆記本。它不工作，並出現以下錯誤信息： (ipython-notebook)[email protected]~/dev/virtualenvs/ipython-notebook$ ipython notebook Traceback (most recent call last): Fi

0熱度

1回答

調用zeromq中各方的特定功能

我正在尋找一種從IPC的一側調用特定功能的方法。假定此示例代碼： socket = context.socket(zmq.REQ) socket.connect("tcp://127.0.0.1:8000") socket.send(resp) 我想指定「RESP」將被轉發到的功能，這可能嗎？如果不是，我怎麼能這樣做？

0熱度

1回答

編碼ZMQ

我目前正在做項目，需要從PC到設備的通信，到目前爲止我已經決定了套接字通信。並編寫了一些代碼。我也在設備上使用ZMQ作爲ipc。我的腳本通過跨文本數據發送。我試圖將我的數據編碼爲utf-8，以便它可以在設備上輕鬆讀取並顯示在框架中並根據需要執行任務。然而，我似乎無法得到正確的編碼，我試着在網上搜索示例或教程，但似乎無法找到任何。我試過使用socket.send（msg.encode（「UTF-8

3熱度

3回答

ZMQ - libzmq.so.3：無法打開共享目標文件：沒有這樣的文件或目錄

我想在我的應用程序中嵌入zeroMQ，我跟着this guideline安裝ZMQ，所以在這裏一切正常。我在我的應用程序這行代碼： ZMQ.Context m_context = ZMQ.context(1); ，但上面的代碼行引發異常如下： Exception in thread "main" java.lang.UnsatisfiedLinkError: /tmp/libjzmq-812

3熱度

1回答

IPython Permission Denied

我遇到一個問題，在spyder中啓動ipython筆記本或ipython控制檯，導致錯誤消息「斷言失敗：權限被拒絕（...... \ src \ err.cpp：247）（在ipython筆記本中）內核無休止地重新啓動我在Windows 7上使用了python的Anaconda安裝，並且在ipython 1.1和ipython 1.0中都有同樣的問題我沒有這個問題當我運行ipython 谷歌搜

1熱度

1回答

如何在ZMQ PUB/SUB中獲得貨運代理的冗餘？

我試過並運行了這個example。它工作得很好。我可以根據需要添加儘可能多的發佈者或訂閱者，所有內容都將通過轉發器進行通信。我關心的是冗餘。如果貨運代理商沒有迴應，直到貨運代理商啓動纔會有效。我發現REQ/REP的example，但它不能作爲訂閱者應用於PUB/SUB。但想法在這裏。在pub/sub場景中是否有類似的方法？謝謝。

1熱度

1回答

我該如何修復錯誤：沒有JSON對象可以從zmq DEALER解碼到ROUTER消息？

我有一個DEALER套接字渲染到路由器，一旦消息到達，我無法將其解碼爲json，如果我打印接收到的文本並將其複製到python終端，我可以解碼它，但接收代碼是無法。這裏是代碼發送： self._out_socket = self._out_context.socket(zmq.DEALER) self._out_socket.connect("ipc://testout") self._ou