• QT: 串口通信主站阻塞式实现

    1.运行结果

    2. 主程序调用

    1. #include "dialog.h"
    2.  
    3. #include 
    4.  
    5. int main(int argc, char *argv[])
    6. {
    7.     QApplication app(argc, argv);
    8.     Dialog dialog;
    9.     dialog.show();
    10.     return app.exec();
    11. }

     3. 对话框类实现

    //dialog.h

    1. #ifndef DIALOG_H
    2. #define DIALOG_H
    3.  
    4. #include "masterthread.h"
    5.  
    6. #include 
    7.  
    8. QT_BEGIN_NAMESPACE
    9.  
    10. class QLabel;
    11. class QLineEdit;
    12. class QSpinBox;
    13. class QPushButton;
    14. class QComboBox;
    15.  
    16. QT_END_NAMESPACE
    17.  
    18. class Dialog : public QDialog
    19. {
    20.     Q_OBJECT
    21.  
    22. public:
    23.     explicit Dialog(QWidget *parent = nullptr);
    24.  
    25. private slots:
    26.     void transaction();
    27.     void showResponse(const QString &s);
    28.     void processError(const QString &s);
    29.     void processTimeout(const QString &s);
    30.  
    31. private:
    32.     void setControlsEnabled(bool enable);
    33.  
    34. private:
    35.     int m_transactionCount = 0;
    36.     QLabel *m_serialPortLabel = nullptr;
    37.     QComboBox *m_serialPortComboBox = nullptr;
    38.     QLabel *m_waitResponseLabel = nullptr;
    39.     QSpinBox *m_waitResponseSpinBox = nullptr;
    40.     QLabel *m_requestLabel = nullptr;
    41.     QLineEdit *m_requestLineEdit = nullptr;
    42.     QLabel *m_trafficLabel = nullptr;
    43.     QLabel *m_statusLabel = nullptr;
    44.     QPushButton *m_runButton = nullptr;
    45.  
    46.     MasterThread m_thread;
    47. };
    48.  
    49. #endif // DIALOG_H

    //dialog.cpp

    1. #include "dialog.h"
    2.  
    3. #include 
    4. #include 
    5. #include 
    6. #include 
    7. #include 
    8. #include 
    9. #include 
    10.  
    11. Dialog::Dialog(QWidget *parent) :
    12.     QDialog(parent),
    13.     m_serialPortLabel(new QLabel(tr("Serial port:"))),
    14.     m_serialPortComboBox(new QComboBox),
    15.     m_waitResponseLabel(new QLabel(tr("Wait response, msec:"))),
    16.     m_waitResponseSpinBox(new QSpinBox),
    17.     m_requestLabel(new QLabel(tr("Request:"))),
    18.     m_requestLineEdit(new QLineEdit(tr("Who are you?"))),
    19.     m_trafficLabel(new QLabel(tr("No traffic."))),
    20.     m_statusLabel(new QLabel(tr("Status: Not running."))),
    21.     m_runButton(new QPushButton(tr("Start")))
    22. {
    23.     const auto infos = QSerialPortInfo::availablePorts();
    24.     for (const QSerialPortInfo &info : infos)
    25.         m_serialPortComboBox->addItem(info.portName());
    26.  
    27.     m_waitResponseSpinBox->setRange(0, 10000);
    28.     m_waitResponseSpinBox->setValue(1000);
    29.  
    30.     auto mainLayout = new QGridLayout;
    31.     mainLayout->addWidget(m_serialPortLabel, 0, 0);
    32.     mainLayout->addWidget(m_serialPortComboBox, 0, 1);
    33.     mainLayout->addWidget(m_waitResponseLabel, 1, 0);
    34.     mainLayout->addWidget(m_waitResponseSpinBox, 1, 1);
    35.     mainLayout->addWidget(m_runButton, 0, 2, 2, 1);
    36.     mainLayout->addWidget(m_requestLabel, 2, 0);
    37.     mainLayout->addWidget(m_requestLineEdit, 2, 1, 1, 3);
    38.     mainLayout->addWidget(m_trafficLabel, 3, 0, 1, 4);
    39.     mainLayout->addWidget(m_statusLabel, 4, 0, 1, 5);
    40.     setLayout(mainLayout);
    41.  
    42.     setWindowTitle(tr("Blocking Master"));
    43.     m_serialPortComboBox->setFocus();
    44.  
    45.     connect(m_runButton, &QPushButton::clicked, this, &Dialog::transaction);
    46.     connect(&m_thread, &MasterThread::response, this, &Dialog::showResponse);
    47.     connect(&m_thread, &MasterThread::error, this, &Dialog::processError);
    48.     connect(&m_thread, &MasterThread::timeout, this, &Dialog::processTimeout);
    49. }
    50.  
    51. void Dialog::transaction()
    52. {
    53.     setControlsEnabled(false);
    54.     m_statusLabel->setText(tr("Status: Running, connected to port %1.")
    55.                            .arg(m_serialPortComboBox->currentText()));
    56.     m_thread.transaction(m_serialPortComboBox->currentText(),
    57.                          m_waitResponseSpinBox->value(),
    58.                          m_requestLineEdit->text());
    59. }
    60.  
    61. void Dialog::showResponse(const QString &s)
    62. {
    63.     setControlsEnabled(true);
    64.     m_trafficLabel->setText(tr("Traffic, transaction #%1:"
    65.                                "\n\r-request: %2"
    66.                                "\n\r-response: %3")
    67.                             .arg(++m_transactionCount)
    68.                             .arg(m_requestLineEdit->text())
    69.                             .arg(s));
    70. }
    71.  
    72. void Dialog::processError(const QString &s)
    73. {
    74.     setControlsEnabled(true);
    75.     m_statusLabel->setText(tr("Status: Not running, %1.").arg(s));
    76.     m_trafficLabel->setText(tr("No traffic."));
    77. }
    78.  
    79. void Dialog::processTimeout(const QString &s)
    80. {
    81.     setControlsEnabled(true);
    82.     m_statusLabel->setText(tr("Status: Running, %1.").arg(s));
    83.     m_trafficLabel->setText(tr("No traffic."));
    84. }
    85.  
    86. void Dialog::setControlsEnabled(bool enable)
    87. {
    88.     m_runButton->setEnabled(enable);
    89.     m_serialPortComboBox->setEnabled(enable);
    90.     m_waitResponseSpinBox->setEnabled(enable);
    91.     m_requestLineEdit->setEnabled(enable);
    92. }

    4.串口服务器线程实现

    //masterthread.h

    1. #ifndef MASTERTHREAD_H
    2. #define MASTERTHREAD_H
    3.  
    4. #include 
    5. #include 
    6. #include 
    7.  
    8. class MasterThread : public QThread
    9. {
    10.     Q_OBJECT
    11.  
    12. public:
    13.     explicit MasterThread(QObject *parent = nullptr);
    14.     ~MasterThread();
    15.  
    16.     void transaction(const QString &portName, int waitTimeout, const QString &request);
    17.     QByteArray HexStringToByteArray(QString HexString);
    18.  
    19. signals:
    20.     void response(const QString &s);
    21.     void error(const QString &s);
    22.     void timeout(const QString &s);
    23.  
    24. private:
    25.     void run() override;
    26.  
    27.     QString m_portName;
    28.     QString m_request;
    29.     int m_waitTimeout = 0;
    30.     QMutex m_mutex;
    31.     QWaitCondition m_cond;
    32.     bool m_quit = false;
    33. };
    34.  
    35. #endif // MASTERTHREAD_H

    //masterthread.cpp

    1. #include "masterthread.h"
    2.  
    3. #include 
    4. #include 
    5. #include 
    6.  
    7. MasterThread::MasterThread(QObject *parent) :
    8.     QThread(parent)
    9. {
    10. }
    11.  
    12. MasterThread::~MasterThread()
    13. {
    14.     m_mutex.lock();
    15.     m_quit = true;
    16.     m_cond.wakeOne();
    17.     m_mutex.unlock();
    18.     wait();
    19. }
    20.  
    21. void MasterThread::transaction(const QString &portName, int waitTimeout, const QString &request)
    22. {
    23.     const QMutexLocker locker(&m_mutex);
    24.     m_portName = portName;
    25.     m_waitTimeout = waitTimeout;
    26.     m_request = request;
    27.     if (!isRunning())
    28.         start();
    29.     else
    30.         m_cond.wakeOne();
    31. }
    32.  
    33. void MasterThread::run()
    34. {
    35.     bool currentPortNameChanged = false;
    36.  
    37.     m_mutex.lock();
    38.     QString currentPortName;
    39.     if (currentPortName != m_portName) {
    40.         currentPortName = m_portName;
    41.         currentPortNameChanged = true;
    42.     }
    43.  
    44.     int currentWaitTimeout = m_waitTimeout;
    45.     QString currentRequest = m_request;
    46.     m_mutex.unlock();
    47.     QSerialPort serial;
    48.  
    49.     if (currentPortName.isEmpty()) {
    50.         emit error(tr("No port name specified"));
    51.         return;
    52.     }
    53.  
    54.     while (!m_quit) {
    55.         if (currentPortNameChanged) {
    56.             serial.close();
    57.             serial.setPortName(currentPortName);
    58.             serial.setBaudRate(57600);
    59.             serial.setStopBits(QSerialPort::TwoStop);
    60.  
    61.             if (!serial.open(QIODevice::ReadWrite)) {
    62.                 emit error(tr("Can't open %1, error code %2")
    63.                            .arg(m_portName).arg(serial.error()));
    64.                 return;
    65.             }
    66.         }
    67.         // write request
    68.         //const QByteArray requestData = currentRequest.toUtf8();
    69.         const QByteArray requestData = HexStringToByteArray(currentRequest);
    70.  
    71.         serial.write(requestData);
    72.         if (serial.waitForBytesWritten(m_waitTimeout)) {
    73.             // read response
    74.             if (serial.waitForReadyRead(currentWaitTimeout)) {
    75.                 QByteArray responseData = serial.readAll();
    76.                 while (serial.waitForReadyRead(10))
    77.                     responseData += serial.readAll();
    78.  
    79.                 const QString response = QString::fromUtf8(responseData);
    80.                 emit this->response(response);
    81.             } else {
    82.                 emit timeout(tr("Wait read response timeout %1")
    83.                              .arg(QTime::currentTime().toString()));
    84.             }
    85.         } else {
    86.             emit timeout(tr("Wait write request timeout %1")
    87.                          .arg(QTime::currentTime().toString()));
    88.         }
    89.         m_mutex.lock();
    90.         m_cond.wait(&m_mutex);
    91.         if (currentPortName != m_portName) {
    92.             currentPortName = m_portName;
    93.             currentPortNameChanged = true;
    94.         } else {
    95.             currentPortNameChanged = false;
    96.         }
    97.         currentWaitTimeout = m_waitTimeout;
    98.         currentRequest = m_request;
    99.         m_mutex.unlock();
    100.     }
    101. }
    102.  
    103. QByteArray MasterThread::HexStringToByteArray(QString HexString)
    104. {
    105.     bool ok;
    106.     QByteArray ret;
    107.     HexString = HexString.trimmed();
    108.     HexString = HexString.simplified();
    109.     QStringList sl = HexString.split(" ");
    110.  
    111.     foreach (QString s, sl) {
    112.         if(!s.isEmpty())
    113.         {
    114.             char c = s.toInt(&ok,16) & 0xFF;
    115.             if(ok){
    116.                 ret.append(c);
    117.             }else{
    118.                 qDebug()<<"invalid hex string"<
    119.             }
    120.         }
    121.     }
    122.     //qDebug()<
    123.     return ret;
    124. }

  • 相关阅读:
    java里面List＜Object＞转map，List＜String＞
    期末前端web大作业——HTML+CSS+JavaScript仿京东购物商城网页制作(7页)
    AI学习路线
    栈的压入、弹出序列
    尝试进行表格处理
    携职教育：2022下半年系统集成项目管理工程师备考常见问题
    Vue 组件间通信方式汇总，总有一款适合你( 附项目实战案例 )
    CHATGPT中国免费网页版有哪些-CHATGPT中文版网页
    【解刊】IEEE旗下Trans系列，中科院1区TOP，国人占比79.388%排名第一！（附IEEE名单）
    python 脚本 解决 windows 端口占用问题
  • 原文地址：https://blog.csdn.net/zkmrobot/article/details/128018674