-
0 votesanswersviews
从ZMQ PULL套接字获取数据 . 如何同步计算？
我有一个 生产环境 者使用PULL / PUSH向多个 Worker 发送数据 . 在执行计算任务之前，所有工作人员都需要接收所有数据 . 我尝试使用发送“go”的PUB / SUB套接字进行同步，但由于PUSH套接字是非阻塞的，因此在数据流结束之前收到go ... 发件人： context = zmq.Context() push_socket = self.context.socket(zm... -
3 votesanswersviews
为什么ZMQ不会丢弃消息？
我有一个应用程序，使用PUB / SUB设置从ZeroMQ发布者获取消息 . 读者有时很慢，所以我在发送器和接收器上都设置了HWM . 我希望接收器将填充缓冲区并跳转以便在处理速度减慢时恢复 . 但我观察到的行为是它永远不会掉落！ ZeroMQ似乎忽视了HWM . 难道我做错了什么？ 这是一个最小的例子： publisher.py import zmq import time ctx = zmq... -
9 votesanswersviews
ZMQ REP，知道谁发送请求
我目前正在使用zmq和python . 服务器正在使用REP套接字 . 在收到消息时，我有办法知道是谁发送的吗？如果收到2条消息，我只需要知道它们是否来自同一个用户，所以例如uid就足够了 . -
5 votesanswersviews
zmq发送NOBLOCK引发资源暂时不可用
使用NOBLOCK调用时，此代码将使资源暂时不可用： context = zmq.Context() sender = context.socket(zmq.PUSH) sender.bind('tcp://*:15556') sender.send('KeEpAliv', zmq.NOBLOCK) # this line will throw exception #sender.send('K... -
0 votesanswersviews
ZMQ模式;发送然后接收
我一直在阅读zmq设计模式，但我似乎没有找到适合我的需要 . 1. Box A sends info (json) to Box B and C; B and C gets different info from each other 2. Boxes B and C do some work based on info received from Box A 3. After finis... -
0 votesanswersviews
轮询我是否可以推送或发送zmq？
通过使用0mq，我试图检测我是否已成功连接到PULL端口，如果我可以推送 . 但是，它没有像我预期的那样工作，请参阅下面的示例代码 . 即使远程对等方尚未启动接受连接，Poller也会立即返回 . 有办法解决吗？ import sys import zmq context = zmq.Context() pusher = context.socket(zmq.PUSH) pusher.connec... -
0 votesanswersviews
pyzmq在pub / sub模型中缺少消息
版本： $ python --version Python 3.5.2 $ ll /somepath/python3.5/site-packages/ | grep zmq drwxrwxr-x 2 xxx xxx 4096 Mar 11 2017 pyzmq-16.0.2.dist-info drwxrwxr-x 15 xxx xxx 4096 Mar 11 2017 zmq... -
2 votesanswersviews
从zmq套接字返回值
我正在使用Socket.IO让客户端网页从我的Node.JS服务器动态获取数据 . 在服务器端，我使用zeromq套接字库将请求转发到Python后端（REQ / REP结构，请参阅zguide中的rrclient.js示例） . 但是，由于我的服务器充当socket.io服务器，我必须按如下方式包装我的响应，以便将其发送回特定客户端： socket.on('app_request',functi... -
1 votesanswersviews
Jenkins的ZMQ事件发布者不发送通知
我一直试图弄清楚我的Jenkins ZMQ事件发布者配置出了什么问题已经超过23个小时而已经放弃了 . 希望你可能知道我做错了什么 . 我已经使用ZMQ-event-publisher插件安装了Jenkins，并且在 Manage Jenkins - > Configure System 已选中 Enable on all Jobs （ Note TCP port to pub... -
1 votesanswersviews
ZeroMQ PUB SUB TCP丢弃消息订户失败
我按照github页面上的说明在我的Manjaro Linux机器上从源代码构建了ZeroMQ . 所有测试都通过 . 基本上， ./autogen ./configure ./make ./make install ./make check 我在Python中使用指南运行气象站示例，并使用tcp通过家庭WiFi从笔记本电脑发送/接收消息到我的PC . 服务器： # # Weather up... -
6 votesanswersviews
Windows 10上的Jupyter笔记本python崩溃
我花了一个星期的时间搜索并尝试不同的解决方案而没有运气 . 我见过其他几个人在一年多的时间里遇到同样的问题 . The issue: Windows 10 Pro build 15063.674 我正在使用最新的Anaconda 5版本和Python 3.6.2，并且所有软件包都更新到最新版本 . 运行Jupyter Notebook，一段时间后，python将崩溃，对话框“python已停止工作... -
1 votesanswersviews
ZeroMQ（TCP）端口转发的解决方法
我目前有一个ZeroMQ对等网络，我正在使用Python和PyZMQ构建 . 目前，服务器使用REP TCP套接字进行侦听，并直接连接到侦听相同类型套接字的其他对等方 . 这需要端口转发以便客户端遗憾地到达服务器 . 反正有没有绕过这个？我可以进行某种UDP发现，然后切换到TCP吗？或者我注定要切换到UDP风格的网络来解决这个问题？ -
1 votesanswersviews
pyzmq使用自己的套接字创建进程
我有一些代码监视一些其他更改的文件，我想要做的是启动使用zeromq与不同的套接字的代码，我现在这样做的方式似乎导致断言在libzmq的某处失败，因为我可能正在重用同一个插座 . 我如何确保从监视器类创建新进程时不会重用上下文？多数民众赞成我认为正在发生的事情，如果你能说出我的其他愚蠢，请告知 . 这是一些代码： import zmq from zmq.eventloop import ioloo... -
0 votesanswersviews
ZMQ的编码
我目前正在做的项目需要从PC到设备的通信，到目前为止我已经决定使用socket通信 . 并编写了一些代码 . 我也在设备上使用ZMQ for ipc . 我的脚本通过将文本作为文本发送来工作 . 我试图将我的数据编码为utf-8，以便可以在设备上轻松读取并显示在框架中并根据需要执行任务 . 但是，我似乎无法使编码正常工作，我已经尝试在线搜索示例或教程，但似乎无法找到任何 . 我已经尝试使用sock... -
3 votesanswersviews
如何检查zeromq中的发送数据是否成功
我是zmq和网络编程的新手 . 我想使用pyzmq库编写一个简单的函数来在客户端和服务器之间发送/接收数据（使用REQ / REP模式） . 我发送数据的方法如下： def send_data(socket, data): try: socket.send(data) except: return False return True 如果数...