ZeroMQ C++客户端如何检测/处理日志服务IP地址变更？

我在Docker Swarm模式下用ZeroMQ C++搭建日志服务，服务端绑定tcp://*:20000，客户端连接tcp://logger_svc:20000。当容器重启导致服务IP变更时，ZeroMQ会缓存logger_svc的旧IP，不会每次调用都重新解析，导致客户端无法连接到新的服务实例。

我试过把socket.send调用放在try-catch块里，但就算关闭日志服务也捕获不到错误，代码如下：

while (true) {
    try {
        // Perform your ZeroMQ send operation here
        m_socket->send(msg, ZMQ_DONTWAIT);

        // If successful, break out of the loop
        break;
    }
    catch (const zmq::error_t& e) {
        // Handle the send error, e.g., log or take necessary actions
        printf("zeromq send error, will try reconnecting");

        // Sleep for a delay before attempting reconnection
        Sleep(1000);

        // Attempt to reconnect by closing the socket and establishing a new connection
        m_socket->close();
        m_socket->connect(GetLogListenerUri());
    }
}

问题原因 #

ZeroMQ基于异步消息队列机制，默认会缓存DNS解析结果；加上ZMQ_DONTWAIT模式下send操作不会立刻抛出连接错误——消息会被存入本地发送队列，直到队列满或超时才会触发错误，这就是try-catch失效的核心原因。

解决方案（结合可用socket选项） #

方案1：利用ZeroMQ内置重连机制

ZeroMQ自带自动重连能力，只需调整以下参数即可，无需手动销毁socket：

• ZMQ_RECONNECT_IVL：初始重连间隔，建议设为1000ms
• ZMQ_RECONNECT_IVL_MAX：最大重连间隔，设为和初始值一致避免间隔过大
• ZMQ_SNDTIMEO：设置发送超时，让send操作在超时后抛出错误

示例配置代码：

// 创建socket后立即配置参数
m_socket->setsockopt(ZMQ_RECONNECT_IVL, 1000);
m_socket->setsockopt(ZMQ_RECONNECT_IVL_MAX, 1000);
m_socket->setsockopt(ZMQ_SNDTIMEO, 2000); // 2秒超时

发送逻辑修改：

try {
    m_socket->send(msg); // 阻塞直到发送成功或超时
    break;
} catch (const zmq::error_t& e) {
    if (e.num() == EAGAIN || e.num() == ECONNRESET) {
        printf("发送超时或连接重置，ZeroMQ将自动重连\n");
        Sleep(1000);
    }
}

方案2：强制销毁socket触发DNS重新解析

如果需要手动控制DNS刷新，必须完全销毁旧socket对象再创建新实例——仅调用close无法清除内部缓存的DNS结果。

修改后的重连逻辑：

while (true) {
    try {
        m_socket->send(msg, ZMQ_DONTWAIT);
        break;
    } catch (const zmq::error_t& e) {
        printf("zeromq发送错误，尝试重新创建连接\n");
        Sleep(1000);
        
        // 销毁旧socket
        delete m_socket;
        // 创建新socket并连接
        m_socket = new zmq::socket_t(m_context, ZMQ_PUB); // 根据实际socket类型调整
        m_socket->connect(GetLogListenerUri());
        // 配置重连参数
        m_socket->setsockopt(ZMQ_RECONNECT_IVL, 1000);
        m_socket->setsockopt(ZMQ_RECONNECT_IVL_MAX, 1000);
    }
}

方案3：开启TCP Keepalive检测死连接

通过配置TCP keepalive参数，让系统层面主动检测连接状态，一旦发现连接断开，ZeroMQ会自动触发重连：

// 开启TCP keepalive
int keepalive = 1;
m_socket->setsockopt(ZMQ_TCP_KEEPALIVE, &keepalive, sizeof(keepalive));
// 30秒无数据后开始发送探测包
int keepalive_idle = 30;
m_socket->setsockopt(ZMQ_TCP_KEEPALIVE_IDLE, &keepalive_idle, sizeof(keepalive_idle));
// 探测包发送间隔10秒
int keepalive_intvl = 10;
m_socket->setsockopt(ZMQ_TCP_KEEPALIVE_INTVL, &keepalive_intvl, sizeof(keepalive_intvl));
// 重试3次后判定连接失效
int keepalive_cnt = 3;
m_socket->setsockopt(ZMQ_TCP_KEEPALIVE_CNT, &keepalive_cnt, sizeof(keepalive_cnt));

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