QDataStream对QVector的序列化

最近发现QDataStream这个好东东，序列化发送数据很方便，与大家分享一下。

客户端：

line.h

#ifndef LINE_H
#define LINE_H
#include <QString>

class Line
{
public:
    Line();

public:
    int pointX;
    int pointY;
    int pointZ;

    QString pointName;

public:
    void getPoint();
    void setPoint();

};

#endif // LINE_H

line.cpp

#include "line.h"

Line::Line()
{
}


void Line::getPoint()
{

}

void Line::setPoint()
{

}

myvector.h

#ifndef MYVECTOR_H
#define MYVECTOR_H

#include <QVector>
#include <QDebug>
#include "line.h"

class MyVector:public QVector<Line>
{
public:
    MyVector();

    friend QDataStream& operator <<(QDataStream &out,MyVector &myVector);

    friend QDataStream& operator >>(QDataStream &in,MyVector &myVector);

    int x;
};

class ChildVector:public MyVector
{
public:
    ChildVector();

public:
    friend QDataStream& operator <<(QDataStream &out,ChildVector &childVector);

    friend QDataStream& operator >>(QDataStream &in,ChildVector &childVector);

    int y;
    int z;
    int childData;

};

#endif // MYVECTOR_H

myvector.cpp

#include "myvector.h"

MyVector::MyVector()
{
}


QDataStream& operator <<(QDataStream &out,MyVector &myVector)
{
    out << quint32(myVector.size());
    qDebug() <<"myVector---size()"<<myVector.size()<<endl;

    for (typename QVector<Line>::const_iterator it = myVector.begin(); it != myVector.end(); ++it)
    {
        out << it->pointName << it->pointX << it->pointY << it->pointZ;
        qDebug()<<"it->pointName####"<<it->pointName<<"it->pointX$$$$$"<<it->pointX<<"it->pointY%%%%"<<it->pointY<<"it->pointZ^^^^^"<<it->pointZ<<endl;
    }
    out << myVector.x;
    return out;
}



QDataStream& operator >>(QDataStream &in,MyVector &myVector)
{
    myVector.clear();
    quint32 c;
    in >> c;
    myVector.resize(c);
    for(quint32 i = 0;i < c;++i)
    {
        Line tLine;
        in >> tLine.pointName >> tLine.pointX >> tLine.pointY >> tLine.pointZ;
    }
    in >> myVector.x;
    return in;
}

ChildVector::ChildVector()
{

}

QDataStream& operator <<(QDataStream &out,ChildVector &childVector)
{
    qDebug() <<"myVector---size()"<<childVector.size()<<endl;

    MyVector *kk = &childVector;
    out << *kk;
    out << childVector.y << childVector.z<<childVector.childData;
    return out;
}

QDataStream& operator >>(QDataStream &in,ChildVector &childVector)
{
    MyVector *kk = &childVector;
    in << *kk;
    in >> childVector.y >> childVector.z >> childVector.childData;

    return in;
}

tcpclient.h

#ifndef TCPCLIENT_H
#define TCPCLIENT_H

#include <QObject>
#include <QDataStream>
#include <Qt/qtcpserver.h>
#include <Qt/qtcpsocket.h>
#include <Qt/qhostinfo.h>
#include <Qt/qhostaddress.h>

#include "myvector.h"

class TcpClient : public QObject
{
    Q_OBJECT
public:
    //explicit TcpClient(QObject *parent = 0);
    TcpClient():m_iOut(&byteArrayWrite,QIODevice::WriteOnly)
    {
        m_nPort = 8080;
        m_bStatus = false;
        tcpClient = NULL;

        //设置数据流的版本，客户端和服务器端使用的版本要相同
        m_iOut.setVersion(QDataStream::Qt_4_6);
        //设置发送长度初始值为0
        m_iOut<<(quint32)0;
    }

signals:

public slots:
    void slotGetStatus();

public:
    void initConnection(QString ip);
    void updata();

    QDataStream m_iIn;
    QDataStream m_iOut;
    QByteArray byteArrayWrite;

    QTcpSocket *tcpClient;

    //MyVector myVector;

    QString m_sIpAddress;
    int m_nPort;
    bool m_bStatus;
};

#endif // TCPCLIENT_H

tcpclient.cpp

#include "tcpclient.h"

//TcpClient::TcpClient(QObject *parent) :
//    QObject(parent)
//{

//}

void TcpClient::initConnection(QString ip)
{
    m_sIpAddress = ip;
    QHostAddress address;
    address.setAddress(ip);

    if(tcpClient == NULL)
    {
        tcpClient = new QTcpSocket(this);
    }

    tcpClient->abort();

    tcpClient->connectToHost(address,8080);



    //connect(tcpClient,SIGNAL(readyRead()),this,SLOT(readData()));
    //connect(tcpClient,SIGNAL(disconnected()),this,SLOT(slotDisconnect()));
    //connect(tcpClient,SIGNAL(connected()),this,SLOT(sendData()));
    m_bStatus = connect(tcpClient,SIGNAL(connected()),this,SLOT(slotGetStatus()));

    while(!m_bStatus)
    {
        initConnection(m_sIpAddress);
    }
}

void TcpClient::slotGetStatus()
{

}

