如何使用 QDataStream 从 QTcpSocket 读取类对象?

Question

我有一个由我定义的类，比如说MyClass。我想通过QTcpSocket发送此类的对象。这个答案建议使用QDataStream，这显示了如何重载<<和>>运算符来实现这一点。

到目前为止，我已经设法使<<超载，并为QDataStream>>运算符.对于发送和接收部分，我遵循Marek R的这个答案的指示，它回答了一个或多或少与这个问题重复的问题。发送MyClass对象的服务器代码似乎有效。但是，我无法弄清楚如何从QDataStream接收和格式化数据。

从马雷克·

void SomeClass::slotReadClient() { // slot connected to readyRead signal of QTcpSocket
QTcpSocket *tcpSocket = (QTcpSocket*)sender();
QDataStream clientReadStream(tcpSocket);
while(true) {
if (!next_block_size) {
if (tcpSocket->bytesAvailable() < sizeof(quint16)) { // are size data available
break;
}
clientReadStream >> next_block_size;
}
if (tcpSocket->bytesAvailable() < next_block_size) {
break;
}
QString str;
clientReadStream >> str;
next_block_size = 0;
}
}

但是，当我使用它时，我收到一个错误：

error: no matching function for call to ‘QDataStream::QDataStream(QTcpSocket*&, QIODevice::OpenModeFlag)’

根据发送方法，我尝试了以下方法：

MyClass obj;
QByteArray block;
QDataStream rs(&block,QIODevice::ReadWrite);
rs.setVersion(QDataStream::Qt_5_7);
int nextblocksize = 0;
while(true)
{
if(!nextblocksize)
{
if(socket->bytesAvailable() < sizeof(quint16))
{
break;
}
socket->read(block,socket->bytesAvailable());
rs>>nextblocksize;
}
if(socket->bytesAvailable() < nextblocksize)
{
break;
}
socket->read(block,socket->bytesAvailable());
rs>>obj;
nextblocksize=0;
}

但是，这会产生以下错误：

error: conversion from ‘QByteArray’ to ‘char*’ is ambiguous
socket->read(block,socket->bytesAvailable());
^

作为参考，以下是发送代码，它编译成功(在读取代码正常工作之前无法检查)：

QTcpSocket *socket = server->nextPendingConnection();
QByteArray block;
MyClass obj(1,2.0, "Hin");
QDataStream ds(&block,QIODevice::ReadWrite);
ds.setVersion(QDataStream::Qt_5_7);
ds<<quint16(0)<<obj;
socket->write(block);

我对网络概念不是很熟悉，所以我可能会错过一些琐碎的东西。

我该怎么做？

另外，区块开头发送的quint16(0)有什么意义？据称它可以作为块大小的指标，但它是如何做到这一点的呢？无论块大小如何，它都不一样吗？还是我完全误解了它的用法？

谢谢。

Answer 1

如果 MyClass 实现了QJsonObject serializeToJson() and void deserializeFromJson(const QJsonObject&)你可以发送类的 json 表示。我认为这样会更简单。

class Serializable
{
public:
Serializable(){}
virtual ~Serializable(){}
virtual QJsonObject serialize_to_json() = 0;
};
class Deserializable
{
public:
Deserializable(){}
virtual ~Deserializable(){}
virtual void deserialize_from_json(const QJsonObject&) = 0;
};
// MyClass implements Serializable and Deserializable
MyClass obj;
// To wrire
// construct QJsonDocument from serializeToJson
// write bytes representing the json 
// QJsonDocument::toJson() returns QByteArray
socket->write(QJsonDocument(obj.serializeToJson()).toJson());

// To read
// Construct QJsonDocument from received bytes
// QJsonDocument::fromJson(bytes).toObject returns QJsonObject
MyClass obj;
obj.deserializeFromJson(QJsonDocument::fromJson(socket->readAll()).toObject());

我省略了 json 检查部分。 解析 JSON