ZMQ_REP服务器已运行，但检测就绪状态的代码始终返回false求助

你的代码核心逻辑错误在于违反了ZMQ REQ/REP套接字的通信规则：REQ套接字必须先发送请求，才能接收响应。你当前仅连接套接字就直接轮询读事件，根本不会触发服务器的响应，所以始终返回false。

修复后的代码 #

#include <iostream>
#include <zmq.hpp>
#include <chrono>
#include <stdexcept>

const std::string SERVER_ENDPOINT = "tcp://localhost:5555";

bool checkServer(const std::string& serverEndpoint) {
    try {
        zmq::context_t context(1);
        zmq::socket_t socket(context, zmq::SocketType::REQ);
        // 设置连接超时，避免长时间阻塞
        socket.set(zmq::sockopt::connect_timeout, 1000);
        socket.connect(serverEndpoint);

        // 发送检测用的PING请求
        zmq::message_t request(5);
        memcpy(request.data(), "PING", 5);
        socket.send(request, zmq::send_flags::dontwait);

        zmq::pollitem_t items[] = {{socket, 0, ZMQ_POLLIN, 0}};
        // 等待1秒检测是否有响应
        zmq::poll(items, 1, 1000);

        if (items[0].revents & ZMQ_POLLIN) {
            zmq::message_t response;
            socket.recv(response, zmq::recv_flags::dontwait);
            return true;
        }
    } catch (const zmq::error_t& e) {
        // 捕获连接失败等异常
        std::cerr << "Connection error: " << e.what() << std::endl;
    }
    return false;
}

int main() {
    bool serverAvailable = false;

    while (!serverAvailable) {
        std::cout << "Waiting for server..." << std::endl;
        serverAvailable = checkServer(SERVER_ENDPOINT);
        std::this_thread::sleep_for(std::chrono::seconds(1));
    }
    std::cout << "Server is available." << std::endl;

    return 0;
}

关键修复说明 #

• 添加请求发送步骤：REQ套接字必须先发送数据，才能触发REP服务器返回响应，之后才能轮询到读事件
• 设置连接超时：避免connect操作在服务器不可用时长时间阻塞
• 异常捕获：处理连接失败、发送失败等ZMQ异常情况
• 接收响应：即使是检测用的响应，也需要调用recv读取，否则套接字状态会异常，影响后续操作

服务器端配合要求 #

你的ZMQ_REP服务器需要能正确处理"PING"请求并返回响应，示例逻辑如下：

zmq::message_t request;
socket.recv(request);
// 确认请求内容（可选）
if (std::string(static_cast<char*>(request.data()), request.size()) == "PING") {
    zmq::message_t response(4);
    memcpy(response.data(), "PONG", 4);
    socket.send(response);
}

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