void TcpClient::updata()
{
    //回到字节流起始位置
    m_iOut.device()->seek(0);
    //重置字节流长度
    m_iOut << (quint32) (byteArrayWrite.size()-sizeof(quint32));
    //往套接字缓存中写入数据，并发送
    int writeBlock = tcpClient->write(byteArrayWrite);

    qDebug()<<"writeBlock******"<<writeBlock;

    byteArrayWrite.resize(0);

    tcpClient->waitForReadyRead(1000);
}

test.h

#ifndef TEST_H
#define TEST_H

#include <QObject>
#include "tcpclient.h"

class Test : public QObject
{
    Q_OBJECT
public:
    explicit Test(QObject *parent = 0);

signals:

public slots:
    void getData();

public:
     TcpClient *tcpClt;
};

#endif // TEST_H

test.cpp

#include "test.h"

Test::Test(QObject *parent) :
    QObject(parent)
{
    tcpClt = new TcpClient();
}

void Test::getData()
{
    QString ipAddress("192.168.154.128");

    tcpClt->initConnection(ipAddress);

    ChildVector myVector;

    Line tLine;
    for(int i = 0;i < 10;i++)
    {
        tLine.pointName = QString("test")+QString::number(i);
        tLine.pointX = 100 + i*10;
        tLine.pointY = 150 + i*100;
        tLine.pointZ = 5000 + i*1000;
        myVector.append(tLine);
    }

    myVector.x = 1000;
    myVector.y = 2000;
    myVector.z = 3000;
    myVector.childData = 30;

    tcpClt->m_iOut << myVector;

    tcpClt->updata();
}

服务端接收：

line.h  line.cpp，myvector.h myvector.cpp不再添加,同客户端

tcpserver.h

#ifndef TCPSERVER_H
#define TCPSERVER_H

#include <Qt/qtcpserver.h>
#include <Qt/qtcpsocket.h>
#include <Qt/qhostinfo.h>
#include <Qt/qhostaddress.h>
#include <Qt/qnetworkinterface.h>
#include <QObject>

#include "myvector.h"

class TcpServer : public QObject
{
    Q_OBJECT
public:
    explicit TcpServer(QObject *parent = 0,int port = 8080);

    ChildVector myVector;

signals:

public slots:
    void readData();
    //void deleteSlot();
    void slotConnected();

private:
    QTcpServer *m_pServer;
    QTcpSocket *m_pTcpClientSocket;


};

#endif // TCPSERVER_H

tcperver.cpp

#include "tcpserver.h"

int GLOBAL_LENGTH = 0;

TcpServer::TcpServer(QObject *parent, int port) :
    QObject(parent)
{
    m_pServer = new QTcpServer(this);
    if(m_pServer->listen(QHostAddress::Any,port))
    {
          qDebug()<<"listen Successfully!!!";
    }
    connect(m_pServer,SIGNAL(newConnection()),this,SLOT(slotConnected()));
}

void TcpServer::slotConnected()
{
    qDebug()<<"slotConnected!!!";
    m_pTcpClientSocket = m_pServer->nextPendingConnection();

    bool bConnect = connect(m_pTcpClientSocket,SIGNAL(readyRead()),this,SLOT(readData()));
    //connect(m_pTcpClientSocket,SIGNAL(disconnected()),m_pTcpClientSocket,SLOT(deleteLater()));
    qDebug()<<"bConnect"<<bConnect;
}

void TcpServer::readData()
{
    quint32 nextBlockSize = 0;
    QDataStream in(m_pTcpClientSocket);
    in.setVersion(QDataStream::Qt_4_6);
    quint32 bufferSize = m_pTcpClientSocket->bytesAvailable();
    if(nextBlockSize == 0)
    {
        if(m_pTcpClientSocket->bytesAvailable()<sizeof(quint32))
        {
            return;
        }
        in>>nextBlockSize;
        qDebug()<<"nextBlockSize:"<<nextBlockSize<<"m_pTcpClientSocket->bytesAvailable()"<<m_pTcpClientSocket->bytesAvailable();
    }

    GLOBAL_LENGTH = nextBlockSize/sizeof(quint32);

    in >> myVector;
    //qDebug()<<"-------------"<<myVector.x<<"@@@@@@@@@@"<<"myVector.size()#####"<<myVector.size()<<endl;
     for(int i = 0; i < myVector.size() ;i++)
     {
         qDebug()<<"***********"<<myVector.at(i).pointName<<"###";
         qDebug()<<"***********"<<myVector.at(i).pointX<<"###";
         qDebug()<<"***********"<<myVector.at(i).pointY<<"###";
         qDebug()<<"***********"<<myVector.at(i).pointZ<<"###"<<endl;
     }

     qDebug()<<"-------------"<<myVector.x<<"@@@@@@@@@@"<<"myVector.y#####"<<myVector.y<<"@@@@@@@@@@"<<"myVector.y#####"<<myVector.z<<"childData-----"<<myVector.childData<<endl;
     if(nextBlockSize==0xFFFF)
     {
         return;
     }
     if(bufferSize < nextBlockSize)
     {
         return;
     }
}

以上代码经过编译测试通过，希望对你有所帮助。