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

 

环境：

主机:WIN7

开发环境:Qt5 3.1.2

说明:

在tcp上传输xml消息.

协议格式如下:

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

部分协议:

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

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

回复报文:

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <dutyinfo>
  3. <version>版本号</version>//表示车辆值班记录有无变化（如增减）
  4. <vehiclenum>车辆数目</vehiclenum>
  5. <vehicle>
  6. <dutyofvehicleuid>32位UUID</dutyofvehicleuid>
  7. <number>车辆编号, 如1,2,3,4</ number>
  8. <platenumber>车牌号</platenumber>
  9. <image>图片url</image>
  10. <liquidlevel>78</liquidlevel>//0至100
  11. </vehicle>
  12. <vehicle>
  13. <dutyofvehicleuid>32位UUID</dutyofvehicleuid>
  14. <number>车辆编号, 如1,2,3,4</ number>
  15. <platenumber>车牌号</platenumber>
  16. <image>图片url</image>
  17. <liquidlevel>78</liquidlevel>//0至100
  18. </vehicle>
  19. …
  20. </dutyinfo>

处理思路:

1.发送:

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

2.接收

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

源代码:

保存为xml文件

  1. //打开需要发送的xml命令
  2. QFile file(FILE_GET_DUTY_TX);
  3. //生成xml文件
  4. QDomDocument doc;
  5. QDomElement root_elem;
  6. QDomElement item;
  7. QDomText text;
  8. //xml文件头
  9. QString header("version=\"1.0\" encoding=\"UTF-8\"");
  10. doc.appendChild(doc.createProcessingInstruction("xml",header));
  11. //根元素
  12. root_elem = doc.createElement("request");
  13. doc.appendChild(root_elem);
  14. //元素:identifier
  15. item = doc.createElement("identifier");
  16. text = doc.createTextNode(QString(Local_Id));
  17. item.appendChild(text);
  18. root_elem.appendChild(item);
  19. //新建文件并保存
  20. file.open(QIODevice::WriteOnly);
  21. QTextStream out(&file);
  22. out.setCodec("UTF-8");
  23. doc.save(out,4,QDomNode::EncodingFromTextStream);
  24. file.close();

读取xml文件,得到字节流

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

发送函数

  1. /*********************************************************************
  2. *                               槽函数:发送网络帧
  3. *参数:cmd:帧命令
  4. *    frame:发送的报文
  5. **********************************************************************/
  6. void Net::slot_net_tx_frame(int cmd,QByteArray frame)
  7. {
  8. QByteArray head;
  9. int i = 0;
  10. i = 0;
  11. //帧头
  12. head[i++] = 0xc5;
  13. head[i++] = 0x5c;
  14. //预留
  15. head[i++] = 0;
  16. head[i++] = 0;
  17. //报文长度
  18. head[i++] = frame.size() >> 24;
  19. head[i++] = frame.size() >> 16;
  20. head[i++] = frame.size() >> 8;
  21. head[i++] = frame.size();
  22. //命令字
  23. head[i++] = cmd >> 24;
  24. head[i++] = cmd >> 16;
  25. head[i++] = cmd >> 8;
  26. head[i++] = cmd;
  27. //组合帧
  28. frame.prepend(head);
  29. //判断当前是否连接上服务器
  30. if (tcp_client->state() == QAbstractSocket::ConnectedState)
  31. {
  32. //已连接上
  33. //发送数据
  34. tcp_client->write(frame);
  35. #ifdef DEBUG
  36. qDebug() << "发送网络帧1:cmd" << cmd;
  37. #endif
  38. }
  39. else
  40. {
  41. //未连接上
  42. Frame = frame;
  43. //连接服务器
  44. if (tcp_client->state() != QAbstractSocket::ConnectingState)
  45. {
  46. tcp_client->connectToHost(Server_Ip,Server_Port);
  47. }
  48. }
  49. }

