发送包含其他结构体的结构体作为ZeroMQ消息

Sending struct containing other struct as ZeroMQ message

本文关键字：结构体 ZeroMQ 消息 包含 其他      更新时间：2023-10-16

我有一个问题发送从指针到结构体构建的zmq消息，其中包含其他结构体。

服务器代码:

#include <zmq.hpp>
#include <string>
#include <iostream>
using namespace zmq;
using namespace std;
struct structB{
    int a;
    string c;
};
struct structC{
    int z;
    struct structB b;
};
int main()
{
    context_t context(1);
    socket_t *socket = new socket_t(context,ZMQ_REP);
    socket->bind("tcp://*:5555");
    message_t *request = new message_t();   
    socket->recv(request);
    struct structB messageB; 
    messageB.a=0;
    messageB.c="aa";
    struct structC *messageC = new struct structC;
    messageC->z = 4;
    messageC->b = messageB;
    char *buffer = (char*)(messageC);
    message_t *reply = new message_t((void*)buffer,
                       +sizeof(struct structB)
                       +sizeof(struct structC)
                       ,0);
    socket->send(*reply);
    return 0;
}
客户机代码:

#include <zmq.hpp>
#include <iostream>
#include <string>
using namespace std;
using namespace zmq;
struct structB{
    int a;
    string c;
};
struct structC{
    int z;
    struct structB b;
};
int main()
{ 
    context_t context(1);
    socket_t *socket = new socket_t(context,ZMQ_REQ);
    socket->connect("tcp://*:5555");
    const char* buffer = "abc";
    message_t *request = new message_t((void*)buffer,sizeof(char*),0);
    socket->send(*request);
    message_t *reply = new message_t;
    socket->recv(reply);
    struct structC *messageC = new struct structC;
    messageC = static_cast<struct structC*>(reply->data());
cout<<messageC->b.a<<endl;//no crash here
    struct structB messageB = messageC->b;//Segmentation fault (core dumped)
    return 0;
}

当我试图从structB中使用名为"c"的字符串时，这个程序崩溃了。如果我尝试打印它，或者像上面的例子那样赋值整个strucb，都没有关系。

问题在哪里?我应该在服务器端以不同的方式创建message_t *reply吗?

不能通过网络发送字符串，因为std::string是一个容器。你可以使用灵活的数组成员或大数组或编写一个小的类序列化(你必须自己编写代码准备缓冲区)来发送数据。

当你做struct structB messageB = messageC->b;时，嵌入在messageC->b中的std::string成员的指针成员可能在复制构造函数或std::string中解引用，这可能导致分段错误。

大字符数组的例子如下:

struct structB{
    int a;
    char c[MAX_LENGTH];
};
后来

struct structB messageB; 
messageB.a=0;
strcpy(messageB.c,"aa"); // #include<cstring> or use std::copy from <algorithm>
struct structC *messageC = new struct structC;
// I guess you want this(not sure) messageC->z = static_cast<int>( sizeof(int) + strlen(messageB) + 1 );
messageC->z = 4;
messageC->b = messageB;

和

const int length = sizeof(int) /* z */ + sizeof(int) /* a */ + strlen("aa") + 1;
zmq::message_t msg (length);
memcpy (msg.data (), &messageC, length);
socket->send(msg);

这些是服务器端需要做的一些改变，你也需要在客户端做类似的改变。

作为一个边注，你的代码是非常混乱的，不要把它部署到更大的应用程序之前，整理一些事情，如删除不必要的new和正确表示嵌套结构。

您的结构不是POD。类"string"不能复制为内存堆。有一个问题。

使用c.c_str()和c.size()作为内存块进行复制

相关文章：