ZMQ数据包发送异常：移除cout语句后无法正常发送

我编写了一段C++代码，用于向GNU Radio Companion中的ZMQ Pull Source发送10字节的ZMQ数据包，代码如下：

#include <iostream>
#include <zmq.h>

using namespace std;

int main() 
{
    void *send_context, *responder;
    unsigned short gnu_trigger[10];
    string trig_addr = "tcp://127.0.0.1:4500";
    int rc;

    /* Bind ZMQ address for transmitting data */
    send_context = zmq_ctx_new();
    responder = zmq_socket(send_context, ZMQ_PUSH);
    rc = zmq_bind(responder, trig_addr.c_str());
    
    while(1)
    {
        cout << "Sending trigger to gnuradio\n";
    
        memset(gnu_trigger, 0x0, sizeof(unsigned short) * 10);
        gnu_trigger[0] = 1;
        
        rc = zmq_send(responder, &gnu_trigger, sizeof(gnu_trigger), 0);
    
        cout << "Sent trigger to gnuradio\n";
        sleep(1);
    }

    zmq_close(responder);
    zmq_ctx_destroy(send_context);
    
    return 0;
}

但遇到一个奇怪的现象：把ZMQ发送前后的cout语句注释或删除后，数据包无法传输；保留这些cout语句时，数据包能成功发送。这是什么原因？

原因分析 #

核心原因是ZMQ的PUSH/PULL模式默认会阻塞发送操作，直到有接收方完成连接，而cout语句的控制台输出会产生短暂延迟，加上后续的sleep(1)，刚好给了GNU Radio的ZMQ Pull Source足够时间完成连接握手。

具体细节：

• 保留cout时，控制台输出的IO操作会消耗少量时间，这段间隙让接收方有机会和PUSH端建立连接，后续的zmq_send就能正常投递消息。
• 移除cout后，程序启动会立刻进入循环执行zmq_send，但此时接收方可能还没完成连接初始化，ZMQ的默认行为会让zmq_send一直阻塞（PUSH套接字在没有已连接的Pull端时，无法完成消息投递），看起来就像“数据包无法传输”。

另外你的代码没有检查zmq_bind的返回值，如果绑定地址失败（比如端口被占用），也会导致后续发送失败，建议添加错误判断：

if (rc != 0) {
    cerr << "zmq_bind failed: " << zmq_strerror(errno) << endl;
    return 1;
}

解决办法 #

1. 确保接收方先启动 #

先打开GNU Radio的流图，等ZMQ Pull Source完全准备好后，再启动你的发送程序，这样连接能立刻建立，不需要依赖cout的延迟。

2. 设置非阻塞发送或超时 #

给PUSH套接字设置非阻塞模式，或者设置发送超时，这样即使没有接收方，zmq_send也不会一直阻塞，而是返回错误，你可以根据返回值处理重试逻辑：

// 设置发送超时为1秒
int timeout = 1000;
zmq_setsockopt(responder, ZMQ_SNDTIMEO, &timeout, sizeof(timeout));

// 或者设置非阻塞模式
int non_block = 1;
zmq_setsockopt(responder, ZMQ_NOBLOCK, &non_block, sizeof(non_block));

如果zmq_send返回-1且errno为EAGAIN，说明当前无法发送，稍后重试即可。

3. 添加连接等待逻辑 #

在进入发送循环前，主动等待接收方连接：

int connections = 0;
while (connections == 0) {
    zmq_getsockopt(responder, ZMQ_CURRENT_CONNECTIONS, &connections, sizeof(connections));
    sleep(1);
}

等检测到有接收方连接后再开始发送，就不需要依赖cout的延迟了。

内容的提问来源于stack exchange，提问作者Mobi Zaman