zeromq相关内容

为什么使用 AMQP/ZeroMQ/RabbitMQ

而不是编写自己的库. 我们正在这里开展一个项目，该项目将是一个自我分割的服务器池，如果一个部分变得太重，经理会将其分割并作为单独的进程放在另一台机器上.它还会提醒所有受此影响的已连接客户端连接到新服务器. 我很好奇使用 ZeroMQ 进行服务器间和进程间通信.我的伙伴更愿意自己动手​​.我期待社区来回答这个问题. 我自己是一个相当新手的程序员，刚刚了解了消息队列.正如我在谷歌上搜 ..

发布时间：2021-11-27 11:47:27 rabbitmq messaging zeromq amqp 其他开发

当 ZMQ_FD option_val 的本地地址通过时，zmq_getsockopt 在 windows x64 上返回 EINVAL

在 windows x64 上，将局部变量的地址传递给 zmq_getsockopt 以获取 ZMQ_FD 始终会导致 EINVAL.下面的代码是重现问题的最小代码. #include #include void zmq_perror(const char*);int main(void){const char *endpoint = "tcp://127.0.0.1:7100";void *c ..

发布时间：2021-11-25 07:32:00 c windows 64-bit zeromq mingw-w64 C#

将 ZeroMQ 交叉编译到 ARM 以在 MonoTouch iPhone 应用程序配置设置中使用

我正在尝试在使用 MonoTouch 用 C# 开发的 iPhone 应用程序中使用 ZeroMQ 库.我已经解决了几乎所有的问题，但在最后一个障碍中失败了.我正在使用 ZeroMQ 2.1.10 和 C# CLR 绑定/包装器，并在 Mac OS X 10.6.8 中进行开发.这是迄今为止的故事: 我首先尝试在一个简单的 Mono C# 控制台应用程序中使用 ZeroMq.我用 ./con ..

发布时间：2021-11-17 22:09:03 iphone ios xamarin.ios arm zeromq 移动开发

是否可以在 Arduino 上运行 ZeroMQ

我想知道是否可以通过 ZeroMQ 与 Arduino 通信.我想使用 Arduino 来控制一些设备，并希望将大部分应用程序放在计算机上.为此，如果 Arduino 和控制器可以通过 zeromq 进行通信并说是 WiFi 或以太网屏蔽，那就太好了.这可能吗? 特别是，考虑到 Arduino 板上的当前芯片，原则上是否可行，有没有人在这方面取得过成功? 解决方案 我认为在 Ardu ..

发布时间：2021-11-17 03:44:47 arduino zeromq 其他开发

c++ - 如何在扩展的PUB-SUB模式中将发布者和订阅者与C++中ZeroMQ中的中介同步?

扩展PUB/SUB拓扑 在一个有 1 个中介的用例中，我有多个发布者和多个订阅者. 在 ZeroMQ 指南中，我了解了如何使用额外的 REQ/REP 套接字同步 1 个发布者和 1 个订阅者.我尝试为我的用例编写同步代码，但是如果我尝试根据 1-1 PUB/SUB 给出的逻辑编写代码，它会变得混乱. 当我们只有 1 个发布者时的发布者代码是: //接收同步请求的套接字zmq:: ..

发布时间：2021-11-17 02:42:44 c++ architecture synchronization zeromq publish-subscribe C/C++开发

zmq 与 redis 的 pub-sub 模式

redis 支持 发布订阅 zmq 还支持 通过消息代理发布订阅 在它们之间进行选择的架构优点\缺点是什么? 我的目标是超出明显的用例特定性能基准测试应该完成的点(这里是 一个很好的例子). 假设使用 Python 等高级语言. 解决方案 我使用 Python 处理过 ZeroMQ 和 Redis.我会说 ZeroMQ 更健壮，它提供了真正简单的负载平衡，而且不仅仅是发布- ..

发布时间：2021-11-17 01:59:52 architecture redis zeromq publish-subscribe design-consideration 其他开发

