pyzmq

    1熱度

    1回答

    我一直在嘗試解決這個問題一段時間,但我一直無法解決它。我用崇高的文本3 SublimeREPL每當我嘗試推出從SublimeREPL IPython的殼,我得到這個錯誤: Traceback (most recent call last): File "/home/user/.config/sublime-text-3/Packages/SublimeREPL/config/Python

    4熱度

    1回答

    該代碼發送將提高資源暫時不可用時,調用與NOBLOCK: context = zmq.Context() sender = context.socket(zmq.PUSH) sender.bind('tcp://*:15556') sender.send('KeEpAliv', zmq.NOBLOCK) # this line will throw exception #sender.se

    1熱度

    1回答

    我創建了一個分開運行的zmq_forwarder.py,它將消息從應用程序傳遞到sockJS連接,目前我正在處理燒瓶應用程序如何通過zmq從sockJS接收消息。我正在粘貼我的zmq_forwarder.py的內容。即時通訊新的ZMQ,我不知道爲什麼每次我運行它,它使用100%的CPU負載。 import zmq # Prepare our context and sockets conte

    0熱度

    1回答

    我看了一下各種ZMQ消息模式,我不確定哪一個會爲我的項目做。我想要做的就是能夠連接到服務器併發送命令(客戶端永遠不會收到任何東西)。在服務器端,我希望能夠檢查是否有消息,如果有,處理它,否則繼續做其他的東西而不會阻止。這樣,即使沒有連接客戶端,服務器也可以繼續工作。 #client.py while(True): select = raw_input() if select

    1熱度

    1回答

    我有一臺服務器(在亞馬遜上運行)和一個連接到它的客戶端。連接建立後,客戶端和服務器專門相互通信併發送消息。 例如 1. Client -> Server 2. Client -> Server 3. Client <- Server 4. Client -> Server 5. Client <- Server 6. Client <- Server 客戶端可能會丟失連接並在一段時間

    4熱度

    4回答

    我似乎無法在我的MacBook(OSX 10.9.1)安裝pyzmq 首先電話是運行: sudo pip install pyzmq 時出錯這libzmq找不到,而且它似乎試圖編譯捆綁版本: [email protected]:~ $ sudo pip install pyzmq Password: Downloading/unpacking pyzmq Downloading

    0熱度

    2回答

    我試圖連接到端點的套接字,直到套接字從該端點接收數據。這是因爲當時端點可能不存在。 目前連接失速,我猜,因爲它無法解析主機名,這需要一段時間。 有沒有什麼辦法可以在套接字連接上設置超時? import zmq import time endpoint = 'tcp://doesnt_exist:12345' ctx = zmq.Context.instance() s = ctx.so

    0熱度

    2回答

    我想在cywgin中運行ipython筆記本。爲了這個工作,我需要安裝pyzmq。然而這不是工作。我已經解決了這個問題,任何人都可以幫忙嗎? $ easy_install pyzmq Searching for pyzmq Reading http://pypi.python.org/simple/pyzmq/ Reading http://github.com/zeromq/pyzmq

    3熱度

    1回答

    我一直在玩pyzmq和簡單的負載平衡使用HWM,我不明白我看到的行爲。 我已經設置了一個簡單的多線程測試,一個DEALER客戶端通過ROUTER到DEALER模式連接到兩個工人。 HWM設置爲1.其中一名工作人員非常快,另一名工作非常緩慢,而且所有客戶端都會向服務器發送100封垃圾郵件。這通常似乎起作用,而且速度更快的工作人員比慢速工作人員處理更多的消息。 然而,即使我將緩慢的工作者設置得如此緩慢

    5熱度

    2回答

    我想使用ZeroMQ rep/req並且無法弄清楚如何處理服務器端錯誤。看看代碼here: socket.bind("tcp://*:%s" % port) while True: # Wait for next request from client message = socket.recv() print "Received request: ", messa