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



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

为了能够处理错误,我试图读取.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,但如何使用它?我无法将它与任何东西进行比较,也无法打印它。

zmq::recv_result_t基于trivial_optional<unsigned int>

trivial_optional<T>是一个类模板,它封装了它可能包含也可能不包含值。使用bool trivial_optional<unsigned int>::has_value()询问类型为trivial_optional<unsigned int>的实例以查看是否存在值。

如果存在值,则使用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
....
}

Q"如何可靠地捕获错误?如果出现错误,是否有更好的方法来处理错误TR

这可以分为两个问题:


第A部分:";我如何可靠地捕获错误">

首先了解语言工具。也有与例外相关的工具和最佳实践以及其他Do-s和Don’t-s。服从他们。

B部分:";处理错误的更好的方式">

处理错误的最佳方法是完全避免错误-这并不能拯救地球(你可以读到Margaret Hamilton女士的故事(她为阿波罗制导计算机软件正确地做到了这一点,拯救了生命和民族自豪感(,以及她真正的方法,拯救了不可避免的主要碰撞案例(。

下一个,弱得多的策略是设计架构(然后是代码(,彻底检查系统的状态(返回值、RTT时间和其他因素(,以便持续做好处理异常的准备,正如它所发生的那样,在系统状态的全面背景下(不要因为站在十字路口中间像盲人一样不知情而感到惊讶,一旦抛出异常……它将在稍后的某个时候抛出,所以要提前做好准备,不要在事后恐慌,求助于混乱的特别选项(

解决方案:

步骤1(
了解并掌握语言工具。

步骤2(
了解并掌握ZeroMQ工具(任何REP都不能从.send()开始(

步骤3(
了解并掌握已发布的ZeroMQ API,有成功异常处理详细信息所需的所有详细信息(预防性错误状态指示-{ EINVAL | ETERM | ENOTSOCK | EINTR | ... }错误状态中的隐藏宝石,针对每个API调用方法进行解释,针对每个此类方法在适当的上下文中进行解释。

如果仍然不相信,至少读一读皮特·辛特晏斯(Pieter Hintjens(的精彩著作《"Code Connected,Volume 1">,你会发现零度禅的根源。

相关内容

最新更新