无法在Python中导入ZMQ(安装问题)
我似乎无法在我的MacBook(OSX 10.9.1)上安装pyzmq 要运行的第一个调用： sudo pip install pyzmq 出现找不到libzmq的错误，它似乎正在尝试编译捆绑版本： jono@air:~ $ sudo pip install pyzmq Password: Downloading/unpacking pyzmq Downloading p
..
pyzmq相关内容
Windows 10 上的 Jupyter 笔记本 python 崩溃
我花了一周的时间寻找和尝试不同的解决方案，但没有成功.一年多以来，我看到其他几个人遇到同样的问题. 问题: Windows 10 专业版 15063.674 我正在使用带有 Python 3.6.2 的最新 Anaconda 5 版本，并且所有包都更新到了最新版本. 运行 Jupyter Notebook，一段时间后，python 将崩溃并显示“python 已停止工作"对
..
如何在 Alpine Linux 容器上安装 pyzmq?
我有一个带有 python:3.6-alpine 内核的容器.我在通过 pip 安装 pyzmq 时遇到问题: Dockerfile: FROM python:3.6-alpine运行 mkdir/代码运行 apk 添加 vim工作目录/添加 ./代码 docker-compose.yml: 版本:'3'服务:电池监控:建造: .图像:BM:1.0.0容器名称:电池监控重新启动:除非停
..
如何轮询 zmq 和变量?
我有 python 服务器，它等待设置和退出全局标志. 在一些线程中，我有使用 zmq.Poller 等待的代码一个消息.它超时，打印心跳消息，然后等待轮询器对于新消息: def timed_recv(zock, msec=5000.0):轮询器 = zmq.Poller()poller.register(zock，zmq.POLLIN)事件 = dict(poller.poll(msec
..
多线程和 ZMQ DEALER/REP hello world 不起作用
首先是我的代码(主要来自 ZMQ doc http://zguide.zeromq.org/py:mtserver): 导入zmq导入时间导入系统进口螺纹#SOCKET_NAME = "tcp://127.0.0.1:8000"SOCKET_NAME = "inproc://mysocket"定义dealerRoutine(上下文):socket = context.socket(zmq.DEA
..
如何避免高CPU使用率?
我创建了一个单独运行的 zmq_forwarder.py，它将消息从应用程序传递到 sockJS 连接，我目前正在研究 Flask 应用程序如何接收来自sockJS 通过 zmq.我正在粘贴我的 zmq_forwarder.py 的内容.我是 ZMQ 的新手，我不知道为什么每次运行它时，它都会使用 100% 的 CPU 负载. 导入zmq# 准备我们的上下文和套接字上下文 = zmq.Conte
..
哪种 ZeroMQ 模式最适合异步套接字对?
我有一个服务器(在亚马逊上运行)和一个连接到它的客户端.建立连接后，客户端和服务器专门相互通信并发送消息. 例如 1.客户端->服务器2. 客户端 ->服务器3. 客户端 服务器5. 客户端
..
ZeroMQ 轮询线程安全
我有一个线程正在对 ZMQ 轮询器进行轮询: poller.poll(超时) 该线程也是通过轮询器中注册的套接字接收和发送消息的线程. 然后我有另一个线程，最终可能会创建一个新的套接字并注册它以轮询输入事件: socket = context.socket(...)socket.bind/connect(...)poller.register(套接字，zmq.POLLIN) 一旦so
..
Pyinstaller 错误运行具有 pyzmq 依赖项的脚本
这是我的第一篇 StackOverflow 帖子！ 我在创建具有 pyzmq (v22.0.2) 依赖项的 pyinstaller(v4.2) 可执行文件时遇到问题.我通过运行“pyinstaller main.py"创建了一个可执行文件.dist 文件夹的创建没有错误，但是当我在终端中运行可执行文件时，我看到下面引号中的错误. 我在 StackOverflow 和 pyinstall
..
从 zmq 套接字返回值
我正在使用 Socket.IO 让客户端网页从我的 Node.JS 服务器动态获取数据.在服务器端，我使用 zeromq 套接字库(REQ/REP 结构，请参阅 zguide 中的 rrclient.js 示例)将请求转发到 Python 后端. 但是，由于我的服务器充当 socket.io 服务器，因此我必须按如下方式包装响应才能将其发送回特定客户端: socket.on('app_re
..
PyZMQ 是否为每个新的客户端连接创建线程?
我正在使用 PyZMQ 创建请求/回复服务器，并且我试图弄清楚为每个新客户端连接创建线程的行为是否由 PyZMQ 自动处理.最终，我试图弄清楚来自一个客户端的需要很长时间才能回复的请求是否会阻止来自所有其他客户端的请求. 通常，我会在 Python 套接字实例上调用 accept ，阻塞直到建立新连接，并在单独的线程中处理任何新连接.但是，PyZMQ 套接字似乎不支持这样的工作流程.那么，这
..
识别ZMQ消息的来源?
如果我通过 ZeroMQ (0MQ) 套接字上的 recv() 方法收到消息... data = s.recv() ...有什么方法可以让我获取底层套接字的 getpeername() 值?我的目标是以不依赖发件人提供准确信息的方式识别消息的来源. 我正在使用 ZMQ(通过 Python)来收集主机指标，从接收者的角度来看发送者的地址是一个有用的标识符. 或者这只是一个坏主意?
..
ZMQ 套接字连接超时
我正在尝试将套接字连接到端点，直到套接字从该端点接收数据.这是因为此时端点可能不存在. 目前连接停止，我猜是因为它无法解析主机名，这需要一段时间. 有没有办法在套接字连接上设置超时? 导入zmq导入时间端点 = 'tcp://doesnt_exist:12345'ctx = zmq.Context.instance()s = ctx.socket(zmq.SUB)t = time.t
..
0mq:发布订阅延迟随着消息不断增长?
pub.py 导入zmq随机导入导入系统导入时间端口 = "5556"如果 len(sys.argv) >1:端口 = sys.argv[1]内部(端口)上下文 = zmq.Context()socket = context.socket(zmq.PUB)socket.bind("tcp://*:%s" % 端口)主题 = 10001为真:msgdata = time.time()socket.
..
Python 中的 ZeroMQ N 到 N 异步模式
N-proxy-N Pub-Sub 类似于问题 ZeroMQ 中的 N 到 N 异步模式?，但遗憾的是从未收到包含工作代码的答案. 我正在尝试按照指南中的描述实施 Pub-Sub 网络:http://zguide.zeromq.org/py:all#The-Dynamic-Discovery-Problem(N-proxy-N 风格的小型消息代理).不幸的是，该指南没有提供任何代码示例
..
REQ/REP 模式中的 ZeroMQ FiniteStateMachineException
我有两个简单的组件，它们应该使用 REQ/REP ZeroMQ 模式相互通信.服务器(REP Socket)使用pyzmq在Python中实现: 导入zmq定义启动服务器():打印“启动服务器"使用 zmq.Context.instance() 作为 ctx:socket = ctx.socket(zmq.REP)socket.bind('tcp://127.0.0.1:5555')为真:msg
..
使用 ZMQ 从多个客户端拉取请求
我有几个工人在等着做一些工作.我看到在 PULL/PUSH 模式中，我需要为工作人员提供客户端的 ip 地址(使用 tcp 协议)，以便它可以侦听来自那里的请求.但是，在我的情况下，我也希望有很多客户端，来自不同 IP 的请求......所以基本上我真的没有一个静态 IP 来绑定工作人员到 PULL.我是使用了错误的模式还是有正确的方法? 解决方案 您应该考虑使用路由器经销商模式.您的路由
..
如何在 ZMQ 套接字中启动/退出时清除缓冲区?(防止服务器与死客户端连接)
我在 python 中使用 REQ/REP 类型的套接字进行 ZMQ 通信.有多个客户端尝试连接到一台服务器.已在客户端脚本中添加超时以防止无限期等待. 问题是，当服务器没有运行，并且客户端尝试建立连接时，它的消息被添加到队列缓冲区中，理想情况下此时甚至不应该存在.当脚本开始运行并且新客户端连接时，服务器首先接收前一个客户端的数据.这不应该发生. 当服务器启动时，它假设有一个客户端连接
..
ZeroMQ:PUSH 上的 HWM 不起作用
我正在尝试编写一个服务器/客户端脚本，其中有一个服务器来释放任务，以及多个执行它的工作人员.问题是我的呼吸机有很多任务，它会在心跳中填满内存.我试图在绑定之前设置 HWM，但没有成功.只要工作人员连接，它就会继续发送消息，完全无视设置的 HWM.我还有一个记录已完成任务的接收器. server.py 导入zmqdef通风():上下文 = zmq.Context()# 用于发送消息的套接字发
..
ZeroMQ 消息大小长度限制?
假设多台机器使用 python 的 zeroMQ 客户端进行交互. 这些消息自然地格式化为字符串. 消息(字符串)的长度有限制吗? 解决方案 发送的消息大小没有限制，但是小消息的处理方式与大消息不同(请参阅 这里). 小消息的最大大小在源代码中定义为 30 字节(参见 此处，查找 ZMQ_MAX_VSM_SIZE).
..