c++ - QSerialPort 读取错误的数据计数

Question

这是我想做的:

我有一个测量压力的测量设备。它通过 COM1 连接。通过发送“ASCII 字母 9”数据，可以从该设备中分别检索测量值。这些测量值应该显示在我的 GUI 中的 QTableView 子类中。我不希望 GUI 在从测量设备读取时卡住，所以我猜这称为非阻塞。

在我的代码和测试中，我想在 for 循环中检索 10 个测量值。但我总是只得到 6 个，有时是 7 个。

我还对 QSerialPort 进行了子类化。

代码如下所示。非常感谢提示我做错了什么，甚至更正我的代码。也可以随意评论代码的设计。

void MainWindow::startInspection()
{
    SauterFH_S *sauterFH_S;
    try
    {
        sauterFH_S = new SauterFH_S(new SerialPort(serialPort, 
        baudRate));
    }
    catch(QSerialPort::SerialPortError& e)
    {
        qDebug() << e;
    }

    connect(sauterFH_S, SIGNAL(measurandAvalaible(char*)),
        measurandTableWidget, SLOT(insertMeasurand(char*)));

    // Retrieve 10 measurements
    for(int i=0; i<10; ++i)
        sauterFH_S->getMeasurand();

    delete sauterFH_S;
}

子类QSerialPort的构造函数如下:

TASte::IO::SerialPort::SerialPort(const QString &portName, qint32 
    baudRate, DataBits dataBits, Parity parity, StopBits stopBits,
    QIODevice::OpenMode openMode, QObject *parent)
:QSerialPort(parent)
{
    setPort(QSerialPortInfo(portName));
    setBaudRate(baudRate);
    setDataBits(dataBits);
    setParity(parity);
    setStopBits(stopBits);

    if( !open(openMode) ) throw error();
}

剩下的应该是重要的:

TASte::Gauge::SauterFH_S::SauterFH_S(IO::SerialPort *port)
    :_port(port)
{

    connect(_port, SIGNAL(readyRead()),this, SLOT(onReadyRead()));
}

TASte::Gauge::SauterFH_S::~SauterFH_S()
{
    // delete _port;
}

void TASte::Gauge::SauterFH_S::getMeasurand()
{
    // typedef QByteArray SerialCommand
    IO::SerialCommand command("9");
    _port->write(command);
}


void TASte::Gauge::SauterFH_S::onReadyRead()
{
    // static const int DATA_LENGTH=8;
    char data[DATA_LENGTH];
    _port->read(data, DATA_LENGTH);

    emit measurandAvalaible(data);
}

提前致谢!

Answer 1

如果您在其他线程中发送和接收数据，则对象 QSerialPort 工作良好。在您的情况下，数据可能会丢失，并且程序有时会卡住。我有同样的问题。我给你看样东西。我在 UDP 中使用传输编写代码，但在串行端口中是相同的概念。所以首先你必须为你的串口创建线程。在我的例子中，我创建了 therad，但用于 UDP。并且您必须定义您的所有连接，每个连接都是线程 MainWindow 和 SerialPort 之间的一些交互。

    thForUdp = new QThread();
    udp->moveToThread(thForUdp);
    thForUdp->start();

    connect(this , SIGNAL(SIGNAL_RefreshStatus()) , udp , SLOT(SLOT_refreshStatus()) , Qt::QueuedConnection);
    connect(udp , SIGNAL(SIGNAL_TransmitionFailed()) , this , SLOT(SLOT_TrasmitionFailed()) , Qt::QueuedConnection); //od
    connect(udp , SIGNAL(SIGNAL_ActualStatus(QByteArray)) , schema , SLOT(SLOT_ActualStatus(QByteArray)) , Qt::QueuedConnection);
    connect(udp , SIGNAL(SIGNAL_RefreshTimer()) , this , SLOT(SLOT_StartRefreshTimer()) , Qt::QueuedConnection ); //do
    connect(this , SIGNAL(SIGNAL_GetAllName()) , udp , SLOT(SLOT_GetAllName()) , Qt::QueuedConnection );
    connect(udp , SIGNAL(SIGNAL_AllName(QVector<QString>)) , schema , SLOT(SLOT_AllName(QVector<QString>)), Qt::QueuedConnection);
    connect(udp , SIGNAL(SIGNAL_setEnableRefresh(bool)) , this , SLOT(SLOT_setEnableRefresh(bool)) , Qt::QueuedConnection);

现在您必须创建从 QSerialPort 继承的对象。在我的例子中，我继承自 QUdpSocket

class Udp : public QUdpSocket , public Object
{
    Q_OBJECT
public:
    Udp(Mediator *medium);

private slots:
    void SLOT_ReadyToReadStatus();

signals:
    void SIGNAL_TransmitionFailed();
    void SIGNAL_RefreshTimer();
    void SIGNAL_ActualStatus(QByteArray stat);
    void SIGNAL_AllName(QVector<QString> vec);
    void SIGNAL_setEnableRefresh(bool state);

};

如您所见，Udp 类具有所有 SIGNAL，然后您会在第一个 block 代码中看到。然后在串口类中创建正确的信号和插槽来发送和接收数据

在我的例子中，这是在 construktor Udp 中

QObject::connect(this , SIGNAL(readyRead()) , this  , SLOT(SLOT_ReadyToReadStatus()));`

现在您的程序将按照此规则运行。MainWindow 窗体 tread A 发送信号(获取数据)--->> 在线程 B 的对象串口中发送数据，在线程 B 中接收数据然后串口发送信号到线程 A(将接收到的数据发送到线程 A)--->> MainWindow 收到数据

非常重要是在 MainWindow 和 SerialPort 之间通过机制 SIGNAL & SLOT 进行通信，因为它们是两个不同的线程。这是QT规则。

此解决方案将使您的程序不会卡住并且数据会被完整接收，因为另一个线程会处理这个问题。

一般我建议在发送数据后使用函数waitForReadyRead()，并通过waitForReadtRead接收数据

{
    if(!this->waitForReadyRead(3000))
    {
     // here is wait for data maximum 3 second 
    // if recived your data find in slot SLOT_ReadyToReadStatus()

    }
// if data is correct receive from this block you send to Thread A via SIGNAL!!
QByteArray array
SIGNAL_Here_Data_To_To_Thread_A(array)


}

试试这个