假设推套接字每1秒发送一次消息，拉套接字每10秒接收一次消息。 因此，在100秒内，推式套接字发送了100条消息，而拉式套接字仅接收到10条消息。现在，如果PUSH socket死了，而PULL socket继续运行，会发生什么呢？它还会收到消息吗？ 另外，推送套接字在没有人接收的情况下持有的消息是否有限制？
浏览 43提问于2021-08-31得票数 0
回答已采纳
3回答
用PyZMQ限制队列长度
、、、
我希望限制我的ZeroMQ消息队列在Python应用程序中消耗的内存量。我知道设置高水标记会限制发送方排队的数量，但是有办法控制接收方排队的数量吗？Python绑定似乎将其设置为无限。我的测试场景:我有两个用于测试的python终端。= zmq.Context()
>>> socket = context.socket(
浏览 9提问于2012-02-21得票数 5
回答已采纳
我正在检查这些值，以了解何时可以关闭套接字(即，当套接字不轮询/发送任何内容时，因此我不会丢失消息)。我使用一个发送方(zmq.socket('push');)和一个接收方(zmq.socket('pull');)，但是检查zmq对象时，我始终拥有ZMQ_POLLIN和ZMQ_POLLOUT的这些
浏览 1提问于2013-03-27得票数 0
回答已采纳
在我的情况下，这个答复根本不重要。所以这是一种火灾和遗忘式的电话。医生们似乎没有一个简单的，直接的答案。对于“完全异步”的REQ-REP，它有一个复杂的拓扑结构，而另一个地方则暗示DEALER-ROUTER模式可能有一些有用的地方。我认为这是非常简单的事情，ZeroMQ应该能够在不需要打开太多端口、在拓扑中创建多个层和引入任何额外延迟的情况下立即完成任务。我在另一个地方读到了超时，并考虑将其设置为0，但我不知道超时后到达的</
浏览 3提问于2017-02-07得票数 1
MT4的每个实例都将在用户本地机器上运行，创建自己的zmq.context和zmq.socket (push)。接收到的消息的顺序并不重要，如果某些消息偶尔下降，也不重要。当前状态：
现在，我的代码(见下面)在我自己的本地机器上使用一个Metatrader 4实例运行得非常好。但是，如果有X实例，所有这些实例都有自己的zmq<
浏览 3提问于2019-12-11得票数 0
回答已采纳
我试图在Python (pyzmq)中与多处理一起使用ZeroMQ。作为一个小示例(不是)，我有一个服务器和一个客户机类，它们都是从multiprocessing.Process继承的。作为子进程的客户端应该向服务器子进程发送一条消息，该进程应该打印消息：import zmq__init__()
self.ctx = zmq.Co
浏览 1提问于2017-05-30得票数 6
回答已采纳
我使用简单的一对一的PUSH/PULL工作者/服务器python代码来发送和接收消息。worker_sock_in = ZMQ</e
浏览 10提问于2019-12-23得票数 1
我使用inproc zmq套接字实现多线程数据共享。我将多个线程客户端连接到一个主线程；每个客户端都有一个推套接字，而主线程有一个拉套接字，充当所有客户端的接收器。以下是一些代码，说明了我的问题的一个变体：import zmq
pull</e
浏览 2提问于2013-08-28得票数 0
我试图在python模式下使用zeroMQ和zeroMQ，每隔几秒钟发送一次大小为4MB的消息。socket = context.socket(zmq.PUSH)
socket</em
浏览 3提问于2011-07-15得票数 8
回答已采纳
3回答
向多个服务器发送消息
、、、、
如果我有一个客户端连接到多个服务器，并尝试发送消息，socket.connect ("tcp://127.0.0.1:5565")socket.connect ("tcp://127.0.0.1:5567"
浏览 3提问于2014-07-16得票数 3
回答已采纳
我有一个基本的ZeroMQ场景，由两个发布者和一个订阅者组成。这在本地计算机上一直运行良好，直到我决定将LAN内不同计算机中的所有进程分开。这就是我如何创建ZeroMQ套接字(简化的Python代码)：发布者代码(两个发布者通用)：self.pub_socket = context.socket(<
浏览 2提问于2012-11-11得票数 5
回答已采纳
4回答
Python中的后台进程
、、、
我需要创建一个后台进程，它将等待传入的命令并执行它们。代码如下： os.path.joinargs']) print 'process exit'
这就是我向进程发送数据的方式建立进程间通信<e
浏览 0提问于2011-08-24得票数 4
回答已采纳
2回答
peer.pyimport time
context = zmq.Context()
socket.setsockopt(zmq.SUBSCRIBE, 'general
浏览 5提问于2014-06-20得票数 3
1回答
当订阅任何前缀时，Java客户端不匹配消息，尽管类似的Python客户端与预期的消息匹配。Python服务器socket = context.socket(zmq.PUB) print(s)
不匹配消息<
浏览 2提问于2015-03-23得票数 0
回答已采纳
ZMQ显然在工作，因为当我将消息推送到pull套接字时，它会接收消息(因此pull和push似乎工作得很好)。但当这条消息随后发布时，似乎没有什么东西能让它流行起来。起初我以为是客户端(基于flash)，但奇怪的是，当我连接到在线服务器(它具有相同的套接字代码)时，它可以毫无问题地接收发布的消息。这是套接字的代
浏览 2提问于2013-04-15得票数 0
在试验ZeroMQ Push/Pull (他们称之为Pipeline)套接字类型时，我很难理解此模式的用途。它被称为“负载均衡器”。我是不是漏掉了什么？如何有效地使用Push/Pull？有没有办法处理这种套接字类型的客户端、任务等的不对称性？# server
import time
context =
浏览 2提问于2012-09-20得票数 47
回答已采纳
我开始在python中使用zeromq和引用。但是，我没有找到任何关于如何处理队列中的消息的文档。我希望将最后接收到的消息与队列的其他元素处理不同。()socket.bind("tcp://*:%s" % port)
while True
浏览 2提问于2017-08-11得票数 1
回答已采纳
1回答
我在使用ZeroMQ时遇到了一个奇怪的问题，一些消息被卡住了，当新消息到达时又被卡住了。这就像是新的消息把卡住的消息推到了门上(我知道，这是个糟糕的对比)。我的代码非常简单：$context = new ZMQContext;$rece
浏览 3提问于2012-06-23得票数 3
回答已采纳
但是，--我很难接收拉套接字上的数据。一旦我试图从电线中提取数据，原子script包就会引发错误address already in use。SOCKET "EURUSD","GBPUSD","USDJPY的拉套接字：import tim
浏览 3提问于2019-12-01得票数 0
回答已采纳
云服务器
ICP备案
对象存储
实时音视频
云直播
腾讯云开发者