风暴工人没有开始

我的 Nimbus 主机和主管运行正常.当我向 Nimbus 主机提交 wordcount 拓扑时，它成功上传.上传拓扑管理器后报错 kill:没有这个进程 当我检查 worker-6001.log 和 6002.log 时，我发现了以下错误: 2014-02-09 17:20:05 b.s.m.TransportFactory [INFO] Storm peer 传输插件:backtype ..

发布时间：2021-11-14 23:41:41 java ubuntu-12.04 zeromq apache-storm jzmq Java开发

风暴错误 java.lang.UnsatisfiedLinkError?

编译没问题，但是运行后..... 26183 [Thread-34] 错误 backtype.storm.util - 异步循环死了！java.lang.UnsatisfiedLinkError: org.zeromq.ZMQ$Socket.finalize()V在 org.zeromq.ZMQ$Socket.finalize(本机方法)在 org.zeromq.ZMQ$Socket.close ..

发布时间：2021-11-14 23:37:23 zeromq apache-storm 其他开发

ZeroMQ REQ-REP 不工作

我正在尝试使用 ZeroMQ 在我的程序之间进行数据交换.我的系统由两部分组成:用 C# 编写并在 Windows 上运行的客户端(REQ)和用 C++ 编写并在 linux ubuntu 上运行的服务器(REP). 客户端发送请求，服务器捕获它，处理并发送回复.永远不会发送回复. 在最小的测试用例中，客户端和服务器只是发送空消息，所以问题不在于消息构造或处理代码. 如果我改变角 ..

发布时间：2021-10-05 19:05:33 linux zeromq 服务器开发

如何从 C# ZeroMQ 中的消息中提取数据?

我需要将数据从 C++ 发送到 C#. 在 C++ 端，在 Linux 下，我使用 ZMQ 库 version 4.1.4. C# 端正在使用 clrzmq4 基于4.1.5 版本的库. 所以我在C++中发送消息的部分: char tempStr[] = "ABCD";zmq_msg_t zmsg;zmq_msg_init_size(&zmsg, 4);memcpy(zmq_m ..

发布时间：2021-10-05 19:05:31 c# zeromq C#/.NET

ZeroMQ - 如何在发布消息的 zeromq zmq 实现中摆脱 setTimeout?

例如在发布我们使用的任何消息时 setTimeout() 我尝试删除超时，但它没有发布任何消息. setTimeout(function () {var t = pub.send(mes + ' ' + stringObject, 0);}, 1000); 我正在使用 NodeJS ZMQ npm 模块. 在不添加 setTimeout() 函数的情况下，是否还有其他方法可以实现 ..

发布时间：2021-10-05 19:05:27 node.js zeromq 其他开发

如何轮询 zmq 和变量?

