通過msgpack通過zeromq發送一個向量

Question

我似乎無法發送一個vector的struct，我用msgpack通過ZeroMQ序列化。

正是這種結構的載體：

struct MyData 
{ 
    MyData() : id(0), x(0), y(0), a(0) {} 
    MyData(const Obj &r) : id(0), x(r.pose[0]), y(r.pose[1]), a(r.pose[2]) {} 
    MyData(const Obj *r) : id(0), x(r->pose[0]), y(r->pose[1]), a(r->pose[2]) {} 
    double id; 
    double x; 
    double y; 
    double a; 
    MSGPACK_DEFINE(id, x, y, a); 
}; 

在發送端：

data是std::vector<MyData>

msgpack::sbuffer sbuf; 
msgpack::pack(sbuf, data); 
zmq::message_t msg(sbuf.data(), sizeof(char *) * sbuf.size(), NULL, NULL); 
local_socket->send(msg); // this is just zeromq's send function 

難道我建造我的sbuffer或message_t錯誤？

在接收端：

我不知道如果我應該投的msg.data()或沒有，但我無法找到如何使用ZeroMQ和messagepack任何工作良好的文檔。

message_t msg; 
server_socket->recv(&msg); 

msgpack::unpacked unpacked; 
msgpack::unpack(&unpacked, reinterpret_cast<char*>(msg.data()), msg.size()); 
msgpack::object obj = unpacked.get(); 

std::vector<MyData> data; 
obj.convert(&data); 
printf("size %d\n", data.size()); 

我得到以下錯誤：

terminate called after throwing an instance of 'msgpack::type_error'
what(): std::bad_cast Aborted

我希望得到任何幫助。

Answer 1

這似乎已經完成了招對我來說：

msgpack::sbuffer sbuf; 
msgpack::pack(sbuf, data); 
zmq::message_t msg(sbuf.size()); 
memcpy(msg.data(), sbuf.data(), sbuf.size());