发帖 回复
返回列表
  • 4890阅读
  • 2回复

qt 在接收两个基本上同时到来的数据时怎么办？ [复制链接]

 上一主题 下一主题
离线yu1121jm
新手上路
 
只看楼主 倒序阅读 楼主  发表于: 2012-04-04
关键词： 网络通信qtcpsocket
qt 在接收两个基本上同时到来的数据时怎么办？
1. 两个数据一起接收？ 我用了blockSize 控制接收大小，接收完后把blockSize=0。 这样如果我接收到了第一个接收到的数据，在清零前第二个数据有到了，那么会怎么办？
2. qt 的tcpSocket 接收数据时，有没有什么队列，会把第二个放在队列里面，等第一个接收玩，再接收第二个？
3. 我没有写多线程，请问怎么解决这个问题？
回复
举报
分享到 淘江湖 新浪 QQ微博 QQ空间 开心 人人 豆瓣 网易微博 百度 鲜果 白社会 飞信
离线ninsun
侠客
只看该作者 1楼 发表于: 2012-04-05
很遗憾...似乎没有内置的解决方案
当两个数据同时到来的时候, 你应该只会收到一个包... 并且,这一个包包含了两个数据....(当然, 还有可能是一个半数据...)
多线程似乎也解决不了这个问题
你需要自己定义一种数据传输协议来处理这种问题.
回复
举报
离线ninsun
侠客
只看该作者 2楼 发表于: 2012-04-05
附上我自己的处理函数, 包括发送与接收
复制代码
  1. void send( const QByteArray& data )
  2. {    
  3.     QMutexLocker _locker(&m_mutex);
  4.     if(m_pSocket && m_pSocket->isOpen() && !data.isEmpty())
  5.     {
  6.         QByteArray _msg = qCompress(data, 9);
  8.         // 在压缩的数据前附加上压缩的数据的长度
  9.         unsigned char _a = (_msg.length()&0xFF000000) >> 24;
  10.         unsigned char _b = (_msg.length()&0xFF0000) >> 16;
  11.         unsigned char _c = (_msg.length()&0xFF00) >> 8;
  12.         unsigned char _d = (_msg.length()&0xFF);
  14.         _msg.prepend(_d);
  15.         _msg.prepend(_c);
  16.         _msg.prepend(_b);
  17.         _msg.prepend(_a);
  19.         m_pSocket->write(_msg);
  20.         m_pSocket->flush();
  21.     }
  22. }
  24. void onConnectionReadyRead()
  25. {
  26.     QByteArray _buffer = m_pSocket->read(m_pSocket->bytesAvailable());
  28.     // 取得数据, 判断是否拥有数据长度信息(有则表示是新的数据)
  29.     m_tmpData.append(_buffer);
  31.     do
  32.     {
  33.         if (m_length == 0)  // 无数据长度
  34.         {
  35.             if (m_tmpData.length()>=4)
  36.             {
  37.                 unsigned int _a = (unsigned char)m_tmpData.at(0);
  38.                 unsigned int _b = (unsigned char)m_tmpData.at(1);
  39.                 unsigned int _c = (unsigned char)m_tmpData.at(2);
  40.                 unsigned int _d = (unsigned char)m_tmpData.at(3);
  41.                 // 获取数据长度
  42.                 m_length = (_a << 24) + (_b << 16) + (_c << 8) + _d;
  43.                 // 将数据长度从数据之中移除(只保留压缩后的数据)
  44.                 m_tmpData = m_tmpData.mid(4);
  45.             }
  46.             else
  47.             {
  48.                 return;
  49.             }
  50.         }
  51.         // 判断数据是否已经完整
  52.         if (m_tmpData.length() >= m_length)
  53.         {
  54.             // 获取完整的数据
  55.             _buffer = m_tmpData.left(m_length);
  56.             // 将剩余的数据继续保留(防止粘包)
  57.             m_tmpData = m_tmpData.mid(m_length);
  58.             // 将数据长度清空()
  59.             m_length = 0;
  60.         }
  61.         else
  62.         {
  63.             return;
  64.         }
  66.         try
  67.         {
  68.             _buffer = qUncompress(_buffer);
  69.         }
  70.         catch(...)
  71.         {
  72.             continue;
  73.         }
  75.         QString _msg = QString::fromUtf8(_buffer.data());
  77.         if(!_msg.isEmpty())
  78.         {
  79.         // 处理数据
  80.         }
  81.     } while (!m_tmpData.isEmpty());
  82. }
回复
举报
发帖 回复
返回列表
快速回复
限100 字节
 
上一个 下一个