我有 python 服务器，它等待设置和退出全局标志. 在一些线程中，我有使用 zmq.Poller 等待的代码一个消息.它超时，打印心跳消息，然后等待轮询器对于新消息: def timed_recv(zock, msec=5000.0):轮询器 = zmq.Poller()poller.register(zock，zmq.POLLIN)事件 = dict(poller.poll(msec ..

发布时间：2021-10-05 19:05:24 python multithreading zeromq pyzmq Python

ZeroMQ 如何管理 zmq::proxy 和 zmq::poll 中的套接字?

我有一个关于 ZeroMQ 的问题，因为我在 zmq::proxy 和 zmq::poll 的 ZMQ 套接字上使用了指针.这样做会发生错误 88(非套接字上的套接字操作)的异常. 实际上，ZeroMQ 希望用户发送一个在 void* 中强制转换的结构(信息来源) 我在官方文档中做了一些研究，但我没有发现为什么 ZeroMQ 不在套接字上使用指针. 编辑:这是我认为正确的代码 ..

发布时间：2021-10-05 19:05:22 c++ zeromq C/C++开发

相对于使用 ZeroMQ 的一个订阅者，向没有订阅者发布是否很慢?

当有一个订阅者与根本没有订阅者时，发布 是否会明显变慢? 更多细节: 我们正在编写一个 ZeroMQ 应用程序，其中速度非常重要. 我们有许多节点通过 进行通信REQ/REP 以及 PUB/SUB 和网络自动选择 { ipc: |tcp: } 传输类，如果节点在同一台机器上. 我们有时希望记录某些节点之间的消息.使用 PUB/SUB 这很容易，我们只需要一个订阅发布者的“日志节点 ..

发布时间：2021-10-05 19:05:19 zeromq 其他开发

ZeroMQ 简单代理

我正在尝试制作一个简单的代理(即星型拓扑)，它允许任何 DEALER 节点与也连接到该代理的任何其他 DEALER 节点通信.这是当前设置: //简单代理#include #include #include 使用命名空间标准；int main(){zmq::context_t 上下文(1);zmq::socket_t 路由器(上下文，ZMQ_ROUTER)；router.bind("ipc:// ..

发布时间：2021-10-05 19:05:16 c++ zeromq C/C++开发

在 ZeroMQ 中进行 PULL-PUSH 同步的另一种可靠方法

如果您使用 PUSH 套接字，您会发现第一个连接的 PULL 套接字将获取不公平的消息份额.只有在所有 PULL 套接字都成功连接时才会发生消息的准确轮换，这可能需要几毫秒.作为 PUSH/PULL 的替代方案，对于较低的数据速率，请考虑使用 ROUTER/DEALER 和负载平衡模式. 因此，在 PUSH/PULL 中进行同步的一种方法是使用负载平衡模式. 对于下面这个特定的情况，我 ..

发布时间：2021-10-05 19:05:13 c++ zeromq message-passing C/C++开发

ZMQ getsocket 方法

zeromq 中 getSocket(type,persistence_id,callback) 的目的是什么? 如果上下文中不存在具有相同persistence_id的套接字，它会创建一个新套接字吗? 这是我的客户 function newSocket(ZMQSocket $soc, $pid) {回声 $pid;}$context = new ZMQContext();$sock ..

发布时间：2021-10-05 19:05:10 php zeromq PHP

当以 ZMQ REQ/REP 模式回复时间过长时，应用程序崩溃

我正在编写一个插件，它通过 ZeroMQ REQ/REP 请求-回复通信原型与桌面应用程序交互.我目前可以接收请求，但如果回复发送速度不够快，应用程序似乎会崩溃. 我在衍生的线程上收到请求并将其放入队列中.该队列在另一个线程中进行处理，在该线程中，应用程序会定期调用处理函数. 正确接收和处理消息，但直到函数的下一次迭代才能发送响应，因为在那之前我无法从应用程序获取数据. 当这个函 ..

发布时间：2021-10-05 19:05:07 c++ zeromq C/C++开发

ZeroMQ:在线程“Timer-0"中获取异常org.zeromq.ZMQException:重试时无法在当前状态(0x9523dfb)下完成操作

我有这个场景:尝试发送到服务器的客户端，但服务器处于脱机状态.socket.send(request, 0);在 Java Timer 线程中: 这是线程 run()ZMQ.Socket m_socket 是在线程外发起的 public void run() {m_socket.send(请求, 0);byte[] 回复 = m_socket.recv(0);//获取分隔符byte[] e ..

发布时间：2021-10-05 19:05:04 java zeromq Java开发

路由器挂在经销商路由器设置中

鉴于以下尝试将 1 个 DEALER 连接到 1 个 ROUTER: 包 net.async导入 org.zeromq.ZMQ导入 org.zeromq.ZMQ.Socket导入 scala.annotation.tailrec对象客户端{val Empty = "".getBytesdef message(x: Int) = s"HELLO_#$x".getBytes值计数 = 5}class ..

发布时间：2021-10-05 19:05:01 scala zeromq 其他开发