在 QTCPSocket(Qt-C++) 中逐字节传输音频文件答案

【问题标题】：Audio file transfer byte by byte in QTCPSocket(Qt-C++)在 QTCPSocket(Qt-C++) 中逐字节传输音频文件
【发布时间】：2017-08-01 04:47:15
【问题描述】：

我需要在套接字中逐字节传输音频文件，在接收端我需要正确安排它。例如，有两个音频文件 A 和 B，我必须从 A 读取一个字节并传输，接下来我必须从 B 读取第一个字节并传输，然后从 A 读取第二个字节，从 B 读取第二个字节，这样传输有要在 EOF 之前完成，在接收方我必须为 A 和 B 组织正确接收的字节。

我在 TCP 套接字中的 C++(Qt) 中为一个音频文件尝试了上述方法。

QString path = "a4.wav";
QFile inputFile(path);
inputFile.open(QIODevice::ReadOnly);

QByteArray block;
QDataStream out(&block, QIODevice::WriteOnly);
out.setVersion(QDataStream::Qt_5_4);

QByteArray q = inputFile.readAll();
block.append(q);
inputFile.close();

out.device()->seek(0);

qint32 x = 0;
unsigned int i = 0;
while (x < block.size()) {
    qint32 y = socket->write(&block.data()[i],1);   //Filling one byte in socket to write
    x += y;
    //qDebug() << y;
    //qDebug() << x;    // summary size you send, so you can check recieved and replied sizes
    i++;
}

但是在上面的代码中，我正在填充和写入一个字节，但是接收方我得到了一堆字节（例如接收 14000 字节）。似乎写套接字中的缓冲区已填满，然后才发生传输。我必须做什么，一次只写一个字节？

【问题讨论】：

为什么要将文件读入字节数组 q 然后将其复制到块中？你为什么要打开 DataStream 'out'？
没有人对每个数据包执行 TCP 一个字节。 TCP 是一种流，因此网络设备可以根据需要对其进行切片和粘合。可以使用 UDP，但仍然会浪费，因为对于每个字节，您还发送了 20 到 40 字节长的数据包头。

标签： c++ qt byte transfer qtcpsocket

【解决方案1】：

您不应该基于逐字节的逻辑来执行 i/o，它效率不高。它还可以启用所谓的 Nagle 算法，该算法将在发送数据包之前等待更多数据。我在发送方的建议：

 QByte * p = buffer.data();
 int sizeLeft = static_cast<int>(buffer.size());
 while (sizeLeft > 0) {
      int n = socket.send(p, sizeLeft);
      if (n < 0) {
           // Error
           return false; // or throw exception 
      }
      p += n;
      sizeLeft -= n;
 }

在接收大小方面，您应该有一个不错的缓冲区，以便您可以进行相同的缓冲。该示例使用标准向量，但它也可能适用于 Qt 容器

int appendReceived(QSocket &socket, std::vector<std::uint32_t> buffer, int maxRecvLength) {
     size_t prevSize = buffer.size();
     buffer.resize(prevSize + maxRecvLength);
     int n = socket.recv(buffer.data() + prevSize, maxRecvLength);
     if (n < 0) {
         // Error
         return n; // or throw exception 
     }
     buffer.resize(prevSize + n);
}

在开始写入数据之前，您可以在发送端进行安排。

std::vector<std::uint8_t> mergeVectors(const std::vector<std::uint8_t> &a, const std::vector<std::uint8_t> &b) {
    std::vector<std::uint8_t> result;
    result.reserve(a.size() + b.size()));
    size_t minSize = std::min(a.size(), b.size());
    for(size_t i = 0; i < minSize; ++i) {
        result.push_back(a[i]);
        result.push_back(b[i]);
    }
    for (size_t i = minSize; i < a.size(); ++i) {
        result.push_back(a[i]);
    }
    for (size_t i = minSize; i < b.size(); ++i) {
        result.push_back(b[i]);
    }
    return result;
}

在接收方你可能有：

void splitAndRemoveFront(std::vector<std::uint8_t> &buffer, std::vector<std::uint8_t> &a, std::vector<std::uint8_t> &b, size_t asize, size_t bsize) {
    assert(buffer.size() >= asize + bsize);
    size_t minSize = std::min(asize, bsize);
    a.reserve(a.size() + asize);
    b.reserve(b.size() + bsize);
    auto p = buffer.begin();
    for(size_t i = 0; i < minSize; ++i) {
        a.push_back(*p++);
        b.push_back(*p++);
    }
    for (size_t i = minSize; i < asize; ++i) {
        a.push_back(*p++);
    }
    for (size_t i = minSize; i < bsize; ++i) {
        b.push_back(*p++);
    }
    buffer.erase(buffer.begin(), p);
}

当然，您还需要以某种方式传输文件的大小，但您了解基本概念。

【讨论】：