pyzmq

0熱度

1回答

我想用pubm/sub模式使用python zmq。我在客戶端面臨一個奇怪的問題。在客戶端，我使用pyzmq，gevent-websocket和bottle作爲wsgi服務器。儘管它適用於一個客戶端，但其他客戶端正在等待第一個客戶端斷開連接。在與一個客戶端合作時，如果我斷開並重新連接，則每次重新連接都會收到兩次或更多的消息。 #!/usr/bin/python from gevent impor

0熱度

1回答

Python龍捲風 - 如何在不停止循環的情況下創建阻塞呼叫？

我正在使用ZMQ流，這些流基於他們自己實現的龍捲風IOLoop。我遇到了一個想要有同步行爲的問題，但IOLoop迫使我進入異步執行。以下是具體情況：我有一類是對相機設置全權負責（相機在不同的進程）： class HamSettingsManager(object): ''' This class makes sure the camera is set to the req

3熱度

1回答

發送NULL消息在PyZMQ

我想翻譯下面的示例HTTP服務器基於0MQ寫在C看到這裏：Hintjens' blog到Python。 def test_http_socket(): ctx = zmq.Context() sock = ctx.socket(zmq.ROUTER) sock.setsockopt(zmq.ROUTER_RAW, 1) sock.bind("tcp://*:

3熱度

2回答

ZeroMQ：在推動HWM不起作用

我想寫一個服務器/客戶端腳本與通風任務的服務器，以及執行它的多個工作人員。問題是，我的呼吸機有太多的任務，它會填滿內存中的心跳。我試圖在綁定之前設置HWM，但沒有成功。只要工作人員連接，它就會一直髮送消息，完全忽略所設置的HWM。我也有一個接收器，可以記錄完成的任務。 server.py import zmq def ventilate(): context = zmq.Cont

3熱度

1回答

難以理解Majordomo API，pyzmq-mdp的工作原理

我正在尋找使用Majordomo API，pyzmq-mdp。在客戶端的存儲庫中的example，我不太明白。在myclient.py中，該示例手動創建一個套接字，而不使用MDPClient API。更糟糕的是，使用mdp_request方法發出請求。但我到目前爲止嘗試過： class Client(MDPClient): def on_timeout(self): pr

0熱度

1回答

如何在單個實例運行REP和PUB非阻塞Pyzmq

我的對象： class mysrv(object): def __init__(self): self._pubsocket = context.socket(zmq.PUB) self._socket = context.socket(zmq.REP) self._socket.bind("tcp://127.0.0.1:9003") s

1熱度

2回答

ZMQ軟件與語言綁定的區別

ZMQ軟件（可在http://zeromq.org/intro:get-the-software處獲得）和語言綁定有什麼區別？由於我已經安裝了語言綁定和我的例子工作正常（用python編寫），那麼ZMQ軟件的用途是什麼？

1熱度

2回答

zmq呼吸機/工人/水槽範例不工作瓦特/子流程

我想複製ZMQ指南中描述的呼吸機/工人/水槽範例。我擁有與ZMQ示例中描述的相同的Python呼吸機，相同的C++工作人員以及相同的Python接收器。我想從一個主python腳本啓動呼吸機，工作人員和接收器，因此我在通風器周圍創建了「類」包裝，並且這兩個類都是Python模塊「multiprocessing.Process」的子類。由於C++是一個二進制文件，我使用Python的subproce

6熱度

1回答

ZeroMQ PubSub不能正常工作w \ Pyzmq

可能有些東西很小，但我無法使用官方Pyzmq軟件包（https://github.com/zeromq/pyzmq）獲得一個簡單的pub-sub示例。我正在使用最新的ZeroMQ穩定版本4.0.3，並且能夠在c中很容易地獲得一個簡單的示例。我試過Mac和Ubuntu機器。我期待着在這個任何輸入;）這裏是我的代碼： sub.py import zmq ctx = zmq.Context()

2熱度

1回答

從併發請求的分佈式工作發回正確的信息

我已經構建了一個Flask + nginx + gunicorn應用程序，它通過一對zmq套接字與服務對話，然後將這個請求發送給分佈式工作人員並返回結果。但是，我沒有進行大量的檢查以查看正確的信息是否發回給用戶。這意味着有時如果用戶A和用戶B在同一時間請求他們的數據，結果可能會導致錯誤的用戶。我猜我需要發送一些上下文與請求（如用戶名）。當結果返回時，將其放入隊列中，並以某種方式確保瀏覽器請求根