pyzmq

0熱度

1回答

嗨我想用ZeroMQ使用呼吸機/工人/接收器模式發送大型數據包。我嘗試添加工人。每次，接收器進程內存使用量都會增加一點。然後它達到在大約6或7的工人一個臨界點，其中呈指數突然存儲器增加，直到它死亡與： > *** error: can't allocate region > *** set a breakpoint in malloc_error_break to debug Assertio

0熱度

1回答

從另一個線程關閉掛zmq套接字

是否有某種方法來關閉一個特定的掛接recv zmq套接字從Python中的另一個線程沒有打破可能正在使用的其他套接字？以下代碼似乎不會退出;更換sock.close()與ctx.destroy()導致其退出，但顯然會摧毀所有插座的情況下： import zmq import time import threading as th ctx = zmq.Context() sock = ctx

0熱度

1回答

多線程和ZMQ經銷商/ REP世界你好不起作用的我所有的代碼（從ZMQ DOC <a href="http://zguide.zeromq.org/py:mtserver" rel="nofollow">http://zguide.zeromq.org/py:mtserver</a>很大程度上啓發）

第一： import zmq import time import sys import threading #SOCKET_NAME = "tcp://127.0.0.1:8000" SOCKET_NAME = "inproc://mysocket" def dealerRoutine(context): socket = context.socket(zmq.DEAL

2熱度

1回答

如何設置一個pyzmq套接字隊列超時

我已經連接了zeromq，「msg_in」已經排隊。如果在這段時間內隊列沒有新消息進入超時設置。如何設置超時。以下是核心代碼 requestDict = {"id":111, "name":"test"} zmqConn.mSocket.send(json.dumps(requestDict), flags=zmq.NOBLOCK) msg_in = zmqConn.mSocket.recv(

2熱度

1回答

結合龍捲風和zmq ioloops：通過同位異常重置連接

當我嘗試按照pyzmq official documentation中所述組合Tornado和pyzmq ioloops時，遇到了一個惱人的問題（雖然不是關鍵）。我有接受來自客戶端（C）REST API請求，並代理他們運行的進程龍捲風（T）服務器雖然ZMQ運輸到另一個進程（Z），做實際工作。 C <-> T <-> Z 如果C關閉連接之前Ž答覆T，Z（龍捲風）輸出一束長異常跡線（見在底部）。

6熱度

1回答

爲什麼在這個例子中gevent.sleep（0.1）是必要的，以防止應用程序被阻塞？

我把我的頭髮拉過來。我試圖找到與zeromq和gevent一起工作的最簡單的例子。我改變了這個腳本來使用PUB/SUB套接字，當我運行它時，'服務器'套接字永遠循環。如果我取消對gevent.sleep（0.1）行的註釋，那麼它將按預期方式工作，併產生到另一個綠色線程，本例中爲客戶端。問題是，爲什麼我需要手動添加睡眠呼叫？我想，當我導入zmq的zmq.green版本時，發送和接收的呼叫是非阻塞的

3熱度

1回答

PyZMQ是否爲每個新客戶端連接創建線程？

我正在使用PyZMQ來創建一個請求/回覆服務器，我試圖找出是否爲每個新的客戶端連接創建一個線程的行爲是由PyZMQ自動處理的。最終，我試圖找出是否需要很長時間回覆的客戶請求將阻止來自所有其他客戶端的請求。通常情況下，我會打電話接受一個Python Socket實例，塊，直到一個新的連接而成，並處理單獨的線程任何新的連接。但是，PyZMQ套接字似乎不支持這樣的工作流程。那麼，在PyZMQ中如何處理

2熱度

1回答

從ZMQ子隊列獲取特定消息

我有一個使用ZMQ的Python消息傳遞應用程序。每個對象都有一個PUB和一個SUB隊列，並且它們相互連接。在某些特定情況下，我想等待SUB隊列中的特定消息，留下我不感興趣的消息以供日後處理。現在，我收到所有消息，並將那些我對Python隊列不感興趣的消息排隊，直到找到我正在等待的消息。但他的意思是，在每個處理路由中，我需要首先在Python隊列中檢查舊消息。有沒有更好的辦法？

2熱度

1回答

同ZMQ_IDENTITY多參保者

我建設有很多用戶的zeromq PUB-SUB模式一個出版商。我想構建持久訂閱者，所以我發現了關於ZMQ_IDENTITy套接字選項。選擇的標識值的時候，我應該怎麼考慮？我可以採取相同的所有用戶？由於它們都是相同的類型，但在不同的機器上，這應該是一個問題，對嗎？此外，UUID是否僅在zguide示例中介紹的vie inproc服務中生成？

9熱度

2回答

ZMQ REP，知道是誰發送請求

我目前在Python中使用zmq。服務器正在使用REP套接字。我有辦法在收到郵件時知道是誰發送郵件嗎？如果收到2條消息，我只需要知道它們是否來自同一個用戶，所以例如uid就足夠了。