zeromq相关内容
使用Django时,我们需要将消息发送到另一个单独的python程序。 Zeromq似乎是轻量级的,应该符合这一要求。 但是,当尝试将套接字设置为zmq.PUSH(或其他任何值)时,它总是以ZeroMQ:Bad Address错误结束。 这是回溯: Exception Type: ZMQError Exception Value: Bad address ... ... so
..
导入org.zeromq.ZMQ; -对于上面的导入语句,我使用的是jzmq主文件夹中的“org文件夹”,该文件夹由ZMQ.Java文件组成。 -因此,编译没有问题。当我开始运行该程序时,它显示以下异常 线程“main”java.lang.UnssufiedLinkError中出现异常:在java.Library.Path中没有jzmq 在java.lang.ClassLoader.
..
当我从下面的ZeroMQ指南中用C++创建Hello World示例时: http://zguide.zeromq.org/page:all#Ask-and-Ye-Shall-Receive 运行该应用程序时,我收到一条Windows安全警报,询问我是否允许该应用程序在公用网络或专用网络上通信。 如下所示: 这里是事情变得有趣的地方。 我只需要我的程序在端口5555上侦听来
..
我已经使用ZeroMQ;编写了玩具主机/工人或任务场。 这就是我到目前为止所得到的--但我想添加PUB/SUB,以便工作人员听取并响应主题(特定主题或通配符匹配)。 主控 #!/usr/bin/env python from __future__ import print_function import random import time from multiprocessin
..
我似乎无法在我的MacBook(OSX 10.9.1)上安装pyzmq 要运行的第一个调用: sudo pip install pyzmq 出现找不到libzmq的错误,它似乎正在尝试编译捆绑版本: jono@air:~ $ sudo pip install pyzmq Password: Downloading/unpacking pyzmq Downloading p
..
当您使用简单的ZeroMQ REQ/rep模式时,您依赖于固定的end()->recv()/recv()->end()序列。 正如this文章所描述的,当参与者在请求中途断开连接时,您会遇到麻烦,因为这样您就不能重新开始接收来自另一个连接的下一个请求,而状态机会强制您向断开连接的连接发送请求。 写完这篇文章后,有没有更好的办法来解决这个问题? 重新连接是解决此问题的唯一方法(除了不使用
..
Python 标准库的 socket.create_connection()方法有一个源地址选项,用于控制连接使用哪个源 IP. 如果机器有多个地址,我如何使用 Python ZeroMQ 套接字做同样的事情? 在这种情况下,我一直在使用 Linux 的 iproute2 ip addr add 来创建地址和 ZeroMQ PUB/SUB 套接字原型. 解决方案 在尝试.con
..
..
我已经将php5.6升级到php7,但是zeromq扩展出了很多问题.我在哪里可以为 php7 下载正确的 zmq.so 文件?没有一个官方网站提供适用于 php7 的版本(我使用的是 apache2.4). 我按照以下教程进行操作:如何安装零MQ. “安装 ZeroMQ"步骤工作正常,但是当我执行“make"命令时,第二步“安装 PHP 绑定"失败,并出现以下错误: "/home/
..
我想保留一个 TCP 端口,以便稍后由服务绑定,以便 Windows 在分配随机端口号时不会无意中使用相同的端口号.我知道这可以通过注册表和重新启动来实现,但我想避免这种笨拙的解决方案. 进程如何在不实际绑定/侦听端口的情况下保留端口,然后根据请求安全地(即避免竞争条件)将其移交给另一个进程? 端口号无需提前确定.第一个进程可以获取一个随机端口号,并传递给请求进程. 编辑: 我突
..
我正在尝试在 c# 应用程序和分布式 python 服务器之间的 TCP 层上实现 ZeroMQ 模式.我得到了一个使用请求-回复 REQ/REP 模式的版本,在 localhost.但是,在测试中,我调试了一些情况,在收到显然不可接受的回复之前,我不小心发送了多个请求. 实际上,网络可能会丢弃大量数据包,我怀疑我会丢弃大量回复和/或无法发送请求. 1) 有没有办法重置 REQ/REP
..
我正在尝试将 ZMQ 集成到严重依赖 MFC 套接字 (CASyncSocket) 的现有 Windows 应用程序中. 我有一个 CWinThread 派生的 UI 线程(没有 GUI),它使用 CAsyncSocket 与服务器异步通信.我想添加一条 ZMQ inproc 通信线路来处理从服务器接收的数据(基于 REQ/REP)与应用程序中的其他线程的通信. 使用 CAsyncSo
..
我目前正在寻找一个好的中间件来构建监控和维护系统的解决方案.我们的任务是监控、收集和维护由多达 10,000 个独立节点组成的分布式系统. 系统以 5-20 个节点为一组集群.每个组通过处理传入的传感器数据来生成数据(作为一个团队).每个组都有一个专用节点(蓝色框)作为组的外观/代理,将组中的数据和状态暴露给外界.这些集群在地理上是分开的,并且可以通过不同的网络连接到外部世界(一个可能通过光
..
我的应用程序需要高性能消息总线,因此我正在评估 ZeroMQ、RabbitMQ 和 Apache Qpid 的性能.为了测量性能,我正在运行一个测试程序,该程序使用其中一个消息队列实现发布 10,000 条消息,并在同一台机器上运行另一个进程来使用这 10,000 条消息.然后我记录发布的第一条消息和收到的最后一条消息之间的时间差. 以下是我用于比较的设置. RabbitMQ:我使用了
..
尝试从 zeromq 教程编译示例 hello_world.c:http://zguide.zeromq.org/page:all#Ask-and-Ye-应收很确定我已经在 OSX Mountain Lion 中安装了所有东西. clang -Wall hwserver.c -o hwserver 给我一个错误: 架构 x86_64 的未定义符号:“_zmq_bind",引用自:hwse
..
我正在尝试编译 ZeroMQ C 绑定以便能够在 iPhone 上使用它,这是我的配置选项: ./configure --host=arm-apple-darwin --enable-static=yes --enable-shared=no CC=/Developer/Platforms/iPhoneOS.platform/Developer/usr/bin/arm-apple-darwi
..
我有一个简单的网络摄像头,我使用 OpenCV 读出它,我现在正尝试使用 ZeroMQ.所以我有以下简单的脚本来读取网络摄像头并使用 ZeroMQ 套接字发送它: 导入 cv2导入操作系统进口zmq导入 base64上下文 = zmq.Context()素材_socket = context.socket(zmq.PUB)镜头_socket.connect('tcp://localhost:55
..
我有一个使用 ZeroMQ 进行消息传递的 C++ 应用程序.但它还必须为基于 AJAX/Comet 的 Web 服务提供 SGCI 连接. 为此,我需要一个普通的 TCP 套接字.我可以通过普通的 Posix 套接字做到这一点,但为了保持跨平台的便携性并使我的生活更轻松(我希望......)我正在考虑使用 Boost::ASIO. 但现在我有 ZMQ 的冲突,想要使用它自己的 zmq
..
Python 标准库的socket.create_connection()method 有一个源地址选项,用于控制连接使用的源 IP. 如果机器有多个地址,我如何用 Python ZeroMQ 套接字做同样的事情? 在这种情况下,我一直在使用 Linux 的 iproute2 ip addr add 来创建地址和 ZeroMQ PUB/SUB 套接字原型. 解决方案 当我尝试将
..
我在运行与 ZMQ 的 PAIR 模式(非阻塞客户端服务器)连接时按下 Ctrl-C.后来当我尝试运行 REQ-REP(阻止客户端单服务器连接)模式时,我不断收到 Address already in use 错误.我试过用 netstat -ltnp | 运行 netstatgrep : 但没有列出任何进程. 那么究竟是谁在使用这个地址? 还有如何优雅地关闭这样的套
..