Qt Socket 收发图片——图像拆包、组包、粘包处理

时间：2019-08-06 20:09:40 阅读：129 评论：0 收藏：0 [点我收藏+]

之前给大家分享了一个使用python发图片数据、Qt server接收图片的Demo。之前的Demo用于传输小字节的图片是可以的，但如果是传输大的图片，使用socket无法一次完成发送该怎么办呢？本次和大家分享一个对大的图片拆包、组包、处理粘包的例子。

程序平台：ubuntu 、 Qt 5.5.1

为了对接收到的图像字节进行组包，我们需要对每包数据规定协议，协议如下图：

技术图片

每包数据前10个字节对应含义如下：前两个字节对应数据包类型，中间四字节预留，最后四字节是包内数据实际长度。对应协议图片更方便刚开始上手的兄弟理解。

对协议有了一个了解后，接下来说下程序结构。客户端按照协议发送图片字节，服务器接收字节，如果客户端发多少服务器就收多少那可真是太好了，然而意外总是如期而至。服务器这边由于socket的缓冲总是会粘包，所以服务器这边主要工作是拆包和组包，这也是整个程序组中最重要的部分。其次就是服务器在接收图片时为了响应更及时，单独使用一个线程进行接收图片，这里面我使用的是Qt的moveToThread。也使用过linux的socket以及线程接收图片，感觉性能要比Qt封装过的要好，大家有需要的话可以在公众号后台留言。

接下来跟着程序走：

客户端发送部分：

①读取图片字节

 1 void Widget::on_pbn_readPicture_clicked()
 2 {
 3     m_picturePath = m_picturePath +"/auboi5.jpg";
 4     QPixmap pix;
 5     bool ret = pix.load(m_picturePath);
 6 
 7     QBuffer buffer;
 8     buffer.open(QIODevice::ReadWrite);
 9     bool ret2 = pix.save(&buffer,"jpg");
10 
11     m_pictureByteArray = buffer.data();
12 
13     if(ret2)
14     {
15         QString str = "read image finish!";
16         ui->textEdit->append(str);
17     }
18 }

读取图片字节主要用到了Qt的QPixmap 类，这个不细说，大家具体可参考Qt文档。图片字节被读取到m_pictureByteArray中，成功后在textEdit显示read image finish!。

②发送图像拆包

 1 QByteArray dataPackage;
 2 
 3     // command 0 ,package total size
 4     QDataStream dataHead(&dataPackage,QIODevice::ReadWrite);
 5     dataHead << quint16(0);
 6     dataHead << quint32(0);
 7     dataHead << quint32(m_pictureByteArray.size());
 8     dataPackage.resize(40960);
 9     mp_clsTcpSocket->write(dataPackage);
10     dataPackage.clear();
11 
12     QThread::msleep(20);

这里我拿医一包数据举例说明。第一包数据是将读取到的整张图片的大小发送出去，以判断接收方接收到的数据是否完整。主要涉及到Qt一些数据类型的转换，如将整型字节存入QByteArray 中使用QDataStream 。之后将数据包大小重新设置为40960，方便服务器处理粘包。

③发送utf8 编码的中文

 1 void Widget::on_pbn_sendChinese_clicked()
 2 {
 3     QByteArray dataPackage;
 4     QByteArray chinese = "阶级终极形态假设！";
 5 
 6     //command 3
 7     QDataStream dataTail(&dataPackage,QIODevice::ReadWrite);
 8     dataTail << quint16(3);
 9     dataTail << quint32(0);
10     dataTail << quint32(chinese.size());
11 
12     dataPackage = dataPackage.insert(10,chinese.data(),chinese.size());
13     dataPackage.resize(40960);
14 
15     mp_clsTcpSocket->write(dataPackage);
16 }

这部分直接略过了，大家参考下即可。

2.服务器接收部分(重要)：

