从 QTcpSocket 读取（许多）值（快速）

Question

我正在使用一个测量设备，它使用最高 70 kHz 的 tcp 套接字发送（二进制）浮点值。

我的目标是尽可能快地读取这些值并将它们用于我程序的其他部分。

到目前为止，我能够使用 QTcpSocket 和 QDataStream 按值提取值：

首先我创建套接字并将流连接到它

mysock = new QTcpSocket(this);
mysock->connectToHost(ip, port);
QDataStream stream(mysock);
stream.setByteOrder(QDataStream::LittleEndian);
stream.setFloatingPointPrecision(QDataStream::SinglePrecision);

然后我从套接字读取并将流数据写入我的浮点值

while(true) //only for test purpose (dont stop reading)
if (mysock->waitForReadyRead())
{
    while (mysock->bytesAvailable() >= 6)
    {
        QByteArray a = mysock->read(6); //each value sent is 6 bytes long
        stream.skipRawData(2); //first 2 bytes don't belong to the number
        float result;
        stream >> result;
        //qDebug()<<result;
    }
}

当我测量 while(true) 循环的迭代频率时，我能够达到大约 30 kHz。 每次读取多个值我可以达到 70 Khz。 （不考虑其他可能会减慢我速度的计算）

我的问题是：

• 如果我一次读取多个值，如何从 QDataStream 中提取这些值？我需要一个 6 个字节的间距，其中只有 4 个字节包含该值。

答案：在我的情况下，有 2 个字节（垃圾）后跟已知数量的值，例如浮点数为 4 个字节，另一个浮点数为 4 个字节，uint16 为 2 个字节。

stream >> trashuint16 >> resultfloat1 >> resultfloat2 >> resultuint16

• 扩展 1：我可以配置我的设备以发送需要写入不同变量的不同类型（int、float）的不同值。

答案：相同。

• 是否有更有效的方法从 QTcpSocket 读取多个值？

答案：在 cmets 中回答。

更新（回答一些问题）：

• 以字节为单位的最大速率：70 kHz x 6 字节（对于一个值）= 420 kB/s（似乎没有那么多:)）

更新 2

• 新问题：当我开始交易（使用stream.startTransaction）时，我想知道二进制代码流中的内容。
• 我不明白QDataStream::startTransaction 的工作原理。将读取多少字节？我没有使用 >> 提取的数据会怎样？

我尝试了以下方法：

if (mysock->waitForReadyRead())
{
    stream.startTransaction();

    char *c = new char[40];
    stream.readRawData(c, 40);    //I want to know whats really inside    
    QByteArray a(c);
    qDebug() << a <<stream.status();
    if (!stream.commitTransaction())
        break;
}

一次又一次地这样做，我有时会得到 status = -1（读取太多），有时不会。如何获取流的“大小”？

Answer 1

您的代码有几个错误。

在使用QDataStream 的同时，您正在从套接字进行直接读取。这可能会破坏东西。

您的代码还假设您的应用程序将接收与另一端发送的数据块相同的数据。你没有这样的保证！您可能会收到在帧中间结束的块数据。它只是靠运气，或者你忽略了应用程序的一些错误。

这应该是这样的：

while(true)
if (mysock->waitForReadyRead()) // IMO doing such loop is terrible approach
// but this is Out of the scope of question, so ignoring that
{
    while (true)
    {
        stream.startTransaction();
        float result;
        qint32 somedata
        stream >> somedata >> result; // I do not know binary format your application is using

        if (!in.commitTransaction())
            break;

        AddDataToModel(result, somedata);
    } 
}

---

编辑：

来自评论：

如果我错了，请纠正我，但如果我想丢弃 2 个字节，我需要执行“stream >> someint(2 byte) >> somefloat(4 byte)”吗？如何处理流中的多个值？

qint16 toBeDiscarded;
float value; 
// note stream.setFloatingPointPrecision(QDataStream::SinglePrecision); 
// is needed to read float as 32 bit floating point number

stream >> toBeDiscarded >> value;
ProcessValue(value);