c++ - 如何从 C++ 中的 .recv() 和 .send() 方法读取 ZeroMQ 返回值？

Question

我正在尝试编写一个用于通过 ZeroMQ 在两台计算机之间进行通信的 C++ 类。

为了能够处理错误，我尝试读取 .recv()- 的返回值和 .send()-方法，但我收到以下错误

error: cannot convert 'zmq::send_result_t' {aka 'zmq::detail::trivial_optional<unsigned int>'} to 'int' in assignment
ret = msocket.send(reply, zmq::send_flags::none);

代码如下所示:

Publisher::Publisher(dataHandler & mdatahandler) :datahandler(mdatahandler)
{
    // construct a REP (reply) socket and bind to interface

    socketState.bind("tcp://*:5555");
    //socketAngles.bind("tcp://*:5556");
    //socketCurrents.bind("tcp://*:5557");
}

Publisher::~Publisher()
{
    socketState.close();
    //socketAngles.close();
    //socketCurrents.close();
}

std::string Publisher::transfer(zmq::socket_t& msocket, std::string replyString,
    int receiveFlag = 0)
{
    zmq::send_result_t ret = 0;
    if (receiveFlag)
    {
        zmq::message_t receivedData;
        ret = msocket.recv(receivedData, zmq::recv_flags::none);
        if (verbose)
        {
            std::cout << "Received " << receivedData.to_string() << std::endl;
        }
        return receivedData.to_string();
    }
    zmq::message_t reply{ replyString.cbegin(), replyString.cend() };

    // send the reply to the client
    ret = msocket.send(reply, zmq::send_flags::none);

    if (ret == -1)
    {
        std::cout << zmq_strerror(errno) << std::endl;
    }
}

套接字定义为

zmq::context_t context{ 1 };
zmq::socket_t socketState{ context, ZMQ_REP };

我怎样才能可靠地捕获错误，如果发生错误，是否有更好的方法来处理错误？

编辑:我添加了 zmq::send_result_t但我该怎么做呢？我无法将其与任何东西进行比较，也无法打印。

Answer 1

zmq::recv_result_t基于 trivial_optional<unsigned int> .trivial_optional<T>是一个类模板，它封装了它可能包含也可能不包含值。 trivial_optional<unsigned int> 类型的实例被 bool trivial_optional<unsigned int>::has_value() 询问看看有没有值。
如果有一个值，则使用 T trivial_optional<unsigned int>::operator*() 提取它。或 T trivial_optional<unsigned int>::value() .

zmq::recv_result_t ret(msocket.recv(receivedData, zmq::recv_flags::none));
if (ret.has_value() && (EAGAIN == ret.value()))
{
    // msocket had nothing to read and recv() timed out
    ....
}