在qt中用tcp传输xml消息

本文博客链接:http://blog.csdn.net/jdh99,作者:jdh,转载请注明.

环境：

主机:WIN7

开发环境:Qt5 3.1.2

说明:

在tcp上传输xml消息.

协议格式如下:

2字节标识(0xc55c,网络序)+2字节预留 +4字节报文内容长度(网络序) + 4字节命令字(网络序)+报文内容

部分协议:

命令字:
请求值班信息:GET_DUTY_INFO
请求报文:

<?xml version="1.0" encoding="UTF-8"?>
<request >
<identifier>客户端的唯一标识符</identifier>
</request>

回复报文:

<?xml version="1.0" encoding="UTF-8"?>
<dutyinfo>
  <version>版本号</version>//表示车辆值班记录有无变化（如增减）
  <vehiclenum>车辆数目</vehiclenum>
	<vehicle>
<dutyofvehicleuid>32位UUID</dutyofvehicleuid>
<number>车辆编号, 如1,2,3,4</ number>
<platenumber>车牌号</platenumber>
<image>图片url</image>
<liquidlevel>78</liquidlevel>//0至100
    </vehicle>
	<vehicle>
<dutyofvehicleuid>32位UUID</dutyofvehicleuid>
<number>车辆编号, 如1,2,3,4</ number>
<platenumber>车牌号</platenumber>
<image>图片url</image>
<liquidlevel>78</liquidlevel>//0至100
</vehicle>
…
</dutyinfo>

处理思路:

1.发送:

调用qt中处理xml文件的类将所需要发送的信息保存为xml文件,然后读取文件,将文件转化为字节流,并拼接帧头,然后发送

2.接收

将接收的字节流去掉帧头后保存为xml文件,然后调用qt中处理xml文件的类读取其中的信息

源代码:

保存为xml文件

//打开需要发送的xml命令
    QFile file(FILE_GET_DUTY_TX);
    //生成xml文件
    QDomDocument doc;
    QDomElement root_elem;
    QDomElement item;
    QDomText text;

    //xml文件头
    QString header("version=\"1.0\" encoding=\"UTF-8\"");
    doc.appendChild(doc.createProcessingInstruction("xml",header));

    //根元素
    root_elem = doc.createElement("request");
    doc.appendChild(root_elem);

    //元素:identifier
    item = doc.createElement("identifier");
    text = doc.createTextNode(QString(Local_Id));
    item.appendChild(text);
    root_elem.appendChild(item);

    //新建文件并保存
    file.open(QIODevice::WriteOnly);
    QTextStream out(&file);
    out.setCodec("UTF-8");
    doc.save(out,4,QDomNode::EncodingFromTextStream);
    file.close();

//读取xml文件
    file.open(QIODevice::ReadOnly);
    QTextStream get(&file);
    //得到xml数据
    Data_Xml_Tx = get.readAll().toLocal8Bit();
    file.close();

/*********************************************************************
*                               槽函数:发送网络帧
*参数:cmd:帧命令
*    frame:发送的报文
**********************************************************************/

void Net::slot_net_tx_frame(int cmd,QByteArray frame)
{
    QByteArray head;
    int i = 0;

    i = 0;
    //帧头
    head[i++] = 0xc5;
    head[i++] = 0x5c;
    //预留
    head[i++] = 0;
    head[i++] = 0;
    //报文长度
    head[i++] = frame.size() >> 24;
    head[i++] = frame.size() >> 16;
    head[i++] = frame.size() >> 8;
    head[i++] = frame.size();
    //命令字
    head[i++] = cmd >> 24;
    head[i++] = cmd >> 16;
    head[i++] = cmd >> 8;
    head[i++] = cmd;
    //组合帧
    frame.prepend(head);

    //判断当前是否连接上服务器
    if (tcp_client->state() == QAbstractSocket::ConnectedState)
    {
        //已连接上
        //发送数据
        tcp_client->write(frame);

    #ifdef DEBUG
        qDebug() << "发送网络帧1:cmd" << cmd;
    #endif
    }
    else
    {
        //未连接上
        Frame = frame;
        //连接服务器
        if (tcp_client->state() != QAbstractSocket::ConnectingState)
        {
            tcp_client->connectToHost(Server_Ip,Server_Port);
        }
    }
}

/*********************************************************************
*                               接收完成处理
**********************************************************************/

void Get_Duty::deal_frame()
{
    int sum = 0;
    int i = 0;
    QSqlQuery q;
    QString version;

    //解锁
    Lock_Net = 0;
    //放弃处理网络信息
    Net_Permission = 0;

    qDebug() << "接收帧:回复值班信息";

    //判断是否有值班信息
    if ((uint8_t)Frame.at(11) == 0)
    {
        //有标题,将数据存入xml文件
        //打开接收命令存储的xml文件
        QFile file(FILE_GET_DUTY_RX);
        //新建文件并保存
        file.open(QIODevice::WriteOnly);
        QTextStream out(&file);
        out.setCodec("UTF-8");
        out << Frame.mid(LEN_FRAME_HEAD);
        file.close();

        //打开xml文件
        QDomDocument doc(FILE_GET_DUTY_RX);
        //获取文件内容
        file.open(QIODevice::ReadOnly);
        doc.setContent(&file);
        file.close();

        //获得根节点
        QDomElement root_node = doc.documentElement();
        //获得第一个子节点:版本
        QDomNode node = root_node.firstChild();
        version = node.toElement().text();
        //判断版本号是否一致
        if (version == Version)
        {
            return;
        }

        //不一致
        Version = version;
        qDebug() << "版本号" << Version;

        //下一个子节点:车辆总数
        node = node.nextSibling();
        sum = node.toElement().text().toInt();
        qDebug() << "车辆总数" << sum;

        //清空前3辆车辆信息
        Car_Three_List[0].clear();
        Car_Three_List[1].clear();
        Car_Three_List[2].clear();
        //清空值班信息表
        q.prepare("DELETE FROM duty");
        q.exec();
        //写入数据库
        for (i = 0;i < sum;i++)
        {
            node = node.nextSibling();

            //插入数据
            q.prepare("INSERT INTO duty VALUES(?,?,?,?,?,?)");
            //uuid
            q.bindValue(0,node.toElement().childNodes().at(0).toElement().text());
            //编号
            q.bindValue(1,node.toElement().childNodes().at(1).toElement().text().toInt());
            //车牌
            q.bindValue(2,node.toElement().childNodes().at(2).toElement().text());
            //图片
            q.bindValue(3,node.toElement().childNodes().at(3).toElement().text());
            //汽油
            q.bindValue(4,node.toElement().childNodes().at(4).toElement().text().toInt());
            //图片标志
            q.bindValue(5,IMG_NULL);
            q.exec();

            //前3辆车辆信息输入
            if (i < 3)
            {
                Car_Three_List[i] = node.toElement().childNodes().at(0).toElement().text();
            }
        }

        //打印数据库
//        q.prepare("SELECT * FROM duty");
//        q.exec();
//        while (q.next())
//        {
//            qDebug() << "uuid" << q.value(0).toString()
//                     << "编号" << q.value(1).toInt()
//                     << "车牌" << q.value(2).toString()
//                     << "图片" << q.value(3).toString()
//                     << "汽油" << q.value(4).toString()
//                     << "图片标志" << q.value(5).toInt();
//        }
    }
    else
    {
        Version = "null";

        //清空值班信息表
        q.prepare("DELETE FROM duty");
        q.exec();
    }

    //接收到值班信息
    emit sig_recv_duty_info();

    //清空接收缓存
    Frame.clear();
    Len_Frame_Content = 0;
}