首页 文章

读取在C中通过ZMQ发送的Flatbuffers对象会抛出未处理的异常

提问于
浏览
2

我试图通过ZMQ在网络上发送一个相当大的Flatbuffers对象,然后使用C读取它 . 访问对象时,我得到了未处理的异常,我不知道如何解决 . 即使这个最小的例子也失败

flatbuffers架构:

namespace flatbuffer;
table TestBuf {
  testStatus:bool;
  testNumber:double;
  testInt:int;
}
root_type TestBuf;

使用REP套接字的main.cpp:

int main() {
    zmq::context_t context(1);
    zmq::socket_t socket(context, ZMQ_REP);
    socket.bind("tcp://*:5555");

    std::cout << "Listening for requests." << std::endl;
    std::cout << "-----" << std::endl;

    double count = 0;
    while (1) {
        zmq::message_t request;
        socket.recv(&request);

        // Read incoming data
        auto reqmsg = flatbuffer::GetTestBuf(&request);
        std::cout << "Received: " << reqmsg << std::endl;

        flatbuffers::FlatBufferBuilder fbb;
        flatbuffer::TestBufBuilder builder(fbb);

        count++;
        builder.add_testNumber(count);      
        std::cout << "Sending " << count << std::endl;

        auto response = builder.Finish();
        fbb.Finish(response);

        // Send the flatbuffer
        int buffersize = fbb.GetSize();
        zmq::message_t message(buffersize);
        memcpy((void *)message.data(), fbb.GetBufferPointer(), buffersize);
        socket.send(message);
    }
    return 0;
}

使用REQ套接字的main.cpp:

int main() {
    // Prepare ZMQ context and socket
    zmq::context_t context(1);
    zmq::socket_t socket(context, ZMQ_REQ);
    std::cout << "Sending out data requests." << std::endl;
    socket.connect("tcp://localhost:5555");

    double count = 0;
    while (1) {
        // Formulate response
        flatbuffers::FlatBufferBuilder fbb;
        flatbuffer::TestBufBuilder builder(fbb);

        count++;
        builder.add_testNumber(count);
        auto response = builder.Finish();
        fbb.Finish(response);

        // Send the flatbuffer
        std::cout << "Sending. " << count << ". ";
        int buffersize = fbb.GetSize();
        zmq::message_t message(buffersize);
        memcpy((void *)message.data(), fbb.GetBufferPointer(), buffersize);
        socket.send(message);
        std::cout << "Sent. ";

        // Receive reply
        zmq::message_t reply;
        socket.recv(&reply);

        // Read the data
        auto inmsg = flatbuffer::GetTestBuf(&reply);
        std::cout << " Received reply: " << inmsg << std::endl;

        //auto num = inmsg->testNumber();
        //std::cout << num << " test number.";
    }
    return 0;
}

这段代码运行正常并显示(我认为)每个程序正在接收的原始缓冲区 . 奇怪的是,尽管消息的内容应该是,但它并没有改变 . 如果我取消注释最后两行并尝试访问inmsg-> testNumber(),我收到此错误消息:

Unhandled exception at 0x000000013F373C53 in KUKAREQ.exe: 0xC0000005: Access violation reading location 0x00000000004B35D8.

我之前已成功通过ZMQ发送了Flatbuffers对象,但我还没有在C中读过它们 . 我很确定我紧跟着Flatbuffers tutorial,但事情显然是错的 . 指针?缓冲区大小?无论哪种方式,我都会感谢帮助 .


编辑:为澄清我对接受的答案的评论,违规行是:

auto inmsg = flatbuffer::GetTestBuf(&reply);

它必须改为:

auto inmsg = flatbuffer::GetTestBuf(reply.data());

读这个问题的人也可能有兴趣知道我后来遇到了一个错误,当没有以正确的顺序调用FlatBufferBuilder函数时会发生这个错误 . 显然,构建Flatbuffers对象的顺序非常重要 . 发现那个人花了我一段时间 - 新手注意 .

1 回答

  • 2

    不熟悉ZeroMQ,但 flatbuffer::GetTestBuf(&request) 这看起来有问题..你需要传递缓冲区,而不是消息结构 . 可能 request.data() 或类似的工作更好 .

    通常,如果它在FlatBuffers中崩溃,您应该使用验证程序来验证您传递给FlatBuffers的缓冲区 . 如果失败,则意味着您没有将合法数据传递给FlatBuffers,就像这里的情况一样 .

    此外,您可能想要检查ZeroMQ是否可以发送缓冲区而不复制,将更快 .

相关问题