0

我正在使用一个测量设备，它使用高达 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 读取许多值？

回答：在评论中回答。

更新（回答一些问题）：

  • 以字节为单位的最大速率：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（读得太多），有时不会。如何获得流的“大小”？

4

1 回答 1

2

您的代码有几个错误。

在使用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);
于 2017-08-02T14:50:21.153 回答