①线程中槽函数接收图片数据拆包

 1 void TcpServerRecvImage::slot_readClientData()
 2 {
 3     QByteArray buffer;
 4     buffer = mp_clsTcpClientConnnect->readAll();
 5 
 6     m_bufferSize = buffer.size();
 7     m_total = m_total + buffer.size();
 8     qDebug() << "socket Receive Data size:" << m_bufferSize << m_total;
 9 
10     if(m_bufferSize == 40960)
11     {
12         emit signal_sendImagedataPackage(buffer);
13         qDebug() << "直接发送";
14         return;
15     }
16 
17 
18     if((m_picture.size() + m_bufferSize) == 40960)
19     {
20         m_picture.append(buffer);
21 
22         emit signal_sendImagedataPackage(m_picture);
23         m_picture.clear();
24         qDebug() << "拼接后40960";
25         return;
26     }
27 
28 
29     if((m_picture.size() + m_bufferSize) < 40960)
30     {
31         m_picture.append(buffer) ;
32         qDebug() << "直接拼接";
33         return;
34     }
35 
36     if((m_picture.size() + m_bufferSize) > 40960)
37     {
38         //case one
39         if((m_bufferSize > 40960) && (m_picture.size() == 0))
40         {
41             while(m_bufferSize/40960)
42             {
43                 QByteArray data = buffer.left(40960);
44                 buffer.remove(0,40960);
45 
46                 emit signal_sendImagedataPackage(data);
47                 m_bufferSize = buffer.size();
48 
49                 if((m_bufferSize/40960 == 0) && (m_bufferSize!=0))
50                 {
51                     m_picture.append(buffer);
52                 }
53                 QThread::msleep(2);
54             }
55             return;
56         }
57 
58         //case two
59         if((m_bufferSize > 40960) && (m_picture.size() > 0))
60         {
61             int frontLength = 40960 - m_picture.size();
62             QByteArray data = buffer.left(frontLength);
63             buffer.remove(0,frontLength);
64 
65             m_picture.append(data);
66             if(40960 == m_picture.size())
67             {
68                 emit signal_sendImagedataPackage(m_picture);
69                 m_picture.clear();
70             }
71 
72             m_bufferSize = buffer.size();
73 
74             while(m_bufferSize/40960)
75             {
76                 QByteArray data = buffer.left(40960);
77                 buffer.remove(0,40960);
78 
79                 emit signal_sendImagedataPackage(data);
80                 m_bufferSize = buffer.size();
81 
82                 if((m_bufferSize/40960 == 0) && (m_bufferSize!=0))
83                 {
84                     m_picture.append(buffer);
85                 }
86                 QThread::msleep(2);
87             }
88             return;
89         }
90     }
91 }

程序有那么一点长，我先说下他们在做的事情：

1> 如果接收到的字节是40960字节，直接发到主线程处理数据的槽中

2> 如果接收到的字节加上缓存中的字节数目小于40960，直接将数据追加到 m_picture中【请原谅我40960没有用宏定义】

3> 如果接收到的字节加上缓存中的字节数目等于40960，直接发送

4> 如果接收到的字节加上缓存中的字节数目大于40960，分两种

①接收到的字节是40960的整数倍

if((m_bufferSize/40960 == 0) && (m_bufferSize!=0))

{

m_picture.append(buffer);

}

如果不加上面这个追加函数，则会有数据解析失败

②接收到的字节不是40960的整数倍

int frontLength = 40960 - m_picture.size();

QByteArray data = buffer.left(frontLength);

buffer.remove(0,frontLength);

先取出那一包数据剩余的部分，然后拼成一包发出。

之前试过直接追加到m_picture中，但经常有数据解析失败，

然后看例子，试了这个，结果......

②主线程处理40960数据包

 1 void Widget::slot_imagePackage(QByteArray imageArray)
 2 {
 3     m_imageCount++;
 4     QString number = QString::number(m_imageCount);
 5     ui->textEdit->append(number);
 6 
 7     QByteArray cmdId = imageArray.left(2);
 8     QDataStream commandId(cmdId);
 9     quint16 size;
10     commandId >> size;
11 
12     if(0 == size)
13     {
14         QByteArray cmdId = imageArray.mid(6,9);
15         QDataStream commandId(cmdId);
16         quint32 size;
17         commandId >> size;
18         qDebug() << "图片的总字节数" << size;
19     }
20 
21     if(2 == size)
22     {
23         QByteArray cmdId = imageArray.mid(6,9);
24         QDataStream commandId(cmdId);
25         quint32 size;
26         commandId >> size;
27         qDebug() << "图片包尾字节数 " << size;
28     }
29 
30     if(3 == size)
31     {
32         QByteArray cmdId = imageArray.mid(6,9);
33         QDataStream commandId(cmdId);
34         commandId >> m_dataSize;
35         qDebug() << "汉子字节数" << size;
36     }
37 
38     switch (size)
39     {
40     case 1:
41         imageArray.remove(0,10);
42         m_imagePackage.append(imageArray);
43         break;
44 
45     case 2:
46         imageArray.remove(0,10);
47         m_imagePackage.append(imageArray);
48 
49         m_pix.loadFromData(m_imagePackage,"jpg");
50         ui->lb_image->setPixmap(m_pix.scaled(595.2,792));  // 500 * 375
51         break;
52 
53     case 3:
54         imageArray.remove(0,10);
55         imageArray.resize(m_dataSize);
56         ui->textEdit->append(QTextCodec::codecForMib(106)->toUnicode(imageArray));
57         break;
58 
59     default:
60         break;
61     }
62 
63 }