通过ZeroMQ套接字发送枕头/数字图像
ZeroMQ是一个高性能、异步消息传递库，它提供了简单而强大的消息传递模式，可以在分布式系统中进行快速、可靠的通信。ZeroMQ使用套接字（sockets）来实现消息传递，可以在不同的进程、线程、计算机之间进行通信。
在ZeroMQ中，套接字可以分为不同的类型，包括REQ/REP、PUB/SUB、PUSH/PULL等。这些类型可以根据不同的通信需求进行选择。
对于发送枕头/数字图像的需求，可以使用ZeroMQ的PUB/SUB模式。PUB（发布者）套接字将消息广播给所有订阅者，而SUB（订阅者）套接字可以选择性地接收感兴趣的消息。
ZeroMQ的优势包括：
- 高性能：ZeroMQ使用异步I/O和多线程技术，能够处理大量的消息传递，并具有低延迟和高吞吐量。
- 简单易用：ZeroMQ提供了简洁的API，使得开发者可以快速上手并进行消息传递。
- 可靠性：ZeroMQ支持消息队列、重试机制和错误处理，确保消息的可靠传递。
- 可扩展性：ZeroMQ可以在分布式系统中进行水平扩展，支持多个节点之间的通信。
- 多语言支持：ZeroMQ提供了多种编程语言的绑定，包括C、C++、Python、Java等，方便开发者在不同的语言环境中使用。
在云计算领域，ZeroMQ可以应用于以下场景：
- 分布式系统通信：在云计算环境中，不同的服务或组件之间需要进行快速、可靠的通信，ZeroMQ可以作为消息传递的基础设施，实现各个组件之间的通信。
- 实时数据处理：云计算环境中常常需要对实时数据进行处理和分析，ZeroMQ可以用于实时数据的传递和交换，提供高性能的数据传输能力。
- 多媒体处理：对于音视频、图像等多媒体数据的处理，ZeroMQ可以作为传输通道，实现多媒体数据的传递和处理。
- IoT设备通信：在物联网领域，设备之间需要进行通信和数据交换，ZeroMQ可以作为设备之间的通信框架，实现设备之间的数据传输和控制。
腾讯云提供了一款基于ZeroMQ的消息队列产品，名为TDMQ（Tencent Distributed Message Queue）。TDMQ是一种高性能、可靠的消息队列服务，基于ZeroMQ技术实现，适用于分布式系统中的消息传递和异步通信。您可以通过以下链接了解更多关于TDMQ的信息：https://cloud.tencent.com/product/tdmq
相关·内容
我想在Python应用程序中使用AMPQ服务，但还没有使用过ZeroMQ。所以我想知道是否可以这样做：
从一个主机和端口订阅“common_messages”
Recver2.py崩溃
发送者发送一条消息
成功地接收到了
接收方2.py被重新启动
接收不在时发送的消息。
这能办到吗？ZeroMQ是否跟踪已发送的消息？如果在消息发送后订阅，ZMQ是否检测到应该接收哪些旧消息，哪些不应该接收？
浏览 0提问于2012-06-20得票数 4
回答已采纳
我的目的是在C中动态地创建一些ZeroMQ套接字(对等点)。
我的服务器中有一个侦听套接字，当客户端发送消息时，我会赋予一个新端口属性，并与这个新端口创建连接，然后返回我的侦听套接字。
例如：
服务器侦听端口8500。
客户端1向8500发送消息。
服务器发送一个新的端口号8510
服务器和客户端在端口8510上创建连接。
(客户端断开端口8500上的连接)
服务器侦听其他连接。
客户端2向8500发送消息。
服务器发送一个新的端口号码8511 ..。
我应该使用哪种类型的ZeroMQ函数？
我在考虑FD和select，但可能与ZeroMQ或zmq_poll
浏览 1提问于2018-03-22得票数 2
回答已采纳
我们正在为一个现有的在线游戏构建一个新的客户端和一个缓存代理组件。当前设置如下所示：
Server
| \
TCP TCP
| \
Client1 Client2
新的设置将是：
Server
| |
TCP TCP
\ \
Proxy <-- (New!)
| \
0MQ 0MQ
| \
Client1 Client2 <-- (New!)
代理组件将靠近现有的游戏服务器，并对其使用基于旧线路的TCP协议，同时对新客户端使用基于Google protocol
浏览 0提问于2013-01-17得票数 1
回答已采纳
1回答
我正尝试在C++中使用zeromq套接字作为原始的TCP客户端套接字。我在一个不同的程序中有一个TCP服务器，我想将数据发送到该服务器。当我将Zeromq客户机连接到服务器时，我可以从服务器接收数据，但无法将数据发送到TCP服务器。当发送时，我得到以下错误:未处理的错误，zmq::error_t有任何想法让它工作吗？ zmq::context_t *ctx = new zmq::context(100, 100);
void *raw_socket = new zmq::socket_t(*ctx, ZMQ_STREAM);
zmq::socket_t *socket = static_ca
浏览 35提问于2019-02-05得票数 0
回答已采纳
2回答
我在Windows和Linux下运行了一个C#应用程序。我想通过Python脚本实现一种与它通信的方式。
我已经尝试过使用ZeroMQ库，当C#应用程序在Windows上运行时，它正在工作--我可以在两端发送/接收消息。但当我试图在Linux/Mono上使用时，我不幸地失败了--应用程序崩溃了，kernel32异常。我试着用教程重新编译libzmq.dll，但是我做错了。
还有其他方法可以做到这一点吗?还是我应该坚持使用ZeroMQ并尝试在Linux/Mono上运行它呢？
浏览 2提问于2014-10-27得票数 1
回答已采纳
我使用ZMQ允许多个客户端连接到服务器，并使用拉/推模式发送视频流。现在的问题是客户端可以断开与服务器的连接。我需要问一下是否存在可靠性问题，如果将被发送到服务器的数据删除，会发生什么情况。客户端将开始从开始发送视频流还是从ZeroMQ中删除它的位置发送视频流。使用拉/推模式是否有缓冲区来解决这个问题。
浏览 2提问于2021-06-30得票数 0
回答已采纳
3回答
在C中，我们有套接字和描述符，可以只获取其中的一个并将它们交给Thread，这使得您可以接受传入的连接，并将工作提供给您喜欢的Thread，然后Thread可以自己发送回响应。
我的问题是，我如何使用ZeroMQ实现这一点？使用请求-回复模式，我似乎不能异步发送和接收，响应必须按顺序进行，我的目标是让多个客户端连接到单个服务器，不按顺序发送响应。
我看过请求响应模式，但API清楚地指出，将该套接字与多个线程一起使用不是一个好主意。也许我错过了什么，或者ZeroMQ比我所知道的更聪明。如果您需要任何进一步的信息，只需发表评论，我将尽我所能提供信息。
我还查看了提供的示例：
下面是套接字描述：
浏览 1提问于2012-06-26得票数 6
回答已采纳
1回答
我正在学习ZeroMQ模式，我需要实现以下内容：
NodeJS将发送消息给许多，但它不需要等待答案的同步，它们可以按任何顺序来。我知道发布/订阅模式以一种方式解决了这个问题:它可以发送给许多人，但是python工作人员是如何将回复发送回来的呢？
另外，为了让python线程接收消息，这是更好的设计: python进程接收消息并发送到适当的线程(不知道如何做)，还是每个线程负责接收自己的消息？
浏览 7提问于2017-01-29得票数 0
我找到了一个！以前，但我仍然不知道如何做，如果我的需要构建异步客户机/服务器使用路由器经销商套接字。
在使用zeromq之前，当我需要构建异步服务器时，我将分离套接字的读部分和写部分。
[dispatch]工作人员将启动epoll_wait套接字的读取事件并启动[worker]线程，以便根据msg执行一些工作，
最后，将在同一套接字的不同线程中触发.send()操作。
读取和发送可以在两个不同的线程中分开。
在两个不同的线程中记录和发送一个套接字
是否可以(允许)使用zeromq套接字？
实际上，我搜索了一些邮件列表，得到了否定的答案。
那么，我想知道如何处理这种情况？
如果只能使用一个线程作
浏览 5提问于2014-09-24得票数 2
我想要XPUB/XSUB，因为我想从XSUB向XPUB发送数据。我成功地发送了一个带有过滤器字符串的订阅消息，从XSUB到XPUB，然后以过滤器字符串作为前缀从XPUB接收数据到XSUB。
如果我不使用这个过滤器，我的XSUB客户端就不会收到任何信息。如果我没有从XSUB发送任何订阅消息到XPUB，我的XSUB客户端也不会收到任何消息。在XPUB/XSUB的zeroMQ中是否有一种完全禁用过滤器的方法？我只想让XSUB接收从XPUB发送的所有东西。
浏览 2提问于2014-07-09得票数 1
回答已采纳
我指的是Zeromq文档中的'A请求-应答代理‘：
我明白了这个应用程序的大意:它就像一个中介，将消息从客户机路由到服务器，然后再路由回来。
我不明白的是，它如何确保来自服务器的正确响应被发送到最初发出请求的正确客户端。我在代码示例中看不到任何可以确保这一点的东西。
现在在示例中，它们只发送一条消息(hello)和一条响应(world)，所以即使消息混淆了也没关系，但我猜testclient和server是故意保持简单的。
欢迎任何想法..。
浏览 1提问于2010-12-07得票数 6
回答已采纳
当我们有多个客户端请求多个服务时，如何将消息发送到zeromq提出的路由器/经销商体系结构中的特定工作进程？更具体地说，如果我们在ZMQ_DEALER后面有service A service B。如何仅向service A或service B发送消息？
浏览 1提问于2013-04-02得票数 2
1回答
我想要创建一个网络体系结构，其中主进程与一些从进程连接，并以这种方式交换消息：
每个奴隶都应该能够向主人发送一条信息。主服务器应该能够向每个连接的从节点的子集发送消息。
即
主人给奴隶1发送一条消息
主人给奴隶2和奴隶3发送一条消息
师父给所有的奴隶发信息。
从1向主发送消息
这些消息可能有答案，但如果没有专门的ZeroMQ处理方法，则可以在更高级别处理这些消息。
--这应该只使用一个端口.
使用普通的套接字，我可以使主绑定在端口上，接受连接，为每个从站生成一个线程来处理传入的数据，并使用单个连接来联系单个从节点。
由于这个架构将使用基于消息的通信，我认为Ze
浏览 2提问于2016-08-16得票数 2
回答已采纳
1回答
我正在做zeromq /SUB，我在django上建立了zeromq酒吧。
这是我用来设置zeromq的代码
from gevent_zeromq import zmq
我正在使用gevent_zeromq库
@api_view(['POST','GET'])
def NOTIFICATION(request):
if request.method == 'GET':
return render_to_response('notifications.html',context)
if request.method == &
浏览 3提问于2015-05-05得票数 4
1回答
我有一个python程序，它从ADC读入值，然后将它们写到一个文件中，如果连接可用，还可以通过TCP发送它们。我可以很好地发送数据，但是，由于数据不断被读取，我希望能够保持连接打开。如何让客户端检查服务器是否有更多数据要发送，从而保持连接打开？
浏览 1提问于2014-06-24得票数 0
1回答
我将C#包装器用于ZeroMQ，但这似乎更像是ZeroMQ的一个潜在问题。
有什么方法可以在不阻塞和的情况下推送消息而不排队呢？如果服务器没有启动，我希望这些消息能够永久地被释放，而不会阻塞。
以下是我迄今尝试过的设置：
1)
发送(阻塞发送)
高水标=0
这(很明显)不阻塞，但是它似乎在内存中排队，直到套接字连接(进程的内存不断上升)。
2)
发送(非阻塞发送)
高水标=1
这是比赛条件。如果我迅速地连续发送两条信息，有时会有一条信息因为超过了高水位而被丢弃。
3)
轮询套接字以确定它是否会阻塞。这并没有真正的帮助，因为在队列开始阻塞之前，我仍然必须将一条(旧的)消息放入队列中(如果我设置了
浏览 1提问于2012-12-11得票数 3
2回答
我有一个继承自QThread的类，它在when循环中处理ZeroMQ订阅套接字(在线程的run方法中轮询)，并在接收来自套接字的消息时通过发出信号通知ZeroMQ线程。
在这个PUB派生类中，在轮询循环之前，我还创建了一个ZeroMQ QThread发布套接字，并且有一些方法可以使用它。这些方法仅在主线程( GUI )中用于向服务器发送数据。
这个解决方案没有任何问题，但并不完美。我只需要一个线程来处理订阅和发布套接字操作。GUI线程( main )将发送一个请求发布数据的信号，而不是调用QThread派生的类方法。
有一个好的模式，基于Qt工具，实现这一点吗？
浏览 0提问于2018-06-11得票数 0
回答已采纳
1回答
使用传统的TCP套接字进行通信
、、、、
我正在用NetMQ编写我的第一个应用程序(ZeroMQ实现.NET)。
我还需要监听使用传统TCP套接字(即非0MQ套接字)从客户端发送的信息。
我在正式的ZeroMQ文档 (查找ZMQ_STREAM)中看到了对这种套接字类型可用性的引用，但是关于如何使用它的细节很少(这也没有多大帮助，.NET API与C++ API有很大不同)。
也没有提到流套接字类型。
最后，我查看了NetMQ的测试套件，并在中找到了对我的问题的部分答案。
以下代码片段起作用：
using (NetMQContext context = NetMQContext.Create())
{
using (var ro
浏览 7提问于2015-02-26得票数 1
回答已采纳
1回答
我已经阅读了ZeroMQ文档，并认为我理解了三种基本模式：ZeroMQ
但是，我看不出它们如何允许我构造A向B和C发送消息的阻塞行为。
也就是说，假设我为A->B和A->C都设置了1024条消息的限制。那么，如果队列填满，我希望A停止发送消息，直到两个接收方都有空间，而不是仅仅丢弃消息(PUB/SUB)。
PUSH/PULL不会将每条消息同时传递给A和B，但只会传递其中的一条。
有什么方法可以用ZeroMQ**?** 来做吗？
谢谢!
浏览 3提问于2016-06-14得票数 0
1回答
我正在构建一个messages，它通过ZeroMQ推送/拉套接字与客户端进行通信，并且能够将客户端从服务器端未订阅的消息中排除在外(与在客户端排除消息的ZeroMQ pub/sub不同)。
目前，我以以下方式实现它：
服务器:在固定端口上绑定ZeroMQ拉套接字
Client:在随机端口或固定端口上绑定ZeroMQ拔接插座
Client:连接到服务器的拉套接字，并发送包含新客户端地址和端口的握手消息。
服务器:接收来自客户端的握手，并将推送套接字连接到客户端的拉服务器。向客户端的套接字发送握手响应。
客户:收到握手。连在一起！
现在，客户机和服务器可以双向通信，而服
浏览 2提问于2022-02-04得票数 0
1回答
我正在考虑使用mongrel2来处理服务的Web请求。对于后端，我希望使用任务群模式，使用C绑定到zeromq。
但是，在阅读了mongrel2手册后，我不清楚如何实现这一点，因为后端处理程序从mongrel2提取消息，并使用ZMQ_PUB套接字将消息发送到mongrel2。
我希望将消息从处理程序转发到后端的任务场，并在处理程序中接收回响应，然后将其发布到mongrel2。zeromq客户端可以绑定到几(2)个输入和几(2)个输出吗？
FWIW，我正在用ANSI C实现这一点。
浏览 0提问于2012-11-28得票数 0
回答已采纳
1回答
今天我看了一下Rasmus在中使用ZeroMQ和libevent所描述的内容。
我让它正常工作，但我注意到客户端等待服务器返回/发送响应。有没有可能使客户端脚本不等待服务器响应？我只希望我发送给服务器的消息是“一发即忘”。
我在谷歌上搜索了一下，但没有找到任何有用的东西，ZeroMQ客户端库似乎没有太多关于异步通信的选项，或者我错过了什么？
浏览 3提问于2012-03-26得票数 2
回答已采纳
3回答
我读了，偶然发现了以下内容：
不能在线程之间共享You套接字。MQ套接字不是线程安全。从技术上讲，这是可能的，但它需要信号量、锁或互斥。这将使您的应用程序变得缓慢和脆弱。在线程之间共享套接字的唯一地方是语言绑定，这些绑定需要执行像套接字上的垃圾收集这样的魔术。
后来：
记住:除非在创建套接字的线程中，否则不要使用或关闭套接字。
我还知道ZeroMQ Context是线程安全。
如果类在.Net中为另一个类的事件注册，则该事件可能从与在其上创建侦听器的线程不同的线程调用。
我认为只有两个选项可以通过ZeroMQ在夜间发送一些东西：
将甚至调用线程同步到ZeroMQ-Socke
浏览 0提问于2011-04-30得票数 20
回答已采纳
1回答
我的数据收集系统将数据发布到ZeroMQ套接字。
我希望能在客户端应用程序中绘制流数据。我对GUI设计没有太多经验，所以决定选择构建一个HTML5客户端。我所读到的许多解决方案都涉及到添加额外的层以使一切正常工作:比如插入一个web服务器来订阅套接字，然后生成HTML以服务于用户。
A: --用最少的额外代码将流数据从ZeroMQ套接字直接推入HTML5客户端的最简单、最轻量级的方法是什么？一个代码示例将非常有用。
B:是否有一个由HTML5页面加载的javascript文件，允许它从ZeroMQ套接字中获取数据？
C: --如果这不是可能的话，下一个最简单的方法是什么?它实际上允许将来自套接
浏览 3提问于2017-08-01得票数 2
回答已采纳
假设你有一台机器能从交易所得到实时的股票价格.这些价格需要以最快的方式转移到网络中的其他50台机器上，这样它们就可以对数据进行自己的处理。
向其他50台机器发送数据的最佳/最快方法是什么？
我正在寻找一个可以在linux上工作的解决方案，使用python作为编程语言。我的一些想法是：
(1)使用python's ZeroMQ模块将其发送到其他机器
(2)将数据保存到共享文件夹，并让50台机器使用NFS读取数据
还有其他想法吗？
浏览 1提问于2011-07-01得票数 1
回答已采纳
1回答
我试图在ZeroMQ中实现基本的交易商路由器套接字。我的问题有几个部分。
在此之前，这里是我的示例脚本
问题-
首先，我的香草经销商脚本无法从套接字中读取消息。
其次，当我实现一个经销商或路由器模式时，是否必须(作为报头的一部分)传递标识，即不能在没有任何标识的情况下发送消息。
换句话说，一个交易商-路由器模式(可以在下面看到)可以共存并在它们之间传递消息，而不需要在报头中发送标识信息。
因为，没有身份我也无法让它发挥作用。
注意事项：-目前图片中的Zeromq库(红宝石客户端)是
浏览 3提问于2015-08-25得票数 2
3回答
首先，我要感谢那令人惊叹的lib！我爱死它了。客户端正在将自己连接到服务器。服务器应该保存IP并在以后使用它(我真的需要IP)。我找到了答案：，但我不明白如何从消息中获取IP (一个XREP)……我想我只能读取ID，但是IP是由0MQ内部管理的。他的第二个解决方案建议将IP作为消息的一部分发送，但我不明白如何获得“公共”-IP。我找到了那篇文章：
is pass bind a service to an ephemeral port, get a full connection endpoint ("tcp://ipaddress:port")
我不明白这是怎么回事。他指的是
浏览 4提问于2013-12-03得票数 15
通过同一个类对象(包括2个zeromq订阅服务器和1个zeromq请求套接字)，我在不同的线程中创建对象。我使用inproc套接字，这些套接字属于同一个ZContext。
每当我创建对象时，服务器(operating 7)系统中打开的文件(lsof _在创建第一个对象之后，打开的文件#增加300的数量，而第二个打开的文件号增加304，并且不断增长。
由于我的程序可以在运行时使用这些对象中的许多，这可能导致对zeromq打开太多文件错误，即使我将限制设置为524288 (ulimit -n)。随着对象的#越来越高，每个对象都会消耗更多打开的文件限制，因为其中一些在1500左右。
在运行时，我的程
浏览 0提问于2018-07-27得票数 2
我正在建立一个分布式系统，我希望异步发送和接收从两端与高水位后阻塞。 PUSH/PULL套接字工作得很好，但我不能绑定PUSH套接字。这意味着，如果客户端在防火墙后面，我就不能有客户端推送到服务器拉取和服务器推送到客户端拉取，因为服务器无法连接到客户端。 在这本书中，写了以下内容，但我找不到一个例子。"REQ到经销商:理论上你可以这样做，但如果你添加第二个REQ，它将会中断，因为经销商无法向原始对等发送回复。因此，REQ套接字将被混淆，和/或返回给另一个客户端的消息。“http://zguide.zeromq.org/php:chapter3 我只需要一对一的连接，所以这在理论上对我
浏览 18提问于2019-05-29得票数 0
1回答
我有一个场景，在.net中有客户机需要连接到python服务器，该服务器为每个接受的客户端创建一个线程。然后，服务器和客户端在它们之间发送和接收数据，直到客户机断开连接并关闭特定的客户端线程。
这个场景适合ZeroMQ吗?如果符合，我应该使用什么模式来实现这个场景？(插座类型等)
浏览 3提问于2015-10-29得票数 1
ZeroMQ指南明确指出，不能在线程之间共享套接字。对于需要通过zmq推送输出的多线程生成器，我看到了两种可能的设计模式：
每个生产者线程0mq套接字
单独线程中的单个0mq套接字
在第一种情况下，每个线程都处理自己的事务。在后一种情况下，您需要一个线程安全队列，所有生产者都可以写入队列，0mq线程从该队列中读取并发送。
在这两种模式之间选择的因素是什么？每种方法的利弊是什么？
浏览 1提问于2013-07-16得票数 0
回答已采纳
请您为下列场景提供ZeroMQ套接字体系结构建议：
1)服务器正在监听端口
2)有多个客户端同时连接服务器。
3)服务器接受来自客户端的所有连接，并为每个客户端提供双向队列，这意味着双方(客户机N或服务器)都可以发送或使用消息，即双方可以是通信的发起者，而另一方应该有一个回调来处理消息。
我们是否应该在每个可接受的连接上创建额外的ZeroMQ套接字，以便从服务器上推送消息？请您向google推荐这类架构的ZeroMQ套接字类型，好吗？
浏览 2提问于2020-01-21得票数 0
回答已采纳
我让这个ZeroMQ消息在我的C应用程序中发送代码
void *socket= zmq_socket (context, ZMQ_DEALER);
// ...
zmq_msg_t zmsg;
zmq_msg_init_size (&zmsg, msg_size);
memcpy(zmq_msg_data (&zmsg), content, msg_size);
zmq_msg_send (&zmsg, socket, 0);
zmq_msg_close(&zmsg);
sleep (1);
这实际上是有效的，但我不喜欢我必须调用sleep(1)来刷新消息的事
浏览 2提问于2013-02-05得票数 3
回答已采纳
1回答
我有我自己的web应用程序，使用第三方API的，通过它每天发送数千个HTTP请求。
我想知道是否通过ZeroMQ发送HTTP请求。ZeroMQ能优先处理队列中的超文本传输协议请求吗?这是通过ZeroMQ发送超文本传输协议请求的好方法吗？
Ravi
浏览 2提问于2014-01-09得票数 0
是否可以使用ZeroMQ作为中间点，不同的程序可以将数据包发送到ip:port组合或可选的网络接口，并让ZeroMQ在特定的出站连接中转发任何这样的数据包？
因此，基本上，我不想以编程方式发送由我生成的数据，而是公开一些端点，让其他应用程序像往常一样无缝地进行通信，但基本上使用ZeroMQ作为中间人，从而相应地路由通信量。
浏览 1提问于2020-11-23得票数 1
回答已采纳
我在一个系统上工作，它需要有一个非常低的执行总延迟。为此，我必须做出一个设计选择。一种选择是使用单个程序来完成整个任务，或者使用两个单独的程序(对于我的用例更可取)，第一个程序将相关数据发送给另一个程序，这两个程序都是在同一主机上实现的。 我现在希望用Python语言实现这个系统，稍后再迁移到C++，两者都在Windows机上运行。对于进程间通信，我考虑使用套接字。我正在尝试得到一个估计，在从一个程序向另一个程序传输数据(通常一次5个浮点数)时，我应该期望的延迟的数量级。
浏览 17提问于2021-08-10得票数 0
我想从客户端向服务器发送数据。只有最后一条消息对服务器是重要的。如果服务器在故障后启动，我只希望服务器从客户端获得最后一条消息。
当服务器关闭时，我希望客户端继续处理和发送消息，或者至少将它们放入一个队列中(长度为一条消息)。
为此，我尝试使用NetMQ/ZeroMQ。怎么做呢？
谢谢!
浏览 30提问于2015-05-22得票数 2
我对Lisp很陌生，我正在努力学习。特别是，我试图使用ZeroMQ库来构建一个分布式系统。这是我的探索性代码
;;hwserver.lisp
(defun main()
;; prepare contexts
(zmq:with-context (context)
(zmq:with-socket (socket context zmq:rep)
(zmq:bind socket "tcp://*5555")
(loop
(let ((request (make-instance 'zmq:msg)))
浏览 1提问于2016-05-31得票数 3
回答已采纳
2回答
我有一个问题，在ZMQ中，从多个线程发布到单个订阅服务器的最佳方法是什么。我有一个用C++编写的web服务器，对于每个连接，都需要向订阅服务器发送一条ZMQ消息。这些服务器可以有数百到数千个并发连接，所以我想知道向这个订阅服务器写入最有效的方法是什么。我可以想出三种不同的方法。
共享连接
我不相信这种方式会起作用，但基本上只有一个连接指针，并将其传递给所有线程。我假设(当我在ZMQ站点上搜索时找不到多少信息)，这将导致竞争情况，因为我不认为zmq_msg_send()是线程安全的。为了解决这个问题，我可以在发送时设置一个互斥锁，但是我担心速度，因为我的服务器需要尽可能快。
共享队列
这类似于共
浏览 3提问于2014-10-03得票数 3
回答已采纳
请考虑以下几点：
一组三种逻辑服务：S1、S2和S3
每个服务的两个实例正在运行，因此我们有以下进程：S1P1、S1P2、S2P1、S2P2、S3P1、S3P2
在单个进程中运行并可由所有服务进程访问的ZeroMQ代理
一个逻辑服务，比方说S1，发布了一个与逻辑服务S2和S3相关的消息M1。每个逻辑服务只有一个进程必须接收M1，所以我们假设S2P1和S3P2。
我试过以下几种方法，但都没有成功：
代理线程1正在运行XSUB/XPUB代理。
代理线程2正在运行一个ROUTER/DEALER代理，ROUTER连接到XPUB套接字并订阅所有内容(对于逻辑S1)
代理线
浏览 1提问于2016-03-10得票数 1
回答已采纳
1回答
在Windows上，我必须用ZeroMQ构建一个相对简单的拓扑。
我有一个从外部接收数据并将其引入ZeroMQ拓扑的进程(让我们称其为桥)。我想使用一组发布器(像ipc:///bridge/entity1，ipc:///bridge/entity2，ipc:///bridge/entity3等等)，但是afaik，ZeroMQ不支持windows上的IPC传输(因为在这样的操作系统中缺乏命名管道)。
所以我不得不转向TCP传输，但我不想为每个实体使用一个端口:我想使用像tcp:///bridge:12345/entity1、tcp:///bridge:12345/entity2之类的东西。
然
浏览 2提问于2013-06-24得票数 0
回答已采纳
我们希望在nodejs中构建一个facade，它将接受来自客户端的请求，然后使用请求/回复模式将请求分包给许多不同的后端服务。我们希望这些请求保留在单个队列中，以防其中一个后端服务宕机。从最初读取ZeroMQ文档来看，似乎每个队列都绑定到自己的端口。向套接字发送消息时，似乎没有一种方法可以命名要发送到的队列/主题。端口和队列之间是否存在一对一的映射关系？
谢谢，汤姆
浏览 0提问于2013-02-22得票数 1
当我从套接字发送数据，然后立即关闭它(不更改默认设置)时，小数据可以成功发送，但大数据(> 2MB)不能成功发送。
下面是我如何设置接收器(在最后的recv()上阻塞)：
In [1]: import zmq
In [2]: ctx = zmq.Context()
In [3]: socket = ctx.socket(zmq.PULL)
In [4]: socket.connect("ipc://@foo")
In [5]: msg = socket.recv()
然后是发送者：
In [1]: import zmq
In [2]: ctx = zmq.Con
浏览 0提问于2014-01-25得票数 2
我知道ZMQ不是线程安全的。
但是我想使用一个线程接收数据：zmq_poll()等待数据到来，然后使用zmq_recv()接收数据；使用另一个线程发送数据：zmq_send()
我想知道这是使用ZMQ的正确方式吗？事实上，我已经试过了。当调用zmq_poll()一次时，程序核心转储，但它只发生一次，并且不能再次出现。
浏览 0提问于2017-10-26得票数 1
我有一个接受HTTP请求的Flask应用程序。当某些HTTP请求传入时，我希望在zeromq流上触发一条消息。我想让zeromq流一直处于打开状态。我想知道做这件事的合适方法是什么。由于建议在生产中使用gunicorn和Flask，这是否意味着Flask应用程序将有多个实例，如果我将zeromq连接放在Flask应用程序的同一位置，则只有一个可以连接，其他实例将失败。
浏览 3提问于2014-07-19得票数 6
我目前正在从事一个项目，其中有客户端系统、用户系统和服务器。对于我们的示例，让我们使用客户端A、Server、用户A.
客户端--向服务器发送一个保持活动的数据包，服务器将套接字信息存储为带有客户端ids的hashmap/列表。这样，更多的客户机可以添加到hashmap/ list中。
用户A希望向客户端A发送信息，因此它连接到服务器向客户端A发送消息。服务器从hashmap/list中获取相关的套接字信息，并将其传递给用户A、或服务器将两个套接字绑定在一起。
在将套接字合并在一起的这一部分中有点无知。如有任何意见或建议，请见谅。目前，我正在试用ZeroMQ，但没有任何其他框架、apis或库可
浏览 0提问于2013-09-11得票数 1
回答已采纳
我试图通过REP-socket.发送大型消息( 300 MB )
有多个客户端，每个客户端通过一个REQ-socket.连接到服务器。服务器为每个客户端创建专用套接字，等待请求(包含标识符)，并使用ZMQ_SENDMORE将消息分为两部分发送。
元数据(~ 1 KB)
数据(~ 300 MB)
在此之后，REP-socket立即关闭。然后在父线程中关闭Context()-instance。套接字的ZMQ_LINGER时间是默认的(无限)。有时发送元数据，但不发送图像数据。
我跟踪了ZeroMQ中的调用，发现内部(windows)套接字在消息数据被发送到网络之前已经关闭。我认为只
浏览 1提问于2015-12-14得票数 5
我想了解如何实现下一个任务分配方案：
TaskController (主节点)
该控制器可以创建作业，发送给工人，asynchronously接收工人的答复。
工作者(任务节点)
工人收到一个新的作业，然后asynchronously运行它，工作完成后，工人将结果发送给TaskController。工作人员可以接收许多作业并异步运行。
最后，我希望有三个接收作业的工作人员(主节点)和3个工作人员(任务节点)，asynchronously运行作业并回复asynchronously接收消息和处理的TaskController (主节点)。
在所有的ZeroMQ示例中，工作人员是同步的--一个工作人
浏览 0提问于2016-09-05得票数 0
我在路由器-路由器与NetMQ的通信方面有问题.
两个应用程序，客户机和服务器。都使用路由器套接字。客户端路由器套接字没有显式地设置它的身份，只有服务器。
在首次建立连接后，消息从客户端(路由器)路由到服务器(路由器)。但是，一旦客户端再次调用Disconnect()，然后再调用Connect() (经过很短的时间，即10毫秒)，服务器就不再接收消息了。
有趣的是，如果使用ZeroMq C# lib，则重新连接可以正常工作。
这是已知的问题还是我做错了什么？
重现问题的最低限度代码：
public class PureNetMQ
{
private static readonl
浏览 0提问于2015-08-11得票数 2
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
