-
1 votesanswersviews
Akka-ZMQ订户创建错误（民意调查）
我成功创建了发布者但未能使用以下内容创建订阅者： public static void main(String [] args) { ActorSystem system = ActorSystem.create("System"); ActorRef subscriber = system.actorOf(new Props(Sub.c... -
8 votesanswersviews
ZeroMQ有哪些替代方案可以移动协议缓冲区有效负载？
目前我有一个使用ZeroMQ来交换协议缓冲区有效负载的解决方案 . 序列化的协议缓冲区方法必须保持不变，但我可以用更方便的选项替换ZMQ . 我在ZMQ不满意的事情是： 它在Java方面使用JNI，在复杂的多线程场景中我被JNI咬过 . 我尽力消除它 . 我不需要排队，我只需要rpc . 我的要求（主要由ZeroMQ涵盖）是： 支持32/64位* nix，Windows，MacOS . 主... -
0 votesanswersviews
OpenCV Mat损坏
我一直致力于一个简单的ip-video-ip程序，部分用于项目，部分用于自学一些使用高级接口的网络基础知识 . 麻烦的是，我可以通过网络从 cv::Mat 发送数据，但是一旦我尝试解码数据，它似乎缺少大量的颜色数据 . 代码在gist中，其中包含在Linux下构建和运行项目所需的所有文件 . 任何人都可以对此有所启发吗？ 如果您需要更多信息，请与我们联系 . 我担心你需要一个网络摄像头来测试 . -
73 votesanswersviews
为什么要使用AMQP / ZeroMQ / RabbitMQ
而不是写自己的图书馆 . 我们正在开发一个项目，这个项目将是一个自我划分的服务器池，如果一个部分变得太重，管理员会将其划分并将其作为一个单独的进程放在另一台机器上 . 它还会警告所有连接的客户端，这会影响连接到新服务器 . 我很好奇使用ZeroMQ进行服务器间和进程间通信 . 我的伴侣宁愿自己动手 . 我期待社区回答这个问题 . 我自己是一个相当新手的程序员，只是学习了消息队列 . 正如我用Goo... -
1 votesanswersviews
ZeroMQ（TCP）端口转发的解决方法
我目前有一个ZeroMQ对等网络，我正在使用Python和PyZMQ构建 . 目前，服务器使用REP TCP套接字进行侦听，并直接连接到侦听相同类型套接字的其他对等方 . 这需要端口转发以便客户端遗憾地到达服务器 . 反正有没有绕过这个？我可以进行某种UDP发现，然后切换到TCP吗？或者我注定要切换到UDP风格的网络来解决这个问题？ -
0 votesanswersviews
org.zeromq.ZMQException：Errno 48：地址已在使用中
我正在尝试使用ZeroMQ实现pub-sub示例 . 我在docker容器中运行发布者的代码，在另一个容器中运行订阅者的代码 . 我的订阅者是： private ZMQ.Context context; { context = ZMQ.context(1); } public void receive() { System.out.println("Getting s... -
1 votesanswersviews
Visual C：插件DLL使用的第三方DLL的位置？
我正在为第三方Windows应用程序编写C插件DLL . 我的插件DLL可以存在于文件系统的任何地方，我指定从第三方应用程序加载它时的位置 . 我的DLL的部分功能要求我使用第三方库（ZeroMQ） . 我将我的DLL链接到ZeroMQ库并且它正确构建 . 但是，在第三方应用程序中加载我的DLL时，我一直收到 The specified module could not be found. 错误 ... -
1 votesanswersviews
线程“main”中的异常java.lang.UnsatisfiedLinkError：Eclipse中java.library.path中没有jzmq
导入org.zeromq.ZMQ; 对于上面的import语句，我在jzmq主文件夹中使用“org文件夹”，该文件夹由ZMQ.java文件组成 . 所以，编译没有问题 . 当我开始运行程序时，它显示以下异常 线程“main”中的异常java.lang.UnsatisfiedLinkError：java.lang.ClassLoader.loadLibrary（未知来源）java.lan... -
0 votesanswersviews
通过CERTBOT使用SSL的ZeroMQ Websockets
我有一个服务器端应用程序，在端口443上托管https安全网页，还需要托管两个额外的websockets . 其中一个websockets将通过tcp直接与“worker”进行通信 . （我将在稍后和单独处理为此添加安全性） . 另一个websocket需要是安全的，客户可以使用浏览器访问wss：//mydomain.com . 问题是我正在使用certbot，据我所知，certbot只会在端口4... -
4 votesanswersviews
为什么ZeroMQ PUB会在没有连接订阅者的情况下对消息进行排队？ （好吧，“断开连接”SUB-s）
我正在使用 ZMQ_PUB 看到一个奇怪的行为 . 我有一个 生产环境 者 .connect() -s到不同的进程那个 .bind() 在 ZMQ_SUB 套接字上 . 订阅者全部 .bind() ，发布者 .connect() -s . 当一个 生产环境 者启动时，它会创建一个 ZMQ_PUB 套接字并将 .connect() -s创建到不同的进程 . 然后它会立即开始定期发送消息 . 正... -
1 votesanswersviews
python3 asyncio ZeroMQ .connect（）块
我尝试使用python3 asyncio和ZeroMQ实现 REQ/REP 模式 我的客户端异步功能： import zmq import os from time import time import asyncio import zmq.asyncio print ('Client %i'%os.getpid()) context = zmq.asyncio.Context(1) lo... -
0 votesanswersviews
纠正消息捕获机制的套接字类型？
我有一个发布者应用程序（PUB），它有N个订阅者（SUB） 这些订户需要能够在重新启动时崩溃，或者掉线并丢失消息 . 我们已经实现了发布者写入的简单事件存储 . 我们已经实现了一个CatchupService，它可以查询事件存储并向订阅者发送错过的消息 . 我们在订户中实现了一个PUSH套接字，它发送一个错过消息的请求 . 订户还有一个PULL套接字，用于侦听单独端口上的错过消息 . 订户将： ... -
1 votesanswersviews
零MQ和Websockets
我目前的架构如下： 使用HTML 5 Web套接字连接到Web服务器的Web UI（Wildfly） . 在Web服务器上，我既是订阅者又是两个不同ZMQ套接字的发布者 . 对于连接到我的Web服务器的每个新用户，我创建一个连续运行并侦听来自上游的消息的线程 . 当我收到新消息时，我将更新广播给正在收听的所有用户 . 然后使用传统的Web套接字将更新发送回其网页 . 这个架构看起来... -
1 votesanswersviews
使用PUB-SUB（慢速用户）的ZMQ延迟
我在类似的主题上发现了很多问题，但它们并没有帮助我解决我的问题 . 使用： Linux Ubuntu 14.04 python 3.4 zmq：4.0.4 // pyZMQ 14.3.1 TL; DR 即使设置了HWM，ZMQ SUB套接字中的接收器队列也会无限增长 . 当订阅者比发布者慢时会发生这种情况 . 我该怎么做才能防止它？ 背景 我在人机交互领域工作 . 我们有一个巨大的... -
2 votesanswersviews
如何检查在ZeroMQ PUB-SUB模式下发送时由于HWM而丢弃的消息
我已经使用ZeroMQ（更具体地说是CZMQ）在Linux中为IPC实现了消息总线 . Here是我实施的 . 我的问题是， how do I know that send dropped the message when the publisher buffer is full? 在我的简单测试设置中，我使用的是具有代理的发布者 - 订阅者 . 我有一个快速发送器和一个非常慢的接收器，导致消息... -
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... -
1 votesanswersviews
ZeroMQ：如何从订阅者通知发布者
我使用 PUB/SUB ZeroMQ 模式 . 系统包括Web服务器（ Pub lisher），集群TCP服务器（ Sub scribers）和外部应用程序（客户端，连接到TCP服务器） . 大量外部客户端连接到每个TCP服务器 . 每个外部客户端都有唯一的 peerId ，我在 Pub lisher中用作主题 . 出于某些管理目的，我将消息发送到TCP服务器（如删除对等，更改等） . ... -
0 votesanswersviews
如何将队列连接到ZeroMQ PUB / SUB
考虑以下： 一组3个逻辑服务： S1 ， S2 和 S3 每个服务的两个实例正在运行，因此我们有以下过程： S1P1 ，2721212，_ 27213， S2P2 ， S3P1 ， S3P2 a ZeroMQ 代理在单个进程中运行，并且可由所有服务进程访问 逻辑服务，比方说 S1 ，发布了逻辑服务 S2 和 S3 感兴趣的消息 M1 . 每个逻辑服务只有一个进程必须接收 M1 ... -
2 votesanswersviews
读取在C中通过ZMQ发送的Flatbuffers对象会抛出未处理的异常
我试图通过ZMQ在网络上发送一个相当大的Flatbuffers对象，然后使用C读取它 . 访问对象时，我得到了未处理的异常，我不知道如何解决 . 即使这个最小的例子也失败 flatbuffers架构： namespace flatbuffer; table TestBuf { testStatus:bool; testNumber:double; testInt:int; } root... -
0 votesanswersviews
ZeroMQ上的MS Bond序列化中的运行时“EndOfStreamException”错误
首先，值得一提的是，在单个F＃解决方案中，Bond消息的序列化和反序列化工作正常 . 但是，我无法正确处理通过ZeroMQ发送和/或接收消息 . 以下程序的订户端存在运行时错误 . 使用绑定编译器定义和编译.bond文件 . 然后从C＃创建一个dll，从F＃调用 . 然后我有两个F＃程序 . 一个通过tcp套接字发布序列化数据，另一个发布是订阅者 . 当在子上接收到消息时，尝试解组原始数据的行是导... -
0 votesanswersviews
如何将Java连接到MQL5（最好使用ZeroMQ）
有谁知道如何在 Java 和 MQL5 之间进行双向连接？最好使用 ZeroMQ . 在这种情况下，Java将从 MQL5 接收数据（可能是数组），它将计算并将信息返回到 MQL5 . 这一切都在运行时 . -
1 votesanswersviews
使用openssl及其未阻止的bio，ssl_read返回SSL_ERROR_SYSCALL和SSL_ERROR_WANT_READ
我使用zeromq和openssl来编写我的服务器和客户端 . 握手成功后，当客户端再次向服务器发送消息时，服务器中的ssl_read（）返回-1，ssl_get_erro（）返回SSL_ERROR_SYSCALL， 当服务器再次收到消息时，这种情况会重复 . 我找不到原因 . 我需要BIO_flush（）吗？我真的很感激你，甚至只是给我一些灵感来解决这个问题 . 好吧，我的程序太复杂了，无法显... -
1 votesanswersviews
tornado：websocket和iostream之间的递归循环
这是我使用Tornado的第一个项目......使用TornadIO ZMQ构建消息服务 . 我正在使用pyzmq的ioloop . 我一直在讨论iostream和websocket之间的递归循环问题，但还不能确定原因 . 似乎客户端连接正常并发送大量消息并收到罚款 . 其他人连接，然后崩溃就好了 . 我不知道我是否正确处理断开连接，或者如果消息中的某些内容导致龙卷风代码中的读取错误 . 在我的服... -
2 votesanswersviews
ZeroMQ混合PUB / SUB DEALER / ROUTER模式
我需要做以下事情： 多个客户端连接到SAME远程端口 每个客户端打开2个不同的套接字，一个是 PUB/SUB ，另一个是 ROUTER/DEALER （服务器偶尔可以发送回客户端心跳，不同的服务器相关信息） . 无论是否可以在ZeroMQ中完成，我都完全迷失了 . 显然，如果我可以使用2个远程端口，这不是问题，但我无法理解我的设置是否可以通过ZeroMQ中的某种信封使用来实现 . 可以... -
1 votesanswersviews
在zeromq中使用XSUB / XPUB代理的简单示例是什么
我跟进How to implement Pub-Sub Network with a Proxy by using XPUB and XSUB in ZeroMQ(C++)? 该问题请求使用XSUB和XPUB的C代理 . 给出的答案基本上是下面引用的代理main（）函数 . 我将此代理扩展为包含发布者和订阅者的完整工作示例 . 问题是我的代码只适用于经销商/路由器选项（如下面的评论所示） . 使用... -
12 votesanswersviews
将pub / sub与zeromq中的req / rep结合使用
客户如何使用zeromq订阅和收听回复？也就是说，在客户端，我想运行一个只接收消息并有选择地发送请求的循环，而在服务器端我想发布大部分时间，但有时也会收到请求 . 看起来我必须有两个不同的插座 - 每个插槽用于一种通信模式 . 是否有可能避免这种情况，并在服务器端从zeromq回调线程上的套接字接收“请求通知”，同时将消息推送到我自己的线程中的套接字？ -
12 votesanswersviews
在zeromq pub sub上丢失了消息
我正在尝试使用zeromq框架实现pub子设计模式 . 我们的想法是推出订阅者，然后推出发布者 . 订阅者将收听100条消息，发布者将发布100条消息 . 到目前为止一切都那么好......然而实际发生的事情是，即使发布者发布时订户已经启动并运行，订阅者也不会收到所有消息（订阅者将收到100条消息，如果出版商将发送至少500条消息） . 似乎发布者发送的第一条消息不会发送给订阅者 . 有任何想法吗... -
1 votesanswersviews
发布者在订阅者和消息丢失之前完成 - 为什么？
对zeromq来说相当新，并试图让一个基本的pub / sub工作 . 当我运行以下（在pub之前启动子站）时，发布者完成但订阅者挂起但没有收到所有消息 - 为什么？ 我认为套接字正在关闭，但邮件已被发送？有没有办法确保收到所有邮件？ 出版商： import zmq import random import time import tnetstring context=zmq.Context()... -
2 votesanswersviews
在zeromq中使用pub / sub req / rep进行轮询
我在我的项目中使用zeromq中的不同模式，现在我正在使用req / rep（稍后将转移到经销商/路由器）和pub / sub . 客户端将消息发送到服务器，服务器将此信息发布给已订阅的其他客户端 . 要使用多个套接字我遵循此线程Combining pub/sub with req/rep in zeromq上的建议并使用zmq_poll . 我的服务器轮询req套接字和pub套接字 . 在编写代...