tcp接收网络帧,并保存为xml文件,然后读取xml文件中的信息

  1. /*********************************************************************
  2. *                               接收完成处理
  3. **********************************************************************/
  4. void Get_Duty::deal_frame()
  5. {
  6. int sum = 0;
  7. int i = 0;
  8. QSqlQuery q;
  9. QString version;
  10. //解锁
  11. Lock_Net = 0;
  12. //放弃处理网络信息
  13. Net_Permission = 0;
  14. qDebug() << "接收帧:回复值班信息";
  15. //判断是否有值班信息
  16. if ((uint8_t)Frame.at(11) == 0)
  17. {
  18. //有标题,将数据存入xml文件
  19. //打开接收命令存储的xml文件
  20. QFile file(FILE_GET_DUTY_RX);
  21. //新建文件并保存
  22. file.open(QIODevice::WriteOnly);
  23. QTextStream out(&file);
  24. out.setCodec("UTF-8");
  25. out << Frame.mid(LEN_FRAME_HEAD);
  26. file.close();
  27. //打开xml文件
  28. QDomDocument doc(FILE_GET_DUTY_RX);
  29. //获取文件内容
  30. file.open(QIODevice::ReadOnly);
  31. doc.setContent(&file);
  32. file.close();
  33. //获得根节点
  34. QDomElement root_node = doc.documentElement();
  35. //获得第一个子节点:版本
  36. QDomNode node = root_node.firstChild();
  37. version = node.toElement().text();
  38. //判断版本号是否一致
  39. if (version == Version)
  40. {
  41. return;
  42. }
  43. //不一致
  44. Version = version;
  45. qDebug() << "版本号" << Version;
  46. //下一个子节点:车辆总数
  47. node = node.nextSibling();
  48. sum = node.toElement().text().toInt();
  49. qDebug() << "车辆总数" << sum;
  50. //清空前3辆车辆信息
  51. Car_Three_List[0].clear();
  52. Car_Three_List[1].clear();
  53. Car_Three_List[2].clear();
  54. //清空值班信息表
  55. q.prepare("DELETE FROM duty");
  56. q.exec();
  57. //写入数据库
  58. for (i = 0;i < sum;i++)
  59. {
  60. node = node.nextSibling();
  61. //插入数据
  62. q.prepare("INSERT INTO duty VALUES(?,?,?,?,?,?)");
  63. //uuid
  64. q.bindValue(0,node.toElement().childNodes().at(0).toElement().text());
  65. //编号
  66. q.bindValue(1,node.toElement().childNodes().at(1).toElement().text().toInt());
  67. //车牌
  68. q.bindValue(2,node.toElement().childNodes().at(2).toElement().text());
  69. //图片
  70. q.bindValue(3,node.toElement().childNodes().at(3).toElement().text());
  71. //汽油
  72. q.bindValue(4,node.toElement().childNodes().at(4).toElement().text().toInt());
  73. //图片标志
  74. q.bindValue(5,IMG_NULL);
  75. q.exec();
  76. //前3辆车辆信息输入
  77. if (i < 3)
  78. {
  79. Car_Three_List[i] = node.toElement().childNodes().at(0).toElement().text();
  80. }
  81. }
  82. //打印数据库
  83. //        q.prepare("SELECT * FROM duty");
  84. //        q.exec();
  85. //        while (q.next())
  86. //        {
  87. //            qDebug() << "uuid" << q.value(0).toString()
  88. //                     << "编号" << q.value(1).toInt()
  89. //                     << "车牌" << q.value(2).toString()
  90. //                     << "图片" << q.value(3).toString()
  91. //                     << "汽油" << q.value(4).toString()
  92. //                     << "图片标志" << q.value(5).toInt();
  93. //        }
  94. }
  95. else
  96. {
  97. Version = "null";
  98. //清空值班信息表
  99. q.prepare("DELETE FROM duty");
  100. q.exec();
  101. }
  102. //接收到值班信息
  103. emit sig_recv_duty_info();
  104. //清空接收缓存
  105. Frame.clear();
  106. Len_Frame_Content = 0;
  107. }

http://blog.csdn.net/jdh99/article/details/38677811

最新文章

  1. C语言之预处理
  2. Redis Sentinel集群配置中的一些细节
  3. [转]webpack进阶构建项目(一)
  4. python学习笔记10（Python的内存管理）
  5. How to use PEM of PPAS
  6. POJ 1144 Network（Tarjan求割点）
  7. effective java 笔记1--序言
  8. 51nod 1257 背包问题 V3
  9. mapreduce任务失败、重试、猜測式运行机制小结
  10. 你所不知道的 CSS 滤镜技巧与细节
  11. 【转载】使用SDL播放YUV图像数据（转）
  12. Android文本框-android学习之旅（十七 ）
  13. Redis in .NET Core 入门：(4) LIST和SET
  14. ng-packagr 打包报错 Public property X of exported class has or is using name &#39;Observable&#39; from external module “/rxjs/internal/Observable” but cannot be named
  15. Java编程思想__内部类
  16. ubuntu1604配置ss代理
  17. Python 中的浅拷贝和深拷贝
  18. 259. 3Sum Smaller小于版3sum
  19. python 关键字yield解析
  20. ConcurrentHashMap内存溢出问题

热门文章

  1. 高性能分布式应用开发中间件ICE介绍
  2. JNI基础
  3. cxf整合spring发布rest服务 httpclient访问服务
  4. 【29.41%】【codeforces 724D】Dense Subsequence
  5. xml报错(dtd):The markup declarations contained or pointed to by the document type declaration must be well-formed
  6. 机器学习: Tensor Flow +CNN 做笑脸识别
  7. Python算法(含源代码下载)
  8. Expression.Blend.4 Chapter 接口设计
  9. python中对文件、文件夹的操作
  10. python 教程 第十二章、 标准库