用于recv和send消息的pyzmq轮询器
pyzmq是一个Python的ZeroMQ库，用于实现高效的消息传输。轮询器是pyzmq中的一个重要组件，用于管理多个Socket对象，实现非阻塞的消息接收和发送。
轮询器的作用是同时监听多个Socket对象，通过轮询方式来检查每个Socket是否有新的消息到达或可发送的消息。它可以有效地处理多个Socket对象的事件，提高程序的并发性能和响应速度。
pyzmq轮询器的基本用法是通过创建一个Poller对象，并使用register方法将需要监听的Socket对象注册到轮询器中。然后使用poll方法来等待事件的发生，并返回准备好的Socket对象的列表。通过这些返回的Socket对象，我们可以进行相应的消息接收和发送操作。
pyzmq轮询器的使用场景包括但不限于：
- 多线程/多进程消息通信：在多线程或多进程的程序中，可以使用轮询器来管理不同线程/进程间的消息通信，实现并发处理。
- 客户端/服务器模式：在分布式系统或网络通信中，可以使用轮询器来管理多个客户端和服务器之间的消息传输，实现高效的通信。
- 实时数据处理：在需要处理实时数据的应用中，可以使用轮询器来监控多个数据源，实时接收和处理数据。
- 分布式计算：在分布式计算中，可以使用轮询器来管理多个计算节点之间的通信，实现任务的协调和分发。
腾讯云提供了一系列与消息传输相关的产品和服务，例如消息队列 CMQ、物联网通信 IoTHub、直播云 LVB 等。具体推荐的产品和产品介绍链接如下：
- 腾讯云消息队列 CMQ：提供高可靠、可扩展、低延迟的消息通信服务。了解更多请访问：https://cloud.tencent.com/product/cmq
- 腾讯云物联网通信 IoTHub：提供稳定可靠的物联网消息通信服务，用于连接和管理物联网设备。了解更多请访问：https://cloud.tencent.com/product/iothub
- 腾讯云直播云 LVB：提供全球领先的直播云服务，包括推流、播放、转码、录制等功能。了解更多请访问：https://cloud.tencent.com/product/lvb
注意：以上推荐的腾讯云产品和链接仅供参考，具体选择应根据实际需求和情况进行。
相关·内容
我用一个使用ZeroMQ的路由器实现了一个简单的请求应答架构。这对于PyZMQ版本2.1.11是正确的。不幸的是，当我在PyZMQ版本14.0.0上测试它时，发送方(REQ)可以发送到路由器，然后路由器接收到它的消息并发送给接收者(REP)，但是接收方没有收到消息！当我将PyZMQ从2.1.11升级到14.0.0时，我遇到了这个问题。
REQ <->路由器<-> REP
这是我的代码：
sender.py
import zmq
import time
if __name__=='__main__':
context = zmq.Context(
浏览 7提问于2013-11-12得票数 5
回答已采纳
我使用pyzmq创建了简单的客户机/服务器。
我不确定的一件事是，即使消息是从服务器发送的，.recv()也不会接收消息。它只是忽略了它，抛出了一个我觉得很奇怪的错误。
Client.py
try:
socket = context.socket(zmq.REQ)
socket.connect("tcp://localhost:2222")
print("Sending request")
socket.send(b"send the message")
message = socket.recv(flag
浏览 0提问于2019-08-16得票数 2
1回答
我试图通过在后台线程上接收消息，同时使用控制台输入发送消息，来设置具有zmq.PAIR的两个对等点之间异步通信的hello world样式示例：
server.py
import zmq
import threading
context = zmq.Context()
socket = context.socket(zmq.PAIR)
socket.bind('tcp://*:5556')
def print_incoming_messages():
while True:
msg = socket.recv_string()
pri
浏览 0提问于2019-04-18得票数 2
1回答
使用REQ-REP模式，我尝试使用轮询请求具有超时的多个clients，这样如果server检测到它无法接收来自第一个client的消息，它将超时并转移到下一个client。
但是，似乎在初始超时之后，它无法向第二个client发送下一条消息。
我在这行的zmq.error.ZMQError: Operation cannot be accomplished in current state中得到了一个错误server。
全输出
Connecting to machine...
Successfully connected to machine 127.0.0.1:9999
Successfu
浏览 0提问于2018-01-24得票数 2
回答已采纳
1回答
我正在为Hyperledger锯齿事件设置一个监听器，该监听器带有pyzmq经销商插座和提供的asyncio功能。目前，即使消息被发送到套接字，也会返回期货，但只会在某些时候完成。 奇怪的是，这只适用于连接消息(仅当在它之前睡眠时，如下所示)，但不适用于事件消息。我已经用JavaScript实现了这一点，它工作起来没有问题。看起来问题不在于锯齿，而在于pyzmq的asyncio功能实现或我的代码。 class EventListener:
def __init__(self):
...
ctx = Context.instance()
浏览 8提问于2019-05-06得票数 1
回答已采纳
2回答
我正在尝试实现pyzmq中两个流套接字之间连接的简单示例。
sender.py
import zmq
context = zmq.Context()
socket = context.socket(zmq.STREAM)
socket.bind("tcp://*:5555")
socket.connect("tcp://localhost:5556")
socket.send("message")
receiver.py
import zmq
context = zmq.Context()
socket = context.socket(z
浏览 5提问于2017-11-08得票数 4
回答已采纳
2回答
我用pyzmq设置了两个模拟发布和订阅过程的小脚本。但是，我无法使用inproc传输将消息发送到订阅服务器客户端。我可以很好地使用tcp://127.0.0.1:8080，只是不能使用inproc。
pub_server.py
import zmq
import random
import sys
import time
context = zmq.Context()
socket = context.socket(zmq.PUB)
socket.bind("inproc://stream")
while True:
socket.send_string("
浏览 6提问于2018-02-02得票数 3
通过路由器套接字发送字符串时，我在zeromq python上遇到错误。字符串类型的消息被成功接收，但有时，尽管我一直在尝试使用msg.encode('utf-8')，unicode消息还是抛出了异常"Type Error: unicode not allowed. use send_unicode".。BUt我想不出一个办法来克服它。我使用的是python 2.7.3。我没有使用pyzmq (仅限导入zmq )。期待您的建议:)谢谢
如果后端位于套接字中：
request=backend.recv_multipart()
#pr
浏览 2提问于2015-03-12得票数 6
.recv()，您可以提供一个可选的参数int flags，它可以是“任意有效的int flags标志”。不幸的是，我找不到任何关于这些标志实际上是什么的参考。
那么，在.recv()中有效的标志是什么？
我用pyzmq和zeromq标记标记了这个问题，因为我相信答案可能并不是pyzmq特有的。
浏览 1提问于2017-11-16得票数 4
回答已采纳
1回答
pyzmq对套接字卡住
、、、
我遵循pyzmq文档中的双向对套接字示例。我用下面的代码创建了两个文件socket1.py import zmq
import random
import sys
import time
port = "5556"
context = zmq.Context()
socket = context.socket(zmq.PAIR)
socket.connect("tcp://localhost:{}".format(port))
print("Socket created")
i = 0
while True:
msg = socke
浏览 19提问于2020-04-14得票数 0
回答已采纳
1回答
我已经连接了zeromq，"msg_in“已经在排队了。如果在一段时间内没有新消息，队列将进入超时设置。如何设置超时。以下是核心代码
requestDict = {"id":111, "name":"test"}
zmqConn.mSocket.send(json.dumps(requestDict), flags=zmq.NOBLOCK)
msg_in = zmqConn.mSocket.recv()
浏览 0提问于2012-10-17得票数 4
回答已采纳
当服务器不可用时，很难正确关闭一个简单的基于pyzmq的客户机。下面是两个片段。
首先是服务器。这或多或少就是pyzmq的例子。这里没有特殊代码：
import zmq
import json
port = 5555
context = zmq.Context()
socket = context.socket(zmq.REP)
socket.bind("tcp://*:{0}".format(port))
while True:
message = socket.recv_json()
print(json.dumps(message))
soc
浏览 1提问于2019-11-01得票数 1
回答已采纳
我试图在ZeroMQ中建立一个PUB子通信，在C++中使用PUB，而在python中使用。我使用python3.8、ZeroMQ 4.3.2、pyzmq 18.1.1和cppzmq 4.5.0。
酒馆：
int main()
{
Sleep(10000);
zmq::context_t context(1);
zmq::socket_t publisher(context, ZMQ_PUB);
publisher.bind("tcp://*:5556");
in
浏览 2提问于2019-12-10得票数 2
回答已采纳
我对ZeroMQ非常陌生，并试图构建一个非常基本的消息传递系统。这段代码很大程度上是基于的例子，有些曲折。
由于某种原因，在最后一条消息到达frontend套接字(hbm，tx)后，代码抛出错误，我不确定它的来源
抱歉，代码/输出太长了，我觉得很重要的一点是要强调问题所在，并帮助调试。
下面是我的代码+输出：
s_frontend = "ipc://frontend.ipc"
s_backend = "ipc://backend.ipc"
import time
def hbm():
"""Worker task, usi
浏览 0提问于2020-05-18得票数 2
回答已采纳
1回答
如何轮询zmq和变量？
、、、
我有python服务器，它等待设置全局标志并退出。
在几个线程中，我的代码使用zmq.Poller等待消息。它超时，打印一条心跳消息，然后在poller上等待一条新消息：
def timed_recv(zock, msec=5000.0):
poller = zmq.Poller()
poller.register(zock, zmq.POLLIN)
events = dict(poller.poll(msec))
data = None
if events and events.get(zock) == zmq.POLLIN:
# if
浏览 2提问于2015-11-17得票数 0
回答已采纳
1回答
cProfile在背叛我吗？
、、、、
我想知道为什么我的基于pyzmq和protobuf的消息传递要比预期慢得多，所以我使用cProfile来检查您在文章末尾找到的脚本。
protoc --python_out=. rpc.proto
python -m cProfile -o rpc.pstats ./test_rpc.py
返回
3.604 sec for 10000 messages, 360.41us/m, 2774 m/s
和
python -m pstats rpc.pstats
rpc.pstats% sort tottime
rpc.pstats% stats 10
提供给我(仅供客户端进程使用)：
浏览 2提问于2015-04-29得票数 2
回答已采纳
1回答
我正在使用PyZMQ创建一个简单的对/对通信原型消息传递模式。
PairServer
import zmq
import random
import sys
import time
port = "9999"
context = zmq.Context()
socket = context.socket(zmq.PAIR)
print("Binding socket to port: " + str(port))
socket.bind("tcp://*:%s" % port)
print("Connection has been es
浏览 4提问于2017-12-20得票数 2
回答已采纳
我正在尝试创建一个简单的信使程序，我刚刚介绍了使用c语言进行tcp/ip套接字编程的基础知识。
但是，通过在time循环中包含“recv”和“send”，客户机-服务器每次只能进行一次通信。我正在考虑让我的信使程序能够立即发送和接收任何信息。例如，如果另一方发送这么多消息，我的程序应该能够接收多条消息。
我猜这一切都归结于recv()和send()不能在while循环中单独执行的问题。如何管理这些函数以异步操作？
我想的B计划就是让服务器将客户端之间的所有消息记录在一个日志文件中，并让客户机每隔一秒就同步它的聊天。
这是实用的信使应用程序所做的，还是有更有效的方法来做到这一点？
浏览 5提问于2015-01-03得票数 2
回答已采纳
1回答
据我所知，SNS可以向订阅者推送消息。我有一个简单的脚本，将推送消息到SQS。但我想要做的基本上是:我有一个社交网络主题，有一个EC2实例，有一个SQS。订阅了SNS主题的SQS。
我想做以下事情，当我在社交网络中创建一个新的消息时，我希望EC2收到这个通知去检查一个服务质量。我可以做最后一部分(去检查SQS)，但不知道如何接收消息？
例如,
PUB：
context = zmq.Context()
socket = context.socket(zmq.PUB)
socket.bind("tcp://*:%s" % '5556')
socket.send(&#
浏览 1提问于2013-05-08得票数 1
回答已采纳
第36页EMX用户手册指出：“可通过可选的毛刺滤波器在上升沿或下降沿激活中断。”然而，Redpine信号RS9110-N-11-21数据表状态：“有效高，电平触发。”该中断由WiFi器件触发。在C#代码中，如果我使用InterruptEdgeLevelHigh或InterruptEdgeLevelLow参数，我会收到一个参数异常。这是可以的，因为它符合EMX用户手册。如果使用InterruptEdgeBoth、InterruptEdgeHigh或InterruptEdgeLow，则无法接收中断。我不确定这是不是因为设备使用了“激活的高电平触发”。
如果RedPine被限制为“触发级别”，我是否
浏览 0提问于2013-01-11得票数 0
1回答
我正在尝试将下面的基于这里用C编写的0MQ的here示例转换为：。
def test_http_socket():
ctx = zmq.Context()
sock = ctx.socket(zmq.ROUTER)
sock.setsockopt(zmq.ROUTER_RAW, 1)
sock.bind("tcp://*:8080")
while True:
id_bytes = sock.recv()
print("id=",id_bytes)
request = sock
浏览 3提问于2013-11-26得票数 4
回答已采纳
我一直在尝试让zeromq在Fedora11上使用Python，因为它需要Python2.7，所以我安装了ActivePython。我使用easy_install安装了pyzmq，它安装得很好。当我从这里运行hello world示例时：
它在以下位置阻塞：
socket.recv()
我读到有一些问题，你发送消息的速度可能比客户端接收消息的速度快，这可能会导致客户端错过“第一条”消息。所以，我不确定的是，这是否是预期行为，或者至少是可能的行为。我本以为一个简单的Hello World示例可以开箱即用……
我想要弄清楚的是，到底是代码还是我的安装导致了问题。
有没有人遇到过类似的事情？
浏览 0提问于2011-11-10得票数 1
回答已采纳
我为Publisher编写了以下代码，它实例化了几个类实例并发布了一些消息。
然而，我在订阅方没有收到任何信息。
Publisher
import zmq
import time
from multiprocessing import Process
class SendData:
def __init__(self, msg, port):
self.msg = msg
self.port = port
ctx = zmq.Context()
self.sock = ctx.socket(zmq.PUB)
浏览 0提问于2016-11-10得票数 1
回答已采纳
2回答
zmq发布c++订阅
、、、、
我在zhelpers.hpp)中有一个ZeroMQ发布服务器(在python3中使用ZeroMQ订阅服务器)(使用pyzmq). )
问题是，订户中没有收到任何消息。我想，ZeroMQ过滤器有一个问题。我不知道如何在.setsockopt()中正确地使用c++来增强来自publisher的消息。
Python发行者：
import zmq
context = zmq.Context()
socket = context.socket(zmq.PUB)
context = zmq.Context()
socket = context.socket(zmq.
浏览 2提问于2016-06-17得票数 0
回答已采纳
1回答
我发现了一个类似的问题，，但它不能解决我的问题。
我想控制推送套接字队列中的消息数量，但是它不能工作，并且仍然排队1000条消息。
所以我想知道如何设置推插座的hwm。提前谢谢。
我的环境是: libzmq 4.0.4，pyzmq 14.1.0，python 3.3
这是我的密码：
server.py
#!/usr/bin/env python3
# -*- coding: utf-8 -*-
import random
import zmq
class TestPush(object):
def __init__(self):
self.ctx = zmq.
浏览 0提问于2014-03-24得票数 4
2回答
我正在尝试将来自客户端的查询发送到基础服务器，然后转发到基础服务器所连接的另外两个服务器。
(这两个服务器在其数据库中找到与查询匹配的内容，如果匹配，则返回查询，如果没有匹配，则不发送任何内容)
首先，我将查询从基础服务器发送到名为ts1的第一个服务器，如果没有收到响应，我会将其发送到名为ts2的第二个服务器。如果我也没有收到来自ts2的回复，我就会向客户端发送一个错误主机消息。
为了完成这个任务，我尝试了while和inner循环，但我的程序在发送第一个查询后挂起。因为ts1服务器在第一次查询时不发送任何内容。
我如何纠正我的代码，使它不会挂起，并执行整个代码？也许它是非阻塞的或阻塞的套接字
浏览 2提问于2020-03-27得票数 0
线融化了我的大脑。我已经看到了几种不同的实现worker + keepalive模型的方法，但很难找出最好的方法。以下是代码的简化版本：
def start_thread(function):
t = Thread(target=function)
t.setDaemon(True)
t.start()
def worker:
run = True
start_thread(keepalive_fn)
msg = recv() #blocking
while msg is not None and run:
proce
浏览 0提问于2012-04-21得票数 1
3回答
我试图使用pyzmq运行一段简单的代码。我使用Python2.7和pyzmq 14.5
$ python --version
Python 2.7.6
$ sudo find /usr -name "*pyzmq*"
/usr/local/lib/python2.7/dist-packages/pyzmq-14.5.0.egg-info
/usr/lib/python2.7/dist-packages/pyzmq-14.0.1.egg-info
下面是我试图运行的代码：
import zhelpers
context = zmq.Context.instance()
serv
浏览 9提问于2015-09-18得票数 14
1回答
我可能遗漏了一些很小的东西，但我无法使用正式的Pyzmq包()在Python中获得一个简单的发布子示例。
我正在使用最新的ZeroMQ稳定版本4.0.3，并且能够很容易地在c ++中获得一个简单的示例，我在Mac和Ubuntu机器上都试过了。(我期待对此提出任何意见；)
这是我的密码：
sub.py
import zmq
ctx = zmq.Context()
s = ctx.socket(zmq.SUB)
s.connect("tcp://127.0.0.1:5567")
s.setsockopt(zmq.SUBSCRIBE,'')
while True:
浏览 7提问于2013-12-18得票数 6
回答已采纳
我试图通过使用pyzmq的ZeroMQ连接发送jpeg图像文件，但是输出是输入的3倍，不再是有效的jpeg。我加载图像并发送..。
f = open("test1.jpg",'rb')
strng = f.read()
socket.send(strng)
f.close()
我接受和保存..。
message = socket.recv()
f = open("test2.jpg", 'w')
f.write(str(message))
f.close()
我是新来的zmq，我找不到任何关于发送图像的信息。是否有人通过ZeroM
浏览 4提问于2014-07-16得票数 6
回答已采纳
最近我一直在学习套接字编程，最后我从中找到了一些很好的例子。
在poll 下有一个使用的聊天服务器示例。
码
(聊天服务器接收客户端消息并向所有其他客户端发送消息)
在我逐行阅读代码并完全理解了这个示例之后，我突然意识到这个设计是多么的巧妙和整洁。
基本上，它使用poll来监视一切，服务器监听套接字accept以获取新传入的TCP连接和所有现有的TCP套接字。不需要额外的线程或进程。
然后我开始问自己：
似乎我可以使用多个进程(如果太复杂的话，可以使用多个线程)来达到同样的效果。以聊天服务器为例，设计如下：
主进程处理新传入的TCP连接，并向全局数组all_sockets添加新的连接
浏览 4提问于2019-11-15得票数 1
我正在尝试学习套接字编程，目前有以下server和client代码，但问题是服务器和/或客户端不能同时发送和接收消息，它们轮流发送和接收消息。
我已经看了下面的例子，但答案似乎不能解决问题，或者我理解错了。
服务器
import socket
import threading
s = socket.socket()
host = socket.gethostname()
port = 8080
s.bind((host, port))
s.listen(1)
print("Waiting for connections")
conn, addr = s.accept()
pr
浏览 0提问于2020-02-25得票数 0
1回答
如何避免高cpu使用率？
、、、、
我创建了一个单独运行的zmq_forwarder.py，它将消息从应用程序传递到sockJS连接，我目前正在研究如何让一个烧瓶应用程序通过zmq接收来自sockJS的消息。我正在粘贴我的zmq_forwarder.py的内容。我对ZMQ很陌生，我不知道为什么每次我运行它时，它都使用100%的CPU负载。
import zmq
# Prepare our context and sockets
context = zmq.Context()
receiver_from_server = context.socket(zmq.PULL)
receiver_from_server.bind(&#
浏览 1提问于2014-02-21得票数 2
回答已采纳
我需要实现一个超时套接字，send()/recv()系统调用在超时之后应该返回该套接字。我认为标准的方法应该是，在select()/recv()之前调用send()/recv()。下面是我从ffmpeg源代码复制的示例代码：
int ff_network_wait_fd(int fd, int write)
{
int
浏览 2提问于2014-08-18得票数 1
回答已采纳
现在，我的代码中有以下结构。请求被直接解析为JSON。
while True:
if self.rest_sock.poll(timeout=0):
request = self.rest_sock.recv_json()
...
我想用一个函数的异步调用来替换这个循环(以减少CPU的时间，如这里所解释的：)。这是通过使用on_recv()将函数注册为事件处理程序来完成的。但是没有解析JSON消息。我想我可以自己解析它，如这里所解释的，。但是，我想知道为什么在异步接收像socket.recv_json()这样的json消息时，没有任何等同于on_recv_json
浏览 4提问于2021-07-15得票数 0
回答已采纳
为了理解基于生成器的并发性，我试着遵循D.Beazley的演讲。我不明白future_monitor的目的，我想知道去掉这个函数会带来什么后果？下面是异步服务器的实现，以及在没有future_monitor函数的情况下我的实现。
也许我误解了未来和add_done_callback是如何使用并发库的。
我不知道：
在主进程中运行什么以及委托给其他进程什么？ add_done_callback如何干扰主进程，它是否会出现在主线程的中间？
据我所知：
提交给池的函数在其他进程中执行，即主进程、fib(n))add_done_callback 和其他进程的返回在返回时在将来的对象中注册(我设想在两个
浏览 0提问于2022-06-19得票数 2
回答已采纳
我无法接收由ZeroMQ订阅者的C++发布服务器通过C++发送的消息。通过publisher发送的消息可以由Python订户接收，但通过C++发布服务器发送的消息不能接收。
这里有更多的细节和简化的代码。
OS: Ubuntu18.04.5LTSC++ 20 (cppzmq 4.7.1)Python 3.6.9 (pyzmq 22.0.3)
Python订阅服务器
import zmq
import time
if __name__ == '__main__':
context = zmq.Context()
socket = context.socket(
浏览 1提问于2021-04-07得票数 0
1回答
我正在编写一个简单的客户机/服务器套接字程序，客户端与服务器连接并进行通信，然后将出口消息发送到服务器，然后服务器关闭连接。代码如下所示。
server.py
import socket
import sys
from threading import Thread
try:
sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
# This is to prevent the socket going into TIME_WAIT status and OSError
# "Address alr
浏览 1提问于2018-01-08得票数 0
1回答
我在使用ZeroMQ时遇到了一个奇怪的问题，一些消息被卡住了，当新消息到达时又被卡住了。这就像是新的消息把卡住的消息推到了门上(我知道，这是个糟糕的对比)。
我的代码非常简单：
rep.php
$context = new ZMQContext;
$receiver = new ZMQSocket($context, ZMQ::SOCKET_PULL);
$receiver->connect("tcp://localhost:8022");
$receiver2 = new ZMQSocket($context, ZMQ::SOCKET_PULL);
$receiver2
浏览 3提问于2012-06-23得票数 3
回答已采纳
1回答
是否有可能在一个线程中有一个发布者和订阅者？不管我做什么
socket_send = context.socket(zmq.PUB)
socket_send.bind("tcp://127.0.0.1:5559")
socket_recv = context.socket(zmq.SUB)
socket_recv.connect("tcp://127.0.0.1:5559")
socket_recv.setsockopt(zmq.SUBSCRIBE, "id1")
订阅不起作用(即消息不到达)。当我使用socket_recv.bind()时，发
浏览 1提问于2014-12-24得票数 0
回答已采纳
1回答
我正在构建一个讨论板风格的服务器/客户端应用程序，其中客户端连接到服务器，能够发布消息、读取消息和退出。
请参阅下面的客户端代码：
import socket
target_host = "0.0.0.0"
target_port = 9996
#create socket object
client = socket.socket(socket.AF_INET,socket.SOCK_STREAM)
#connect the client
client.connect((target_host,target_port))
#receiving user name pr
浏览 1提问于2015-11-28得票数 0
如果我用pyzmq连接到一个不存在的套接字，我需要点击CTRL_C来停止程序。谁能解释一下为什么会发生这种情况？
import zmq
INVALID_ADDR = 'ipc:///tmp/idontexist.socket'
context = zmq.Context()
socket = context.socket(zmq.REQ)
socket.connect(INVALID_ADDR)
socket.send('hello')
poller = zmq.Poller()
poller.register(socket, zmq.POLLIN)
c
浏览 3提问于2011-10-30得票数 2
回答已采纳
在C++ ZMQ发布程序中，我将字符串打包到message_t中，如下所示：
int main()
{
zmq::context_t context(1);
zmq::socket_t socket(context, ZMQ_PUB);
socket.bind("tcp://*:5555");
socket.setsockopt(ZMQ_CONFLATE, 1);
std::cout << "Server Up and Sending\n";
while(true)
{
浏览 4提问于2017-06-30得票数 1
1回答
根据ZeroMQ文档，当排队的消息数量达到高峰时，pub套接字就应该丢弃消息。
在下面的示例中，这似乎不起作用(是的，在绑定/连接之前设置了hwm )：
import time
import pickle
from threading import Thread
import zmq
ctx = zmq.Context()
def pub_thread():
pub = ctx.socket(zmq.PUB)
pub.set_hwm(2)
pub.bind('tcp://*:5555')
i = 0
while True:
浏览 2提问于2018-11-17得票数 2
我试图在PUB/SUB领域内使用pyzmq multiprocessing.Process套接字原型。
我有一个订户：
import time
import collections
import zmq
context = zmq.Context()
socket = context.socket(zmq.SUB)
socket.setsockopt(zmq.SUBSCRIBE, b"")
socket.connect("tcp://localhost:5000")
nb_recv = 0
begin = time.time()
counter =
浏览 2提问于2017-10-12得票数 0
2回答
我正在尝试写一个双向聊天程序使用UDP在C++。下面是我的代码：
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <netdb.h>
#include <iostream>
#include <cstring>
#include <unistd.h>
#include <s
浏览 1提问于2015-04-16得票数 0
我所访问的TCP服务器(试图使用内置的节点TLS套接字)期望按一定顺序(发送、接收成功、发送更多消息、成功时发送更多消息、发送更多消息等)进行发送/接收的握手过程。接收消息没有任何东西可以让我知道它响应的是哪一个发送，所以我无法轻松地使用内置的TCP节点库的流特性。
有什么办法在Node处理这个案子吗？
示例(python)，这是流程的示例：
s.send("hello")
s.send("send this 1")
reply = s.recv()
message = reply[0]
if message == OK:
浏览 2提问于2019-07-18得票数 0
2回答
我试图编写一个消息队列实现，这样我的线程就可以交换数据。为了保持简单，队列只负责发送指向内存的指针。只有一个线程可以发送消息，只有一个线程可以读取消息。
struct mq_t表示消息队列。
mq_t.messages是指针的循环缓冲区。
mq_t.send是上一次发送消息的索引。
mq_t.recv是要接收的下一条消息的索引。
我想知道一些事情：
线程安全:我没有使用互斥锁或锁，但我认为代码非常线程安全。这是真的吗？
在代码中，我使用像while (isempty(queue));这样的东西。是否有更好的方法来处理这些事情，比如挂起线程直到内存发生变化？
跨平台:我的代码是依赖于非跨平台代码
浏览 0提问于2013-08-03得票数 6
回答已采纳
如文档所述，ZMQ套接字是。所以我想标题的答案是“不”。
不过，我仍然不知道如何使用ZMQ实现一个非阻塞的模式：
具体来说，客户端有一个主线程，用于处理来自(线程安全的)消息队列的业务处理消息。消息来自各种来源，如网络、计时器、I/O等。主线程偶尔希望向远程服务器发送请求，但不希望等待响应(可能需要一段时间才能到达)。
通常，我会使用两个线程：
主消息处理循环线程。这将在REQ/REP套接字上请求send()
一个辅助侦听器线程，它将等待服务器的响应。这将在套接字上使用阻塞的recv()，并将响应推送到主线程的队列。
如何使用ZeroMQ实现这一目标？辅助线程是否应该打开inp
浏览 1提问于2013-07-10得票数 2
回答已采纳
2回答
MPI超过缓冲器
、、、、
假设我有两个处理器：
第一个P0
调用MPI_Send将消息A发送给p1；
呼叫MPI_Recv从p1接收B；
第二个P1
调用MPI_Send将消息B发送给p0；
呼叫MPI_Recv从p0接收A；
如果消息A和B的大小都超过了系统缓冲区，会发生什么情况？
浏览 5提问于2017-05-26得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
