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
文章浏览阅读608次。uniapp 支付宝小程序拉起收银台 h5拉起收银台 授权 获取code _uniapp h5获取支付宝授权
文章浏览阅读463次。ehcache 使用说明_withevictionadvisor
文章浏览阅读2.1w次，点赞38次，收藏76次。在Windows环境配置多版本Java相信很多小伙伴在开发springboot后端或者玩minecraft的时候都会遇到上古Java的版本要求（比如Java8），但是如今最新的Java版本已经到Java16了，如何在电脑安装多个版本的Java并做到切换呢？下面来一起看看吧0、准备的准备多版本的Java需求一般是Java1.8+Java11之后版本的组合，本文就将以Java8和Java16两种版本的安装与配置为例。如果你的电脑之前没有安装过任何版本的Java，请直接跳到第2步如果你的电脑之前已经安_windows下可以按照 java 8+吗
文章浏览阅读9.3k次。北航GPA计算器北京航空航天大学的GPA计算方法为： 制度 计算公式 百分制 $4-3\times\frac{(100-X)^2}{1600}$ 五级制 优秀：4 良好：3.5 中等：2.8 及格：1.7 不及格：0 两级制 不计入GPA，但计入总学分 ..._北航gpa计算器
文章浏览阅读1.7w次，点赞8次，收藏15次。（苹果锤子三件套）需要的人多的话，我给大家发一个Thor抓{ T子会员}的教程！Thor三件套（抓包工具）●Thor俗称锤子是一款os平台的抓包调试Htp或Htts协议的工具，在众多抓包调试Htp或Htps协议的工具中功能方面相比较完善和稳定，用户可以通过Thor对绝大多数app进行一些项目的调试，或者抓取一些需要的图片、音频、压缩包、下载链接等，从而制作出来的便是Thor过器。●Anubis是一款网络开发调试和HTTP学习的工具，用来调试API或者学习理解HTTP协议，配合hor使用，可以进行日期._ios付费软件推荐
文章浏览阅读1.3k次，点赞49次，收藏28次。作为Python编程高手，你精通Python语言的各种特性和功能，对编程有着深入的理解和丰富的经验。你熟悉Python的常见应用领域，如数据分析、机器学习、Web开发等，并能根据需求选择合适的库和框架进行开发。作为一名Python编程高手，你的职责是通过编写高效、可靠的Python代码来解决实际问题，帮助他人理解和应用Python编程技术。无论是初学者还是有经验的开发者，你都能够提供专业的指导和建议，分享最佳实践，帮助他们在Python编程的道路上不断进步。那么他就可以准确度很高的还原已有的正确的编程。
文章浏览阅读883次。一.RabbitMQ的可靠性投递1.MQ实现异步通信过程中，消息丢失或重复，可能导致业务数据不一致如何解决？ ps:在解决问题之前，必须清楚可靠性只是问题的一方面，发送消息的效率同样是需要考虑的问题，而这两个因素无法兼得。如果在发送消息的每一个环节都采取相关措施来保证可靠性，势必会对消息的收发效率造成影响。会产生消息丢失的四个地方：1.从生产者到Broker,Broker未接收 可能原因：网络连接或者Broker的问题（硬盘故障、硬盘写满了）导致消息发送失败，但生产者..._rabbitmq consumer tag
文章浏览阅读962次，点赞2次，收藏11次。<!DOCTYPE html><html lang="en"><head> <meta charset="UTF-8"> <title> </title> <style type="text/css"> *{ margin: 0; padding: 0; } body{ margin: 0; } .div1{ border-style: none; disp..._html酒店预约界面及代码
文章浏览阅读1.3k次。unable to access ' ':Could not resolve host: github.com解决方案转载自：https://blog.csdn.net/weixin_42259631/article/details/82893426在终端输入：sudo vim /etc/resolv.conf在最后一行增加nameserver 8.8.8.8或者nameserver 114.114.114.114即可。..._git pull unable to access
文章浏览阅读176次。php数组转为url参数的实现方法：首先创建一个PHP示例文件；然后定义一个数组；最后通过“http_build_query( $array )”方法将数组转为URL参数即可。php 将数组转换网址URL参数$array =array ( 'id' =123, 'name' = 'dopost' );echo http_build_query( $array );//得到结果id=123name=..._php 数组转reqeust
文章浏览阅读4.3k次。nslookup是一个网络工具，通常用于查询域名系统（DNS）服务器以获取主机名或IP地址相关的信息。它可以用于查找主机名的IP地址，反向查找IP地址的主机名，以及查询DNS记录的其他信息。_nslookup命令的作用和使用方法
文章浏览阅读1.1k次。2019独角兽企业重金招聘Python工程师标准>>> ..._n n ___': - _* . &; v. 7_ 'v & .