我试图通过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 回答
不熟悉ZeroMQ,但
flatbuffer::GetTestBuf(&request)
这看起来有问题..你需要传递缓冲区,而不是消息结构 . 可能request.data()
或类似的工作更好 .通常,如果它在FlatBuffers中崩溃,您应该使用验证程序来验证您传递给FlatBuffers的缓冲区 . 如果失败,则意味着您没有将合法数据传递给FlatBuffers,就像这里的情况一样 .
此外,您可能想要检查ZeroMQ是否可以发送缓冲区而不复制,将更快 .