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

Question

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

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

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 字节）。似乎写套接字中的缓冲区已满，然后只发生传输。我必须做什么，一次只写一个字节？

Answer 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;
 }

关于接收大小，您应该有一个合适的缓冲区，以便您可以进行相同的缓冲。该示例使用 std 向量，但它也可能适用于 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);
}

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

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

Audio file transfer byte by byte in QTCPSocket(Qt-C++)

c++

qt

byte

transfer

qtcpsocket