当收到所有回复时，非阻塞zmq发送/接收和处理
当收到所有回复时，非阻塞zmq发送/接收和处理是指使用ZeroMQ（zmq）进行消息传递时的一种通信模式。在这种模式下，发送方可以在等待接收方回复的同时继续发送其他消息，而不需要等待接收方的回复。
非阻塞zmq发送/接收和处理的优势在于提高了系统的并发性和响应性能。通过允许发送方在等待回复时继续发送其他消息，可以减少通信的延迟时间，提高系统的吞吐量。同时，接收方也可以在处理接收到的消息时不受发送方的阻塞影响，提高了系统的并发处理能力。
这种通信模式适用于需要高效处理大量消息的场景，例如分布式系统中的任务调度、消息队列、实时数据处理等。通过使用非阻塞zmq发送/接收和处理，可以实现高效的消息传递和处理，提升系统的性能和可扩展性。
腾讯云提供了一系列与消息传递相关的产品和服务，例如腾讯云消息队列 CMQ、腾讯云消息队列 CKafka 等。这些产品可以帮助用户实现高效的消息传递和处理，满足不同场景下的需求。
腾讯云消息队列 CMQ 是一种高可靠、高可用的分布式消息队列服务，支持消息的发布和订阅，以及消息的持久化存储和可靠传递。用户可以通过 CMQ 实现异步通信、解耦系统组件、削峰填谷等功能。了解更多关于腾讯云消息队列 CMQ 的信息，可以访问腾讯云官网的产品介绍页面：腾讯云消息队列 CMQ
腾讯云消息队列 CKafka 是一种高吞吐量、低延迟的分布式消息队列服务，适用于大规模数据流的处理和分发。CKafka 提供了多种消息传递模式，包括发布/订阅、点对点和批量消费等，可以满足不同场景下的需求。了解更多关于腾讯云消息队列 CKafka 的信息，可以访问腾讯云官网的产品介绍页面：腾讯云消息队列 CKafka
通过使用腾讯云的消息队列服务，用户可以轻松实现非阻塞zmq发送/接收和处理的功能，提升系统的性能和可靠性。
相关·内容
我用朱莉娅和包裹。
我成功地使用ZMQ模式交易商/路由器发送和接收消息。
以下是我如何收到一条信息：
dataRecv = bytestring(ZMQ.recv(sockRouter))
但它挡住了。我需要的是非阻塞。
在c++和ZeroMQ中，我们可以这样做：
zmq_msg_recv(&message, socket, 0); // blocking
zmq_msg_recv(&message, socket, ZMQ_DONTWAIT); // non-blocking
在朱莉娅，我找到了一个关键词：ZMQ.ZMQ_DONTWAIT，但我不知道如何使用它。我试过这样做：
浏览 1提问于2015-11-12得票数 3
回答已采纳
3回答
我正在尝试将ZMQ集成到一个严重依赖CASyncSocket (CASyncSocket)的现有windows应用程序中。
我有一个CWinThread派生的UI线程(没有GUI)，它使用CAsyncSocket与服务器异步通信。我想添加一个ZMQ inproc通信线路来处理从服务器接收到的数据(基于REQ/REP )到应用程序中的其他线程的通信。
使用CAsyncSocket，每当要接收的套接字上有新的数据可用时，MFC框架就会调用OnReceive方法(这可能是对核心MFC专家的过度简化)。
在ZMQ中有这样的机制吗？或者，我是否需要添加UI线程启动的额外专用WorkerThread来处理
浏览 6提问于2014-11-21得票数 4
回答已采纳
我使用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
在Python上，.recv()/.send()操作是阻塞的，这对于REQ/REP.来说是完美的。
在Golang，我必须将一个zmq.DONTWAIT传递给.recv()和.send()操作，这样才能使它工作。
但问题是，流程需要锁定步骤，所以：
server.recv()
client.send()
client.recv()
server.send()
在3到4之间，奇怪开始了，因为它们是异步的。
当客户端发送了一条消息，而服务器尚未收到它，但客户端试图接收响应时，锁定步骤不再是锁定步骤。
与zmq.DOBLOCK相比，是否有某种zmq.DONTWAIT？
还是我
浏览 2提问于2016-11-04得票数 3
回答已采纳
1回答
我正在编写一个C++/ZMQ脚本，它让一个订阅者从一个单独的脚本运行的发布者那里获取数据。我不能编辑发布者代码，我需要获取ZeroMQ订阅者接收消息的时间。
基本上，我有：
void *zmq_subscriber_ = zmq_socket( context, ZMQ_SUB );
zmq_setsockopt( zmq_subscriber_, ZMQ_SUBSCRIBE, NULL, 0 );
while ( ( zmq_msg_recv( &msg, zmq_subscriber_, ZMQ_DONTWAIT ) ) < 0 )
{ usleep( 1000 ); }
浏览 35提问于2018-06-14得票数 3
回答已采纳
1回答
我正在执行这个服务器程序，从多个客户端接收，但是在一个客户端收到第一条消息后，服务器将接收数据，然后它不会等待其他客户端的请求，只会显示第一个客户端的数据并停止。
另外，我无法成为使用相同linux机器的其他VM的客户端。我不知道如何修改它，以便让服务器从更多的客户端接收。
1.我在不同的VM-s中运行同一个客户端程序，并试图将数据发送到服务器。只传递一条客户端消息，而其他客户端则无法发送，只能等待。
谢谢
import zmq
import json
ports = ["192.168.1.24:10000"]
context = zmq.Context()
print(
浏览 0提问于2018-02-23得票数 1
我有一个使用ZeroMQ的java程序。
但是如果接收到context.term();超时，我发现程序在message( recvMsg() )中被阻塞了！
ZMQ.Context context = ZMQ.context(1);
ZMQ.Socket socket = context.socket(ZMQ.REQ);
socket.connect(mAddress);
ZMsg ZM = new ZMsg();
ZM.add(qString);
ZM.send(socket, true);
socket.setReceiveTimeOut(mTimeout);
浏览 0提问于2017-09-04得票数 1
回答已采纳
我有一个Python脚本，其中绑定了几个(例如，5) ZMQ接收器套接字，如下所示：
receiver_1 = context.socket(zmq.PULL)
receiver_1.bind("tcp://*:5555")
...
receiver_5 = context.socket(zmq.PULL)
receiver_5.bind("tcp://*:5559")
receivers = [receiver_1, ..., receiver_5]
然后我启动一些Google引擎实例，它们连接相应的发送方套接字。
我想并行地从这些套接字中提取，所以我尝试用
浏览 3提问于2014-06-25得票数 5
我正在尝试服务器和客户端的Zeromq Hello world示例。以下是示例代码
//
// Hello World client in C++
// Connects REQ socket to tcp://localhost:5555
// Sends "Hello" to server, expects "World" back
//
#include <zmq.hpp>
#include <string>
#include <iostream>
int main ()
{
// Prepare ou
浏览 1提问于2013-09-27得票数 1
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
回答已采纳
我正在为我们的项目使用ZMQ，并编写了一个工厂，它根据所需的消息类型创建ZMQ客户端。然而，我发现一个问题是，有时TrySendFrame返回false，而大多数时候它返回true。有什么办法可以纠正这个问题吗？
数据保持不变，代码保持不变，地址和一切保持不变，但偶尔会从TrySendFrame返回false。
我不能确定它为什么会失败。在使用SendFrame而不是TrySendFrame之后，它在某些情况下会永远被阻塞。
public ZmqPushClient(string address, bool isByteData = false) : base(address, isByteD
浏览 30提问于2019-09-02得票数 1
我有这个代码
context = zmq.Context()
app_worker = context.socket(zmq.PUSH)
app_worker.bind("tcp://127.0.0.1:9005")
app_sub = context.socket(zmq.SUB)
app_sub.connect("tcp://127.0.0.1:9004")
app_sub.setsockopt(zmq.SUBSCRIBE,'sometopic')
while True:
msg = app_sub.recv()
msg
浏览 0提问于2013-09-19得票数 1
我有一个分布式控制系统，在这个系统中，我每秒发送一次心跳。在接收端，如果超过2秒没有收到消息，我需要采取行动。问题是，当zeroMQ在等待答案时，我不能做其他任何事情，比如检查从收到最后一条消息到现在已经过了多少时间。
我现在拥有的代码如下。有没有人知道如果超过2秒没有收到任何消息，我如何采取行动？欢迎所有提示！
使用Pieter Hintjes的提示进行编辑我将轮询添加到代码中，但我仍然不能工作。还有其他想法吗？
from datetime import datetime
import zmq
context = zmq.Context()
# Set up subscriber conn
浏览 2提问于2013-03-21得票数 2
在阅读zeromq指南时，我看到了客户机代码，它在一个循环中发送100 k请求，然后在第二个循环中接收答复。
#include "../include/mdp.h"
#include <time.h>
int main (int argc, char *argv [])
{
int verbose = (argc > 1 && streq (argv [1], "-v"));
mdp_client_t *session = mdp_client_new ("tcp://localhost:5555&#
浏览 4提问于2014-12-03得票数 8
回答已采纳
CZMQ库为zstr和zframe类(zstr_recv_nowait()和zframe_recv_nowait())提供了nowait选项，但没有任何类似于zmsg_recv_nowait()。有什么解决方案吗？而不是使用带有ZMQ_DONTWAIT标志的zmq_msg_recv。我的代码是：
zmq_pollitem_t items[] = { {sock, 0, ZMQ_POLLIN, 0} };
zmq_poll(items, 1, 10);
/* now receive all pending messages */
while (1) {
zmsg_t *msg = zms
浏览 2提问于2013-02-14得票数 0
回答已采纳
我试图在python中使用带有两个套接字的ZeroMQ Poller()功能：
import zmq
# Prepare our context and sockets
context = zmq.Context()
receiver = context.socket(zmq.DEALER)
receiver.connect("ipc:///tmp/interface-transducer")
subscriber = context.socket(zmq.SUB)
subscriber.bind("ipc:///tmp/fast-service")
su
浏览 5提问于2020-10-30得票数 1
回答已采纳
2回答
我正在使用zmq /rep模式通信。实现非常简单，req发送一些数据并等待recv。代表接收数据，处理和回复。
//REQ
zmq_connect
zmq_send
zmq_recv //blocking
zmq_close
//REP
zmq_bind
while(true) {
while(data_received) {
//miscellaneous process
zmq_recv //non-blocking
Print zmq_error_no if zmq_recv fails
}
zmq_send
}
在代表端，将在zmq_recv超
浏览 21提问于2015-03-11得票数 7
回答已采纳
我现在正在用Python实现一个数据订阅者，它订阅了一个数据发布者(实际上是一个ZeroMQ发布者套接字)，并且在任何新消息被输入后都会得到通知。在我的订阅服务器中，消息在收到后被转储到数据处理器。当完成时，订阅者也会得到处理器的通知。由于数据处理器是用C++编写的，所以我必须用一个简单的C++模块来扩展Python代码。
下面是我的数据订阅者的一个简化的可运行代码示例。代码main.py，其中模块proc表示处理器，订阅localhost:10000上的ZeroMQ套接字，设置回调，并通过调用proc.onMsg将接收到的消息发送给处理器。
#!/bin/python
# main.py
浏览 5提问于2016-05-29得票数 4
回答已采纳
在我的代码中，我只能接收来自我所连接的第一个发布者(端口5556)的消息。
那么，在连接到第二个连接(5557)之前，是否需要关闭第一个连接(5556)？
如果是这样的话，那么在ZeroMQ指南的语句中
订阅者可以连接到多个发布服务器，每次使用一个连接呼叫。然后，数据将到达并被交织(“公平排队”)，这样就不会有单个发布者淹没其他发布者。
短语“每次使用一个连接调用”是否意味着我们需要在连接到第二个发布者之前关闭第一个连接？
如何同时连接到多个发布者以接收来自两者的消息。
代码：
#include <zmq.hpp>
#include
int main (int argc,
浏览 0提问于2018-03-07得票数 0
我目前正在处理一个相当大的数据处理任务，需要拆分和分配处理。我有一个使用ZeroMQ的PUSH / PULL机制的完全工作的管道原型-“处理”数据正在发送，并正常完成。
但是，一旦数据被扇出，处理完成后，我需要指示工作进程(在while/true循环中运行)终止。我认为在这方面使用ZMQ的PUB/SUB机制是明智的。然而，工人没有接收到任何控制消息。
令人沮丧的是，如果我切换到推/拉机制，工作进程会收到消息并正确终止。
我从原型中复制了一些代码：
您可以看到生产者(向worker发送数据的位)创建并绑定到一个控制套接字(第19行)，worker也绑定了该套接字(第53行)。一旦来自生产者的工
浏览 0提问于2012-12-06得票数 4
回答已采纳
我正在尝试创建一个简单的，它连接到一个request，然后发送一个请求。
的规范说，REQ-套接字
在没有连接的对等点时，应在发送或返回适当的错误时阻塞。
我用这个代码试了一下：
#include <zmq.hpp>
zmq::context_t context;
zmq::socket_t requestSocket(context, ZMQ_REQ);
requestSocket.connect("inproc://test");
requestSocket.send(0, 0);
但是send不会阻塞，也不会抛出错误。当我在创建REP-套接字之后，它不
浏览 3提问于2014-08-11得票数 0
回答已采纳
1回答
我正在尝试使用带有zmq4套接字的gob (来自pebbe的zmq4)。zmq4套接字没有io设备，因此gob似乎不可能直接读写：
我不能在&client ( type **zmq4.Socket )的参数中使用io.Writer类型：zmq4.Socket没有实现io.Writer (缺少写方法)
一个zmq4发送函数，SendMessage()，接受一个interface{}，所以我使用它来发送。
在服务器端，zmq4接收函数正在返回string、[]byte、[]string或[][]byte。我使用的是RecvMessage()，它返回一个[]string。
可以写入bytes
浏览 9提问于2020-04-25得票数 2
1回答
这就是我想要实现的--
REST服务(部署在多个实例上)获得一个请求，对其进行处理，并将其传递给一组工作实例。
工作人员完成较大部分的工作，准备响应并将其发送回来。
与此同时，主服务已经完成了一些与原始请求相关的工作，将其与worker响应合并，并将其发送回请求连接上的调用者。
如何通过ZMQ对此进行建模？
我已经尝试过这样做--创建一个推送套接字，并在服务实例中执行“绑定”。-工作人员“连接”到相应的拉动插座。-由于相同的服务实例必须获取响应，而不是其他服务实例，因此每次发送消息到推送套接字时，服务都会附加一个响应队列名称。- Worker接收消息，执行工作，并在消息中给出的响应队列上推送(
浏览 4提问于2015-11-03得票数 1
2回答
我有一个串行设备，正在通过串行服务器转换为TCP/IP。这似乎是正确的，因为其他应用程序可以这样连接。
在我的应用程序中，我试图使用ZeroMQ ZMQ_STREAM向设备发送信息请求，并等待回复。
// from it's own thread: threadTx
zmq::socket_t soc_tx(zmq_ctx, ZMQ_STREAM);
soc_tx.connect("tcp://10.10.10.100:4003");
std::string msg("hello");
zmq::message_t zmsg(msg.c_str(),
浏览 3提问于2018-07-26得票数 1
回答已采纳
我有两个使用CZMQ的独立的C程序。一个是客户端，另一个是服务器。服务器将数据从文件传输到客户端，客户端将接收到的数据写入一个名为“testdata_out”的新文件。一旦客户端从服务器接收到最后一块数据，客户机就会退出。
问题是服务器位于那里，等待向客户端发送更多数据，但客户端程序已经完全退出。我在GDB上看了一下，服务器被困在
zframe_t *identity = zframe_recv( router );
我使用fprintf()进行了详细的日志记录，以确认情况确实如此。
我使用作为我的示例--我复制了确切的代码，并对其进行了测试，以确保其工作正常。
基本上，我在寻找想法--如果身
浏览 5提问于2016-09-07得票数 2
我正在尝试如何有效地将ZMQ应用于多线程(因此send不阻止接收，接收不阻止发送)。
我想使用ZMQ_DONTWAIT标志，但是在发送数据时，它有时不会被发送(EAGAIN错误，所以当处理兆字节数据时，我不得不重新排队，这是浪费资源)。
我想出了以下代码：
Concurrency::concurrent_queue<zmq::message_t> QUEUE_IN;
Concurrency::concurrent_queue<zmq::message_t> QUEUE_OUT;
void SendThread(zmq::context_t &context)
浏览 4提问于2014-10-16得票数 0
我有一个类连接，它是Zmq请求/应答的一种包装器。使用它，我将接受来自客户端的请求并发送回响应。用来完成这些任务的两个函数是：
void Connection::receiveMessage ()
{
//recv messages over zmq and send it to back-end.
}
void Connection::sendMessage ()
{
//This method would be called by back-end and it will send the message over Zmq.
}
面临的问题：-由于zmq请求/回复是同步操作，在接收新消息
浏览 1提问于2014-09-28得票数 0
我在努力连接两个插座：
前端(路由器)-处理客户端请求并将它们转发到后端
后端(路由器)-接收来自前端的请求，并处理他们使用的工人数量(这需要一些初始化，配置等)。
服务器代码如下所示：
void server_task::run() {
frontend.bind("tcp://*:5570");
backend.bind("inproc://backend");
zmq::pollitem_t items[] = {
{ frontend, 0, ZMQ_POLLIN, 0 },
{
浏览 6提问于2017-10-10得票数 2
1回答
我正在处理分布式应用程序。网络是基于ZMQ (jeromq)的，下面是我的架构：
N Clients (Dealer socket) <---> (Router) Proxy (Dealer) <---> 1 (Dealer) Reciving Worker
<---> N (Dealer) Processing Workers
因此，我的接收工作者在一个单独的线程中运行，侦听消息并将它们放入队列。
Processing从队列中选择消息，
浏览 0提问于2016-01-22得票数 0
回答已采纳
1回答
我和茱莉亚一起工作。
有一个网络库: ZeroMQ。
我需要的是创建一个能够接收多零to套接字的julia项目。以下是一个简单的解释：
s1 = Socket();
ZMQ.bind(s1, ip1:port1);
s2 = Socket();
ZMQ.bind(s2, ip2:port2);
s3 = Socket();
ZMQ.bind(s3, ip3:port3);
ZMQ.recv(s1, msg0, 0); // it's blocking
ZMQ.recv(s2, msg1, 0); // it's blocking
ZMQ.recv(s3, msg2, 0); /
浏览 5提问于2015-11-11得票数 3
回答已采纳
1回答
我正在使用c#中的ZMQ c#包来接收来自订阅者的消息。我能够收到信息，但我坚持在时间循环。如果发布服务器停止发送数据，我想中断while循环。
这是我的订户代码：
using (var subscriber = new SubscriberSocket())
{
subscriber.Connect("tcp://127.0.0.1:4000");
subscriber.Subscribe("A");
while (true)
浏览 3提问于2022-02-22得票数 3
回答已采纳
我使用curl发送POST和GET请求，并使用回调函数获取这些请求的回复。这些callback函数是静态成员函数，它们反过来调用非静态成员函数(您不能在curl中直接使用非静态成员函数，因此需要解决这个问题)。
因为这些回调函数不能返回结果，所以我在C++类中使用一个属性来存储回复。这一切都很好，但现在我的问题是。是在整个请求被发送并由回调函数处理应答之前curl_easy_perform()阻塞，还是在curl_easy_perform()之后继续我的程序，并且在收到来自请求的应答时被以某种方式中断？
对我来说重要的是，我想要确保我的属性中应该包含回复的数据已经存在，或者该属性中可能还有旧数
浏览 9提问于2013-03-09得票数 16
回答已采纳
请参阅第67页。
Question>我不明白为什么下面的代码对多线程有好处。根据我的理解，在等待来自子线程的反馈时，主线程可以做不同的事情。
但是，在下面的代码中，step2似乎在调用char *string = s_recv (receiver);时被阻塞，而step3在调用char *string = s_recv (receiver);时被阻塞
根据我的理解，在收到来自step_i的信号之前，(step_i+1)可以做一些空闲的事情。但是，正如您看到的代码所示，step2和step3都被阻塞，不能做任何事情。为什么这是一个多线程代码？
谢谢
// Multithreaded re
浏览 0提问于2013-04-25得票数 2
回答已采纳
1回答
安装和运行ZeroMQ
、、、、
我试图在我的电脑上安装ZeroMQ，但我无法使我的程序运行不崩溃。
安装：
1) install Visual Studio 2017.
2) clone from git jzmq and libzmq
3) install ZMQ version 4.0.4 for windows.
4) run the script build in: \libzmq\builds\msvc\build\build.bat
5) open in Visual Studio 2017: libzmq\builds\msvc\vs2017\libzmq.sln and jzmq\jzmq-jni\b
浏览 20提问于2017-08-15得票数 1
我正在开发一个相对简单的基于Python / ZeroMQ的工作分发系统，使用REQ/路由器套接字。该系统是分布式的，工作节点分布在不同的大陆上。
负责分发工作的.bind()-s ROUTER是一个ROUTER套接字。使用TCP套接字通过TCP对其进行.connect()处理。
在设置一个新的工作节点的过程中，我注意到虽然较小的消息(最多1kB)没有问题，但是由ROUTER-end发送的~2kB和up的回复从未被工人接收到他们的REQ-socket中--当我调用recv()时，套接字就挂起了。
工作代码在Docker容器中运行，当使用--net=host运行相同的映像时，我能够解决这个问题-
浏览 12提问于2017-11-22得票数 0
考虑下面的示例代码(我快速地输入了它作为示例，如果有错误也没关系-我对理论感兴趣)。
bool shutDown = false; //global
int main()
{
CreateThread(NULL, 0, &MessengerLoop, NULL, 0, NULL);
//do other programmy stuff...
}
DWORD WINAPI MessengerLoop( LPVOID lpParam )
{
zmq::context_t context(1);
zmq::socket_t socket (context, ZMQ_SU
浏览 0提问于2013-04-25得票数 5
回答已采纳
我有一个架构，其中我有一个ROUTER套接字和多个DEALER套接字。
一些DEALER套接字只会发送数据，有些只能接收数据，而另一些则可以同时执行这两种操作。
我有一个场景，其中我有一个DEALER套接字，它以极快的速度发送数据。该数据由另一个DEALER接收，它将尽可能快地处理该数据。发送速率将始终高于接收。
在我当前的设置中，我的ROUTER套接字上的ZMQ_SNDHWM会为接收客户端命中，并将悄悄地丢弃消息。我不想这样。
处理这种情况的最佳方法是什么？
我看过不同端口上的DEALER->DEALER，但这可能很难维护，这取决于创建的会话数量，每个会话可能必须有一个端口。
另一种解
浏览 0提问于2018-02-22得票数 2
2回答
我的当前程序是通过zmq接收消息。一个线程不时地醒来，检查zmq上一次收到了什么。
现在，我想改进这个设置，并实际处理每一条消息，而不是醒来时的最后一条消息。另外，当有新的事情发生时，我希望我的线程能醒来。有什么方法可以强制我的线程唤醒我的线程，一旦他有了我的线程的新消息。
浏览 6提问于2017-06-19得票数 2
回答已采纳
使用select，我可以确定是否可以无阻塞地接收或发送任何字节。
使用此函数，我可以确定可以接收的字节数：
function BytesAvailable(S: TSocket): Integer;
begin
if ioctlsocket(S, FIONREAD, Result) = SOCKET_ERROR then
Result := -1;
end;
是否还有一种方法可以确定可以发送多少字节？
因此，我可以确定当我使用N个字节调用send时，它将恰好返回N个已发送的字节(或SOCKET_ERROR)，但不会少于N个字节(发送缓冲区已满)。
FIONWRITE不可用于Wins
浏览 1提问于2012-10-12得票数 4
我正在使用zeroMQ实现发送-recv消息.我用的模式是:酒吧-潜艇。
但是，我似乎可以从发布者那里发送一些消息，但是我无法从订阅者那里接收到它。这是我的代码：
//订户：
int main(int argc, char** argv){
void * context = zmq_ctx_new();
void * subscriber = zmq_socket(context, ZMQ_SUB);
zmq_connect(subscriber, "tcp:://127.0.0.1:5556");
const int SIZE = 20;
浏览 6提问于2015-04-15得票数 0
回答已采纳
我正在用C#编写一个服务器。msdn.microsoft.com上的异步示例建议如下所示。
BeginAccept侦听客户端(即当客户端调用时启动一个新线程)。
BeginReceive从客户端接收数据(&启动一个新线程来完成它)。
BeginSend来回复将数据发送到客户端(&启动另一个线程)。
在这一点上，似乎有4个单独的线程，从我(可能很天真)的角度来看，服务器需要2.1才能继续侦听，而与客户端的对话则需要2.1。为什么我与客户端的对话需要3个线程，因为我必须在发送之前等待回复，并且在等待从客户端接收数据时不会做任何其他事情。
干杯
浏览 0提问于2014-01-15得票数 2
回答已采纳
多个客户端连接到单个ZMQ_PUSH套接字。当客户端意外断电时，服务器不会收到警报，并继续向其发送消息。尽管使用了ZMQ_OBLOCK并将ZMQ_HWM设置为5(最多只能排队5条消息)，但我的服务器直到重新连接客户端并立即接收到队列中的所有消息时才会出现错误。
浏览 15提问于2018-09-04得票数 1
回答已采纳
1回答
我有一台托管路由器套接字的机器：
router = zmq_ctx.socket(zmq.ROUTER)
router.setsockopt(zmq.constants.ROUTER_HANDOVER, 1)
router.bind(url)
然后我有很多机器像这样连接到它。
dealer = zmq_ctx.socket(zmq.DEALER)
dealer.setsockopt(zmq.IDENTITY, options.identity)
dealer.connect(url)
# send some message every 10 seconds
发送信息，过了一段时间就关机了。经销
浏览 3提问于2014-11-18得票数 1
我们在ZeroMQ中使用的是一种ZeroMQ可扩展的正式通信模式。发送者应用程序共发送30,000条消息，每个10 of。有很多数据丢失，因此我们在发送方设置了以下内容：
zmq_socket = context.socket(zmq.PUSH)
zmq_socket.setsockopt(zmq.SNDBUF, 10240)
zmq_socket.setsockopt(zmq.SNDHWM, 1)
zmq_socket.bind("tcp://127.0.0.1:4999")
在接收方：
zmq_socket = context.socket(zmq.PULL)
zmqSoc
浏览 5提问于2017-05-03得票数 2
我正在实现一个基于UDP的停止等待ARQ。我正在尝试模拟错误概率。
在发送方和接收方中，我都有一个while()循环来继续发送和接收。一切都正常工作，直到我在接收端引入错误概率。
我故意让接收方不发送ACK，即使它已经接收到包(以模拟ACK丢失的情况)。
令我惊讶的是，--发送方和接收方--都挂起！我之所以知道这一点，是因为为了进行调试，我在发送方和接收方的printf()循环中都放置了一个while，没有打印任何内容。
为什么会发生这种事？即使没有任何传输，while循环(独立于sendto()和recvfrom())也不应该停止。
浏览 7提问于2013-10-28得票数 0
我一直在用棘轮测试PHP，直到ZMQSocket::send突然开始挂起，没有明显的原因。
$context = new ZMQContext();
$socket = $context->getSocket(ZMQ::SOCKET_PUSH, 'notify');
$res = $socket->send(json_encode($entryData)); //Hangs here.
请注意，我可以使用ZMQ::MODE_NOBLOCK，这将停止挂起，但它没有解决问题。也就是说，客户仍然没有收到任何东西。我也重新启动了我的盒子，这并不能解决问题。
Ubuntu
浏览 1提问于2014-02-14得票数 9
我试图使用spring集成和amqp (rabbitmq)在春季批处理中实现远程分块。
我无法理解ChunkMessageChannelItemWriter是如何在下面的远程分块测试中收集回复的
它是怎么工作的？它是否发送一条消息，等待它的回复，接收它的回复，然后再收到第二条消息，等待第二条消息回复，收到第二条消息回复等等？
还是它异步发送所有消息，等待回复，然后在回复通道到达时接收答复？
如果我们在这里引用远程分块文档
它使用入站和出站适配器。如果ChunkMessageChannelItemWriter收到回复，为什么我们需要适配器？在从侧，为什么使用适配器和服务激活器？
请任何人帮助
浏览 1提问于2014-06-04得票数 1
回答已采纳
环境设置：
多播发送和接收应用程序都运行在同一台计算机中。
我正在将ZeroMQ组播与OpenPGM支持集成起来，但在我的示例代码中遇到了问题。
即在接收端应用程序中没有接收到“多播消息”。如果我做错了，请纠正我。也无法找到适当的例子关于ZeroMQ PGM组播需求。
// ZMQ_pgm_receive.cpp :
//
//Headers
#include "stdafx.h"
#include "zmq.h"
#include <iostream>
#include <windows.h>
std::string f
浏览 1提问于2017-03-08得票数 4
2回答
在我的一个应用程序中，我使用的是交易商/路由器的连接。我将交易商套接字上的linger选项设置为0，以便一旦路由器套接字关闭，就会丢弃在交易商套接字上发送的所有消息。虽然这对于TCP连接很好，但是它会阻塞inproc。下面是一个最小的工作示例：
#include <zmq.h>
#include <windows.h>
int main()
{
void *context = zmq_ctx_new();
void *router = zmq_socket(context, ZMQ_ROUTER);
zmq_bind(router,
浏览 6提问于2017-02-10得票数 4
回答已采纳
信号可以在任何线程或主程序本身接收。我从主程序中创建了一个辅助线程。所以在我的程序中有两个线程: 1.主线程(进程本身) 2.辅助线程。我只想知道，每当信号到达我的辅助线程，那应该发送信号到我的主线程(程序)。我使用pthread_kill(main_threadid，sig)从辅助线程内部的信号处理程序寄存器发送信号。但。我观察每一次信号发送到主线程接收到辅助子线程本身，信号处理程序陷入接收发送信号的循环。
#include <pthread.h>
#include <signal.h>
#include <stdio.h>
#include <un
浏览 1提问于2017-07-29得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
