Qt中几个常用的串口modbus类
QModbusRtuSerialSlave //modbus串口通信方式下的服务器类
QModbusRtuSerialMaster //串口通信方式下的客户端类
QModbusServer // QModbusServer类接收和处理modbus的请求。
QModbusDataUnit //存储接收和发送数据的类，数据类型为1bit和16bit
QModbusReply //客户端访问服务器后得到的回复（如客户端读服务器数据时包含数据信息）
Windows系统：Windows10
Qt版本：Qt5.15或者Qt6
Pro配置文件如下
QT += core gui serialbus serialport
greaterThan(QT_MAJOR_VERSION, 4): QT += widgets
CONFIG += c++11
# You can make your code fail to compile if it uses deprecated APIs.
# In order to do so, uncomment the following line.
#DEFINES += QT_DISABLE_DEPRECATED_BEFORE=0x060000 # disables all the APIs deprecated before Qt 6.0.0
SOURCES += \
main.cpp \
widget.cpp
HEADERS += \
widget.h
# Default rules for deployment.
qnx: target.path = /tmp/$${TARGET}/bin
else: unix:!android: target.path = /opt/$${TARGET}/bin
!isEmpty(target.path): INSTALLS += target
widget.h文件
#ifndef WIDGET_H
#define WIDGET_H
#include <QWidget>
//前向声明
class QModbusClient;
class QModbusReply;
class Widget : public QWidget
{
Q_OBJECT
public:
Widget(QWidget *parent = nullptr);
~Widget();
private:
QModbusClient *modbusDevice = nullptr;
private slots:
void onReadReady();
};
#endif // WIDGET_H
widget.cpp文件
#include "widget.h"
#include <QModbusRtuSerialMaster>
#include <QModbusDataUnit>
#include <QModbusReply>
#include <QVariant>
#include <QSerialPort>
#include <QDebug>
//构造函数
Widget::Widget(QWidget *parent)
: QWidget(parent)
{
//1. 创建QModbusDevice对象
modbusDevice = new QModbusRtuSerialMaster;
//2. 如果处于连接状态，则断开连接
if (modbusDevice->state() == QModbusDevice::ConnectedState)
{
//断开连接设备
modbusDevice->disconnectDevice();
}
//3. 设置串口相关参数
//设置串口信息
modbusDevice->setConnectionParameter(QModbusDevice::SerialPortNameParameter, QVariant("COM3"));
//设置校验 无校验
modbusDevice->setConnectionParameter(QModbusDevice::SerialParityParameter, QSerialPort::NoParity);
//设置波特率
modbusDevice->setConnectionParameter(QModbusDevice::SerialBaudRateParameter, QSerialPort::Baud19200);
//设置停止位
modbusDevice->setConnectionParameter(QModbusDevice::SerialStopBitsParameter, QSerialPort::OneStop);
//设置数据位
modbusDevice->setConnectionParameter(QModbusDevice::SerialDataBitsParameter, QSerialPort::Data8);
//4. 设置其他信息
//设置超时时间
modbusDevice->setTimeout(1000); //1秒
//设置失败重试次数
modbusDevice->setNumberOfRetries(3);
//5. 连接到设备
bool ok = modbusDevice->connectDevice();
if (!ok)
{
qDebug() << "连接到串口失败： " << modbusDevice->errorString();
}
else
{
qDebug() << "连接到串口成功";
}
//6. 发送写请求
//从地址0开始写10个保持寄存器的值
//QModbusDataUnit writeData(QModbusDataUnit::HoldingRegisters, 0, 10);
//从地址0开始写10个线圈的值
QModbusDataUnit writeData(QModbusDataUnit::Coils, 0, 10);
for (int i = 0; i < writeData.valueCount(); i++)
{
writeData.setValue(i, (i * i) % 2);
}
qDebug() << "发送的数据为： " << writeData.values();
QModbusReply* reply = modbusDevice->sendWriteRequest(writeData, 1);
if (reply)
{
if (!reply->isFinished())
{
//接收响应信息
connect(reply, &QModbusReply::finished, this, [this, reply](){
if (reply->error() == QModbusDevice::ProtocolError)
{
//接收到的响应信息是协议错误
qDebug() << "写入数据错误：" << reply->errorString();
}
else if (reply->error() != QModbusDevice::NoError)
{
//接收到的响应消息是其它错误
qDebug() << "写入数据错误： " << reply->errorString();
}
else
{
//接收到的消息没有错误 一般没有必要解析响应消息
const QModbusDataUnit data = reply->result();
qDebug() << "消息数据个数：" << data.valueCount() << " :" << data.values();
}
reply->deleteLater();
});
}
else
{
//发送没有响应数据
//broadcast replies return immediately
reply->deleteLater();
}
}
else
{
qDebug() << "sendWriteRequest Error: " << reply->errorString();
}
//7. 发送读取数据请求
//从地址0开始读取10个保持寄存器的值
//QModbusDataUnit data(QModbusDataUnit::HoldingRegisters, 0, 10);
//从地址0开始读取10个离散输入量的值
//QModbusDataUnit data(QModbusDataUnit::DiscreteInputs, 0, 10);
//QModbusDataUnit::Coils 从地址0开始读取10个线圈值
QModbusDataUnit data(QModbusDataUnit::Coils, 0, 10);
//QModbusDataUnit::InputRegisters 从地址0开始读取10个输入寄存器的值
//QModbusDataUnit data(QModbusDataUnit::InputRegisters, 0, 10);
reply = modbusDevice->sendReadRequest(data, 0x1);
if (nullptr == reply)
{
qDebug() << "发送请求数据失败: " << modbusDevice->errorString();
}
else
{
if (!reply->isFinished())
{
connect(reply, &QModbusReply::finished, this, &Widget::onReadReady);
}
else
{
//broadcast replies return immediately
delete reply;
}
}
}
//析构函数
Widget::~Widget()
{
if (modbusDevice)
{
modbusDevice->disconnectDevice();
}
delete modbusDevice;
}
//准备读取数据的槽函数
void Widget::onReadReady()
{
auto reply = qobject_cast<QModbusReply*>(sender());
if (nullptr == reply)
{
return;
}
//判断是否出错
if (reply->error() == QModbusDevice::NoError)
{
//读取响应数据
const QModbusDataUnit responseData = reply->result();
qDebug() << "读到数据为：" << responseData.values();
}
else if (reply->error() == QModbusDevice::ProtocolError)
{
qDebug() << "Read response Protocol error: " << reply->errorString();
}
else
{
qDebug() << "Read response Error: " << reply->errorString();
}
//删除reply
reply->deleteLater();
}
执行结果
20:32:27: Starting D:\ProgramData\Qt\build-Test-Desktop_Qt_5_15_2_MinGW_32_bit-Debug\debug\Test.exe ...
连接到串口成功
发送的数据为： QVector(0, 1, 0, 1, 0, 1, 0, 1, 0, 1)
消息数据个数： 10 : QVector(0, 1, 0, 1, 0, 1, 0, 1, 0, 1)
读到数据为： QVector(0, 1, 0, 1, 0, 1, 0, 1, 0, 1)
20:34:02: D:\ProgramData\Qt\build-Test-Desktop_Qt_5_15_2_MinGW_32_bit-Debug\debug\Test.exe exited with code 0
widget.h文件
#ifndef WIDGET_H
#define WIDGET_H
#include <QWidget>
//前向声明
class QModbusClient;
class QModbusReply;
class Widget : public QWidget
{
Q_OBJECT
public:
Widget(QWidget *parent = nullptr);
~Widget();
private:
QModbusClient *modbusDevice = nullptr;
private slots:
void onReadReady();
};
#endif // WIDGET_H
widget.cpp文件
#include "widget.h"
#include <QModbusRtuSerialMaster>
#include <QModbusDataUnit>
#include <QModbusReply>
#include <QVariant>
#include <QSerialPort>
#include <QDebug>
//构造函数
Widget::Widget(QWidget *parent)
: QWidget(parent)
{
//1. 创建QModbusDevice对象
modbusDevice = new QModbusRtuSerialMaster;
//2. 如果处于连接状态，则断开连接
if (modbusDevice->state() == QModbusDevice::ConnectedState)
{
//断开连接设备
modbusDevice->disconnectDevice();
}
//3. 设置串口相关参数
//设置串口信息
modbusDevice->setConnectionParameter(QModbusDevice::SerialPortNameParameter, QVariant("COM3"));
//设置校验 无校验
modbusDevice->setConnectionParameter(QModbusDevice::SerialParityParameter, QSerialPort::NoParity);
//设置波特率
modbusDevice->setConnectionParameter(QModbusDevice::SerialBaudRateParameter, QSerialPort::Baud19200);
//设置停止位
modbusDevice->setConnectionParameter(QModbusDevice::SerialStopBitsParameter, QSerialPort::OneStop);
//设置数据位
modbusDevice->setConnectionParameter(QModbusDevice::SerialDataBitsParameter, QSerialPort::Data8);
//4. 设置其他信息
//设置超时时间
modbusDevice->setTimeout(1000); //1秒
//设置失败重试次数
modbusDevice->setNumberOfRetries(3);
//5. 连接到设备
bool ok = modbusDevice->connectDevice();
if (!ok)
{
qDebug() << "连接到串口失败： " << modbusDevice->errorString();
}
else
{
qDebug() << "连接到串口成功";
}
//6. 发送写请求
//从地址0开始写10个保持寄存器的值
QModbusDataUnit writeData(QModbusDataUnit::HoldingRegisters, 0, 10);
for (int i = 0; i < writeData.valueCount(); i++)
{
writeData.setValue(i, i * i);
}
qDebug() << "发送的数据为： " << writeData.values();
QModbusReply* reply = modbusDevice->sendWriteRequest(writeData, 1);
if (reply)
{
if (!reply->isFinished())
{
//接收响应信息
connect(reply, &QModbusReply::finished, this, [this, reply](){
if (reply->error() == QModbusDevice::ProtocolError)
{
//接收到的响应信息是协议错误
qDebug() << "写入数据错误：" << reply->errorString();
}
else if (reply->error() != QModbusDevice::NoError)
{
//接收到的响应消息是其它错误
qDebug() << "写入数据错误： " << reply->errorString();
}
else
{
//接收到的消息没有错误 一般没有必要解析响应消息
const QModbusDataUnit data = reply->result();
qDebug() << "消息数据个数：" << data.valueCount() << " :" << data.values();
}
reply->deleteLater();
});
}
else
{
//发送没有响应数据
//broadcast replies return immediately
reply->deleteLater();
}
}
else
{
qDebug() << "sendWriteRequest Error: " << reply->errorString();
}
//7. 发送读取数据请求
//从地址0开始读取10个保持寄存器的值
QModbusDataUnit data(QModbusDataUnit::HoldingRegisters, 0, 10);
//从地址0开始读取10个离散输入量的值
//QModbusDataUnit data(QModbusDataUnit::DiscreteInputs, 0, 10);
//QModbusDataUnit::Coils 从地址0开始读取10个线圈值
//QModbusDataUnit data(QModbusDataUnit::Coils, 0, 10);
//QModbusDataUnit::InputRegisters 从地址0开始读取10个输入寄存器的值
//QModbusDataUnit data(QModbusDataUnit::InputRegisters, 0, 10);
reply = modbusDevice->sendReadRequest(data, 0x1);
if (nullptr == reply)
{
qDebug() << "发送请求数据失败: " << modbusDevice->errorString();
}
else
{
if (!reply->isFinished())
{
connect(reply, &QModbusReply::finished, this, &Widget::onReadReady);
}
else
{
//broadcast replies return immediately
delete reply;
}
}
}
//析构函数
Widget::~Widget()
{
if (modbusDevice)
{
modbusDevice->disconnectDevice();
}
delete modbusDevice;
}
//准备读取数据的槽函数
void Widget::onReadReady()
{
auto reply = qobject_cast<QModbusReply*>(sender());
if (nullptr == reply)
{
return;
}
//判断是否出错
if (reply->error() == QModbusDevice::NoError)
{
//读取响应数据
const QModbusDataUnit responseData = reply->result();
qDebug() << "读到数据为：" << responseData.values();
}
else if (reply->error() == QModbusDevice::ProtocolError)
{
qDebug() << "Read response Protocol error: " << reply->errorString();
}
else
{
qDebug() << "Read response Error: " << reply->errorString();
}
//删除reply
reply->deleteLater();
}
执行结果
20:23:23: Starting D:\ProgramData\Qt\build-Test-Desktop_Qt_5_15_2_MinGW_32_bit-Debug\debug\Test.exe ...
连接到串口成功
发送的数据为： QVector(0, 1, 4, 9, 16, 25, 36, 49, 64, 81)
消息数据个数： 10 : QVector(0, 1, 4, 9, 16, 25, 36, 49, 64, 81)
读到数据为： QVector(0, 1, 4, 9, 16, 25, 36, 49, 64, 81)
20:23:29: D:\ProgramData\Qt\build-Test-Desktop_Qt_5_15_2_MinGW_32_bit-Debug\debug\Test.exe exited with code 0
程序界面
[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-J2Oiv0Co-1621479015968)(assets/image-20210520104421393.png)]
settingdialog.h文件
#ifndef SETTINGDIALOG_H
#define SETTINGDIALOG_H
#include <QDialog>
#include <QtSerialPort>
namespace Ui {
class SettingDialog;
}
//串口设置相关类
class SettingDialog : public QDialog
{
Q_OBJECT
public:
struct Settings
{
//串口名
QString serialName = "COM3";
//校验位
int parity = QSerialPort::NoParity;
//波特率
int baud = QSerialPort::Baud19200;
//数据位
int dataBits = QSerialPort::Data8;
//停止位
int stopBits = QSerialPort::OneStop;
//响应时间
int responseTime = 1000;
//重试次数
int numberOfRetries = 3;
};
explicit SettingDialog(QWidget *parent = nullptr);
~SettingDialog();
//返回参数设置信息
Settings settings() const;
private slots:
void on_btnApply_clicked();
private:
Ui::SettingDialog *ui;
Settings m_settings;
};
#endif // SETTINGDIALOG_H
settingdialog.cpp文件
#include "settingdialog.h"
#include "ui_settingdialog.h"
//构造函数
SettingDialog::SettingDialog(QWidget *parent) :
QDialog(parent),
ui(new Ui::SettingDialog)
{
ui->setupUi(this);
//设置默认参数信息
ui->serialNameLineEdit->setText(tr("COM3"));
ui->parityComboBox->setCurrentIndex(0);
ui->baudComboBox->setCurrentText(QString::number(m_settings.baud));
ui->dataBitComboBox->setCurrentText(QString::number(m_settings.dataBits));
ui->stopBitComboBox->setCurrentText(QString::number(m_settings.stopBits));
ui->spinBoxTimeOut->setValue(m_settings.responseTime);
ui->spinBoxRetry->setValue(m_settings.numberOfRetries);
}
//析构函数
SettingDialog::~SettingDialog()
{
delete ui;
}
//返回参数信息
SettingDialog::Settings SettingDialog::settings() const
{
return m_settings;
}
//引用按钮槽函数
void SettingDialog::on_btnApply_clicked()
{
m_settings.serialName = ui->serialNameLineEdit->text();
m_settings.parity = ui->parityComboBox->currentText().toInt();
m_settings.baud = ui->baudComboBox->currentText().toInt();
m_settings.dataBits = ui->dataBitComboBox->currentText().toInt();
m_settings.stopBits = ui->stopBitComboBox->currentText().toInt();
m_settings.responseTime = ui->spinBoxTimeOut->value();
m_settings.numberOfRetries = ui->spinBoxRetry->value();
//隐藏参数设置对话框
hide();
}
mainwindow.h文件
#ifndef MAINWINDOW_H
#define MAINWINDOW_H
#include <QMainWindow>
#include <QModbusDataUnit>
#include "writeregistermodel.h"
QT_BEGIN_NAMESPACE
namespace Ui
{
class MainWindow;
}
class SettingDialog;
class QModbusClient;
class QModbusReply;
QT_END_NAMESPACE
class MainWindow : public QMainWindow
{
Q_OBJECT
public:
MainWindow(QWidget *parent = nullptr);
~MainWindow();
//信号与槽进行关联
void initActions();
//读请求数据包封装
QModbusDataUnit readRequest() const;
//写请求数据包封装
QModbusDataUnit writeRequest() const;
private slots:
void onConnectButtonClicked();
void onConnectTypeChanged(int);
void onModbusStateChanged(int state);
void onReadButtonClicked();
void onReadReady();
void onWriteButtonClicked();
void onReadWriteButtonClicked();
void onWriteTableChanged(int);
private:
Ui::MainWindow *ui = nullptr;
SettingDialog *m_settingDialog = nullptr;
QModbusClient *modbusDevice = nullptr;
QModbusReply *reply = nullptr;
WriteRegisterModel *writeModel = nullptr;
};
#endif // MAINWINDOW_H
mainwindow.cpp文件
#include "mainwindow.h"
#include "ui_mainwindow.h"
#include <QMessageBox>
#include "settingdialog.h"
#include <QModbusRtuSerialMaster>
#include <QModbusReply>
#include <QStandardItemModel>
#include <QModbusDataUnit>
//连接类型枚举变量
enum ModbusConnection {
Serial,
Tcp
};
MainWindow::MainWindow(QWidget *parent)
: QMainWindow(parent)
, ui(new Ui::MainWindow)
{
ui->setupUi(this);
//创建对象
m_settingDialog = new SettingDialog(this);
//初始化信号与槽
initActions();
//创建写模型
writeModel = new WriteRegisterModel(this);
writeModel->setStartAddress(ui->sbWriteStartAddr->value());
writeModel->setNumberOfValues(ui->cbWriteCount->currentText());
//MVC
ui->treeViewWrite->setModel(writeModel);
//隐藏第二列
ui->treeViewWrite->hideColumn(2);
connect(writeModel, &WriteRegisterModel::updateViewport,
ui->treeViewWrite->viewport(), QOverload<>::of(&QWidget::update));
//默认为串口连接方式
ui->cbConnType->setCurrentIndex(0);
onConnectTypeChanged(0);
auto model = new QStandardItemModel(10, 1, this);
for (int i = 0; i < 10; i++)
{
model->setItem(i, new QStandardItem(QStringLiteral("%1").arg(i + 1)));
}
ui->cbWriteCount->setModel(model);
ui->cbWriteCount->setCurrentText("10");
connect(ui->cbWriteCount, &QComboBox::currentTextChanged,
writeModel, &WriteRegisterModel::setNumberOfValues);
auto valueChanged = QOverload<int>::of(&QSpinBox::valueChanged);
connect(ui->sbWriteStartAddr, valueChanged, writeModel, &WriteRegisterModel::setStartAddress);
connect(ui->sbWriteStartAddr, valueChanged, this, [this, model](int i){
int lastIndex = 0;
const int curIndex = ui->cbWriteCount->currentIndex();
for (int j = 0; j < 10; j++)
{
//设置使能
if (j < (10 - i))
{
lastIndex = j;
model->item(j)->setEnabled(true);
}
else
{
//设置禁用
model->item(j)->setEnabled(false);
}
}
if (curIndex > lastIndex)
{
ui->cbWriteCount->setCurrentIndex(lastIndex);
}
});
}
//析构函数
MainWindow::~MainWindow()
{
if (modbusDevice)
{
modbusDevice->disconnectDevice();
delete modbusDevice;
}
delete ui;
}
//信号与槽进行关联s
void MainWindow::initActions()
{
//使能部分功能
ui->actionConnect->setEnabled(true);
ui->actionDisconnect->setEnabled(false);
ui->actionQuit->setEnabled(true);
ui->actionOption->setEnabled(true);
//禁用读写操作
ui->btnRead->setEnabled(false);
ui->btnWrite->setEnabled(false);
ui->btnReadWrite->setEnabled(false);
//信号与槽关联
connect(ui->btnConnect, &QPushButton::clicked,
this, &MainWindow::onConnectButtonClicked);
connect(ui->actionConnect, &QAction::triggered,
this, &MainWindow::onConnectButtonClicked);
connect(ui->actionDisconnect, &QAction::triggered,
this, &MainWindow::onConnectButtonClicked);
//读操作按钮槽函数关联
connect(ui->btnRead, &QPushButton::clicked,
this, &MainWindow::onReadButtonClicked);
connect(ui->btnWrite, &QPushButton::clicked,
this, &MainWindow::onWriteButtonClicked);
connect(ui->btnReadWrite, &QPushButton::clicked,
this, &MainWindow::onReadWriteButtonClicked);
connect(ui->cbRegisterType, QOverload<int>::of(&QComboBox::currentIndexChanged),
this, &MainWindow::onWriteTableChanged);
connect(ui->cbConnType, QOverload<int>::of(&QComboBox::currentIndexChanged),
this, &MainWindow::onConnectTypeChanged);
//退出菜单
connect(ui->actionQuit, &QAction::triggered, this, &MainWindow::close);
//显示参数设置对话框
connect(ui->actionOption, &QAction::triggered, m_settingDialog, &QDialog::show);
connect(ui->actionAbout, &QAction::triggered, [=]() {
QMessageBox::aboutQt(this, "About Qt");
});
}
//构建请求报文
QModbusDataUnit MainWindow::readRequest() const
{
//const auto type = static_cast<QModbusDataUnit::RegisterType>(ui->cbRegisterType->currentData().toInt());
QModbusDataUnit::RegisterType type = QModbusDataUnit::Invalid;
qDebug() << ui->cbRegisterType->currentText();
if (ui->cbRegisterType->currentText() == QString("线圈"))
{
type = QModbusDataUnit::Coils;
}
else if (ui->cbRegisterType->currentText() == QString("离散输入"))
{
type = QModbusDataUnit::DiscreteInputs;
}
else if (ui->cbRegisterType->currentText() == QString("输入寄存器"))
{
type = QModbusDataUnit::InputRegisters;
}
else if (ui->cbRegisterType->currentText() == QString("保持寄存器"))
{
type = QModbusDataUnit::HoldingRegisters;
}
qDebug() << "请求报文类型: " << type;
//获取
int startAddress = ui->spReadStartAddr->value();
Q_ASSERT(startAddress >= 0 && startAddress < 10);
quint16 numberOfEntries = ui->cbReadCount->currentText().toUShort();
return QModbusDataUnit(type, startAddress, numberOfEntries);
}
//写请求数据包封装
QModbusDataUnit MainWindow::writeRequest() const
{
QModbusDataUnit::RegisterType type = QModbusDataUnit::Invalid;
qDebug() << ui->cbRegisterType->currentText();
if (ui->cbRegisterType->currentText() == QString("线圈"))
{
type = QModbusDataUnit::Coils;
}
else if (ui->cbRegisterType->currentText() == QString("离散输入"))
{
type = QModbusDataUnit::DiscreteInputs;
}
else if (ui->cbRegisterType->currentText() == QString("输入寄存器"))
{
type = QModbusDataUnit::InputRegisters;
}
else if (ui->cbRegisterType->currentText() == QString("保持寄存器"))
{
type = QModbusDataUnit::HoldingRegisters;
}
qDebug() << "请求报文类型: " << type;
//获取
int startAddress = ui->sbWriteStartAddr->value();
Q_ASSERT(startAddress >= 0 && startAddress < 10);
quint16 numberOfEntries = ui->cbWriteCount->currentText().toUShort();
//qDebug() << "Test: " << startAddress << " " << numberOfEntries;
return QModbusDataUnit(type, startAddress, numberOfEntries);
}
//连接和断开连接的槽函数
void MainWindow::onConnectButtonClicked()
{
if (!modbusDevice)
{
return;
}
//清空状态栏消息
statusBar()->clearMessage();
if (modbusDevice->state() != QModbusDevice::ConnectedState)
{
auto type = static_cast<ModbusConnection>(ui->cbConnType->currentIndex());
if (type == Serial)
{
//设置串口连接信息
modbusDevice->setConnectionParameter(QModbusDevice::SerialPortNameParameter,
m_settingDialog->settings().serialName);
modbusDevice->setConnectionParameter(QModbusDevice::SerialParityParameter,
m_settingDialog->settings().parity);
modbusDevice->setConnectionParameter(QModbusDevice::SerialBaudRateParameter,
m_settingDialog->settings().baud);
modbusDevice->setConnectionParameter(QModbusDevice::SerialDataBitsParameter,
m_settingDialog->settings().dataBits);
modbusDevice->setConnectionParameter(QModbusDevice::SerialStopBitsParameter,
m_settingDialog->settings().stopBits);
}
else
{
//TCP连接信息
}
modbusDevice->setTimeout(m_settingDialog->settings().responseTime);
modbusDevice->setNumberOfRetries(m_settingDialog->settings().numberOfRetries);
if (!modbusDevice->connectDevice())
{
statusBar()->showMessage(tr("Connect failed..") + modbusDevice->errorString(), 5000);
}
else
{
statusBar()->showMessage(tr("Connect Successfully"), 5000);
qDebug() << "连接OK";
ui->actionConnect->setEnabled(false);
ui->actionDisconnect->setEnabled(true);
//使能读写操作
ui->btnRead->setEnabled(true);
ui->btnWrite->setEnabled(true);
ui->btnReadWrite->setEnabled(true);
}
}
else
{
//断开连接
modbusDevice->disconnectDevice();
ui->actionConnect->setEnabled(true);
ui->actionDisconnect->setDisabled(true);
qDebug() << "断开连接成功";
//禁用读写操作
ui->btnRead->setEnabled(false);
ui->btnWrite->setEnabled(false);
ui->btnReadWrite->setEnabled(false);
}
}
//连接类型槽函数 TCP Serial
void MainWindow::onConnectTypeChanged(int index)
{
//如果之前存在连接，则断开连接，然后释放内存
if(modbusDevice)
{
modbusDevice->disconnectDevice();
delete modbusDevice;
modbusDevice = nullptr;
}
auto type = static_cast<ModbusConnection>(index);
if (type == Serial)
{
modbusDevice = new QModbusRtuSerialMaster(this);
qDebug() << "new QModbusRtuSerialMaster Ok";
statusBar()->showMessage("new QModbusRtuSerialMaster Ok", 3000);
}
else if (type == Tcp)
{
}
else
{
statusBar()->showMessage("连接类型非法", 5000);
}
connect(modbusDevice, &QModbusClient::errorOccurred, [this](QModbusDevice::Error){
statusBar()->showMessage(modbusDevice->errorString(), 5000);
});
if (!modbusDevice)
{
//分配空间失败
ui->btnConnect->setDisabled(true);
if (type == Serial)
{
statusBar()->showMessage(tr("创建Modbus Master失败"), 5000);
}
else
{
statusBar()->showMessage(tr("创建Modbus Client失败"), 5000);
}
}
else
{
connect(modbusDevice, &QModbusClient::stateChanged,
this, &MainWindow::onModbusStateChanged);
}
}
//Modbus状态改变槽函数
void MainWindow::onModbusStateChanged(int state)
{
//判断Modbus设备连接是否处于连接状态
bool connected = (state != QModbusDevice::UnconnectedState);
ui->actionConnect->setEnabled(!connected);
ui->actionDisconnect->setEnabled(connected);
if (QModbusDevice::UnconnectedState == state)
{
ui->btnConnect->setText(tr("Connect"));
}
else
{
ui->btnConnect->setText(tr("Disconnect"));
}
}
//读操作槽函数
void MainWindow::onReadButtonClicked()
{
if (!modbusDevice)
{
return;
}
ui->textEditRead->clear();
statusBar()->clearMessage();
//发送请求报文数据
auto *reply = modbusDevice->sendReadRequest(readRequest(), ui->sbServerAddr->value());
if (reply)
{
if (!reply->isFinished())
{
//完毕之后 自动触发槽函数
connect(reply, &QModbusReply::finished, this, &MainWindow::onReadReady);
}
else
{
//广播消息 不需要返回响应
delete reply;
}
}
else
{
statusBar()->showMessage(tr("Read Error: ") + modbusDevice->errorString(), 5000);
}
}
//读取数据
void MainWindow::onReadReady()
{
auto reply = qobject_cast<QModbusReply*>(sender());
if (!reply)
{
return;
}
if (reply->error() == QModbusDevice::NoError)
{
const QModbusDataUnit data = reply->result();
for (int i = 0, total = (int)data.valueCount(); i < total; i++)
{
const QString str = tr("Address: %1 Value: %2").arg(data.startAddress() + i)
.arg(QString::number(data.value(i), data.registerType() <= QModbusDataUnit::Coils ? 10 : 16));
ui->textEditRead->append(str);
}
}
else if (reply->error() == QModbusDevice::ProtocolError)
{
statusBar()->showMessage(tr("Read response error: %1 (Modbus exception: 0x%2)").
arg(reply->errorString()).
arg(reply->rawResult().exceptionCode(), -1, 16), 5000);
}
else
{
statusBar()->showMessage(tr("Read response error: %1 (Code: 0x%2)").
arg(reply->errorString()).
arg(reply->error(), -1, 16), 5000);
}
//释放内存
reply->deleteLater();
}
void MainWindow::onWriteButtonClicked()
{
if (!modbusDevice)
{
return;
}
statusBar()->clearMessage();
QModbusDataUnit writeData = writeRequest();
QModbusDataUnit::RegisterType type = writeData.registerType();
//qDebug() << "test: " << writeData.valueCount();
for (int i = 0, total = (int)(writeData.valueCount()); i < total; i++)
{
if (type == QModbusDataUnit::Coils)
{
writeData.setValue(i, writeModel->m_coils[i + writeData.startAddress()]);
}
else
{
//qDebug() << "test: " << writeModel->m_holdingRegisters[i + writeData.startAddress()];
writeData.setValue(i, writeModel->m_holdingRegisters[i + writeData.startAddress()]);
}
}
qDebug() << "写数据内容为：" << writeData.values();
//发送请求报文数据
auto *reply = modbusDevice->sendWriteRequest(writeData, ui->sbServerAddr->value());
if (reply)
{
if (!reply->isFinished())
{
//完毕之后 自动触发槽函数
connect(reply, &QModbusReply::finished, this, [this, reply]{
if (reply->error() == QModbusDevice::ProtocolError)
{
statusBar()->showMessage(tr("Write Protocaol response error: %1").arg(reply->errorString()), 5000);
}
else if (reply->error() != QModbusDevice::NoError)
{
statusBar()->showMessage(tr("Write response error: %1").arg(reply->errorString()), 5000);
}
else
{
qDebug() << "写响应的数据: " << reply->result().values();
}
reply->deleteLater();
});
}
else
{
//广播消息 不需要返回响应
reply->deleteLater();
}
}
else
{
statusBar()->showMessage(tr("Write Error: ") + modbusDevice->errorString(), 5000);
}
}
//读写按钮槽函数
void MainWindow::onReadWriteButtonClicked()
{
if (!modbusDevice)
{
return;
}
statusBar()->clearMessage();
QModbusDataUnit writeData = writeRequest();
QModbusDataUnit::RegisterType type = writeData.registerType();
//qDebug() << "test: " << writeData.valueCount();
for (int i = 0, total = (int)(writeData.valueCount()); i < total; i++)
{
if (type == QModbusDataUnit::Coils)
{
writeData.setValue(i, writeModel->m_coils[i + writeData.startAddress()]);
}
else
{
//qDebug() << "test: " << writeModel->m_holdingRegisters[i + writeData.startAddress()];
writeData.setValue(i, writeModel->m_holdingRegisters[i + writeData.startAddress()]);
}
}
qDebug() << "写数据内容为：" << writeData.values();
//发送请求报文数据
auto *reply = modbusDevice->sendReadWriteRequest(readRequest(), writeData, ui->sbServerAddr->value());
if (reply)
{
if (!reply->isFinished())
{
connect(reply, &QModbusReply::finished, this, &MainWindow::onReadReady);
//完毕之后 自动触发槽函数
connect(reply, &QModbusReply::finished, this, [this, reply]{
if (reply->error() == QModbusDevice::ProtocolError)
{
statusBar()->showMessage(tr("Write Protocaol response error: %1").arg(reply->errorString()), 5000);
}
else if (reply->error() != QModbusDevice::NoError)
{
statusBar()->showMessage(tr("Write response error: %1").arg(reply->errorString()), 5000);
}
else
{
qDebug() << "写响应的数据: " << reply->result().values();
}
reply->deleteLater();
});
}
else
{
//广播消息 不需要返回响应
reply->deleteLater();
}
}
else
{
statusBar()->showMessage(tr("Write Error: ") + modbusDevice->errorString(), 5000);
}
}
void MainWindow::onWriteTableChanged(int index)
{
const bool coilsOrHolding = index == 0 || index == 3;
if (coilsOrHolding)
{
ui->treeViewWrite->setColumnHidden(1, index != 0);
ui->treeViewWrite->setColumnHidden(2, index != 3);
ui->treeViewWrite->resizeColumnToContents(0);
}
ui->btnReadWrite->setEnabled(index == 3);
ui->btnWrite->setEnabled(coilsOrHolding);
ui->groupBox_2->setEnabled(coilsOrHolding);
}
writeregistermodel.h文件
#ifndef WRITEREGISTERMODEL_H
#define WRITEREGISTERMODEL_H
#include <QAbstractItemModel>
#include <QBitArray>
#include <QObject>
class WriteRegisterModel : public QAbstractTableModel
{
Q_OBJECT
public:
WriteRegisterModel(QObject *parent = nullptr);
int rowCount(const QModelIndex &parent = QModelIndex()) const override;
int columnCount(const QModelIndex &parent = QModelIndex()) const override;
QVariant data(const QModelIndex &index, int role = Qt::DisplayRole) const override;
QVariant headerData(int section, Qt::Orientation orientation, int role) const override;
bool setData(const QModelIndex &index, const QVariant &value, int role) override;
Qt::ItemFlags flags(const QModelIndex &index) const override;
public slots:
void setStartAddress(int address);
void setNumberOfValues(const QString &number);
signals:
void updateViewport();
public:
int m_number = 0;
int m_address = 0;
QBitArray m_coils;
QVector<quint16> m_holdingRegisters;
};
#endif // WRITEREGISTERMODEL_H
writeregistermodel.cpp文件
#include "writeregistermodel.h"
enum {
NumColumn = 0, CoilsColumn = 1, HoldingColumn = 2, ColumnCount = 3, RowCount = 10 };
WriteRegisterModel::WriteRegisterModel(QObject *parent)
: QAbstractTableModel(parent),
m_coils(RowCount, false), m_holdingRegisters(RowCount, 0u)
{
}
int WriteRegisterModel::rowCount(const QModelIndex &/*parent*/) const
{
return RowCount;
}
int WriteRegisterModel::columnCount(const QModelIndex &/*parent*/) const
{
return ColumnCount;
}
QVariant WriteRegisterModel::data(const QModelIndex &index, int role) const
{
if (!index.isValid() || index.row() >= RowCount || index.column() >= ColumnCount)
return QVariant();
Q_ASSERT(m_coils.count() == RowCount);
Q_ASSERT(m_holdingRegisters.count() == RowCount);
if (index.column() == NumColumn && role == Qt::DisplayRole)
return QString::number(index.row());
if (index.column() == CoilsColumn && role == Qt::CheckStateRole) // coils
return m_coils.at(index.row()) ? Qt::Checked : Qt::Unchecked;
if (index.column() == HoldingColumn && role == Qt::DisplayRole) // holding registers
return QString("0x%1").arg(QString::number(m_holdingRegisters.at(index.row()), 16));
return QVariant();
}
QVariant WriteRegisterModel::headerData(int section, Qt::Orientation orientation, int role) const
{
if (role != Qt::DisplayRole)
return QVariant();
if (orientation == Qt::Horizontal) {
switch (section) {
case NumColumn:
return QStringLiteral("#");
case CoilsColumn:
return QStringLiteral("Coils ");
case HoldingColumn:
return QStringLiteral("Holding Registers");
default:
break;
}
}
return QVariant();
}
bool WriteRegisterModel::setData(const QModelIndex &index, const QVariant &value, int role)
{
if (!index.isValid() || index.row() >= RowCount || index.column() >= ColumnCount)
return false;
Q_ASSERT(m_coils.count() == RowCount);
Q_ASSERT(m_holdingRegisters.count() == RowCount);
if (index.column() == CoilsColumn && role == Qt::CheckStateRole) {
// coils
auto s = static_cast<Qt::CheckState>(value.toUInt());
s == Qt::Checked ? m_coils.setBit(index.row()) : m_coils.clearBit(index.row());
emit dataChanged(index, index);
return true;
}
if (index.column() == HoldingColumn && role == Qt::EditRole) {
// holding registers
bool result = false;
quint16 newValue = value.toString().toUShort(&result, 16);
if (result)
m_holdingRegisters[index.row()] = newValue;
emit dataChanged(index, index);
return result;
}
return false;
}
Qt::ItemFlags WriteRegisterModel::flags(const QModelIndex &index) const
{
if (!index.isValid() || index.row() >= RowCount || index.column() >= ColumnCount)
return QAbstractTableModel::flags(index);
Qt::ItemFlags flags = QAbstractTableModel::flags(index);
if ((index.row() < m_address) || (index.row() >= (m_address + m_number)))
flags &= ~Qt::ItemIsEnabled;
if (index.column() == CoilsColumn) // coils
return flags | Qt::ItemIsUserCheckable;
if (index.column() == HoldingColumn) // holding registers
return flags | Qt::ItemIsEditable;
return flags;
}
void WriteRegisterModel::setStartAddress(int address)
{
m_address = address;
emit updateViewport();
}
void WriteRegisterModel::setNumberOfValues(const QString &number)
{
m_number = number.toInt();
emit updateViewport();
}
6.1 RTUMaster写操作示例(一).rar
6.2 RTUMasterTest写操作(二).rar
7.1 Qt教程汇总
网址：https://dengjin.blog.csdn.net/article/details/115174639
文章浏览阅读2.1k次。原文链接先说说编解码问题编码转换时，通常需要以unicode作为中间编码，即先将其他编码的字符串解码（decode）成unicode，再从unicode编码（encode）成另一种编码。 Eg：str1.decode('gb2312') #将gb2312编码的字符串转换成unicode编码str2.encode('gb2312') #将unicode编码..._python中encode在什么模块
文章浏览阅读949次，点赞21次，收藏15次。本文介绍了Java中的数据输入流（DataInputStream）和数据输出流（DataOutputStream）的使用方法。
文章浏览阅读111次。ie无法兼容_ie 浏览器 newdate
文章浏览阅读239次。这篇文章把 Docker 和 K8s 的关系给大家做了一个解答，希望还在迟疑自己现有的知识储备能不能直接学 K8s 的，赶紧行动起来，K8s 是典型的入门有点难，后面越用越香。
文章浏览阅读561次。ADI中文手册获取方法_adi 如何查看数据手册
文章浏览阅读1k次，点赞4次，收藏3次。React 获取接口数据实现分页效果以拼多多接口为例实现思路加载前 加载动画加载后 判断有内容的时候 无内容的时候用到的知识点1、动画效果（用在加载前，加载之后就隐藏或关闭，用开关效果即可）2、axios请求3、map渲染页面4、分页插件（antd）代码实现import React, { Component } from 'react';//引入axiosimport axios from 'axios';//引入antd插件import { Pagination }_react 分页
文章浏览阅读449次，点赞9次，收藏7次。这个变量与验签过程中的SignatureVerificationFilter::PUT_MESSAGE这个宏是对应的，SignatureVerificationFilter::PUT_MESSAGE，如果在签名过程中putMessage设置为true，则在验签过程中需要添加SignatureVerificationFilter::PUT_MESSAGE。项目中使用到了CryPtopp库进行RSA签名与验签，但是在使用过程中反复提示无效的数字签名。否则就会出现文章开头出现的数字签名无效。_cryptopp 签名
文章浏览阅读848次。新闻稿是新闻从业者经常使用的一种文体，它的格式与内容都有着一定的规范。本文将从新闻稿的格式和范文两个方面进行介绍，以帮助读者更好地了解新闻稿的写作_新闻稿时间应该放在什么位置
文章浏览阅读1.7k次。Java中的转换器设计模式 在这篇文章中，我们将讨论 Java / J2EE项目中最常用的 Converter Design Pattern。由于Java8 功能不仅提供了相应类型之间的通用双向转换方式，而且还提供了转换相同类型对象集合的常用方法，从而将样板代码减少到绝对最小值。我们使用Java8 功能编写了..._java转换器模式
文章浏览阅读150次。1，kubectl run创建pods[root@master ~]# kubectl run nginx-deploy --image=nginx:1.14-alpine --port=80 --replicas=1[root@master ~]# kubectl get podsNAME READY STATUS REST...
文章浏览阅读128次。PAT菜鸡进化史_乙级_1003“答案正确”是自动判题系统给出的最令人欢喜的回复。本题属于 PAT 的“答案正确”大派送 —— 只要读入的字符串满足下列条件，系统就输出“答案正确”，否则输出“答案错误”。得到“答案正确”的条件是： 1. 字符串中必须仅有 P、 A、 T这三种字符，不可以包含其它字符； 2. 任意形如 xPATx 的字符串都可以获得“答案正确”，其中 x 或者是空字符串，或..._1003 pat乙级 最优
文章浏览阅读5.6k次。CH340与Android串口通信为何要将CH340的ATD+Eclipse上的安卓工程移植到AndroidStudio移植的具体步骤CH340串口通信驱动函数通信过程中重难点还存在的问题为何要将CH340的ATD+Eclipse上的安卓工程移植到AndroidStudio为了在这个工程基础上进行改动，验证串口的数据和配置串口的参数，我首先在Eclipse上配置了安卓开发环境，注意在配置环境是..._340串口小板 安卓给安卓发指令