Qt_TCP_Modbus例程

#include "ModbusTcpClient.h" #include "ui_ModbusTcpClient.h" #include <QModbusRtuSerialMaster> #include <QSerialPort> #include <QModbusDataUnit> #include <QDebug> #include <QUrl> #include <QModbusTcpClient> ModbusTcpClient::ModbusTcpClient(QWidget *parent) : QMainWindow(parent), ui(new Ui::ModbusTcpClient),m_holdingRegisters(20) { ui->setupUi(this); if (modbusDevice) { modbusDevice->disconnectDevice(); delete modbusDevice; modbusDevice = nullptr; } modbusDevice = new QModbusTcpClient(this);//QModbusTcpClient用于TCP通信中的client if (ui->lineEdit->text().isEmpty()) ui->lineEdit->setText(QLatin1Literal("127.0.0.1:502")); connect(modbusDevice, &QModbusClient::errorOccurred, [this](QModbusDevice::Error) { statusBar()->showMessage(modbusDevice->errorString(), 5000); }); connect(modbusDevice, &QModbusClient::stateChanged, this, &ModbusTcpClient::onStateChanged);//连接状态发生改变时改变connect按钮上的显示文字（connect or discennect） // QByteArray text = QByteArray::fromHex("517420697320677265617421"); // text.data(); // returns "Qt is great!" // qDebug()<<text.data(); } ModbusTcpClient::~ModbusTcpClient() { if (modbusDevice) modbusDevice->disconnectDevice(); delete modbusDevice; delete ui; } void ModbusTcpClient::on_sendButton_clicked() { if (!modbusDevice)//如果设备没有被创建就返回 return; QString strDis; QString str1 = ui->textEdit->toPlainText(); qDebug()<<str1; QByteArray str2 = QByteArray::fromHex (str1.toLatin1().data());//按十六进制编码接入文本 //qDebug()<<str2; QString str3 = str2.toHex().data();//以十六进制显示 statusBar()->clearMessage();//清除状态栏显示的信息 QModbusDataUnit writeUnit(QModbusDataUnit::HoldingRegisters,0,10);//发送的数据信息（数据类型 ，起始地址，个数） // QModbusDataUnit::RegisterType table = writeUnit.registerType();//得到寄存器类型传给table for (uint i = 0; i < writeUnit.valueCount(); i++) { int j = 2*i; QString st = str3.mid (j,2); bool ok; int hex =st.toInt(&ok,16); qDebug()<<hex; writeUnit.setValue(i,hex);//设置发送数据为123456789 } // auto *reply = modbusDevice->sendWriteRequest(writeUnit, 1);//发送数据 1是server address if (auto *reply = modbusDevice->sendWriteRequest(writeUnit, 1)) { if (!reply->isFinished()) { //reply Returns true when the reply has finished or was aborted. connect(reply, &QModbusReply::finished, this, [this, reply]() { if (reply->error() == QModbusDevice::ProtocolError) { statusBar()->showMessage(tr("Write response error: %1 (Mobus exception: 0x%2)") .arg(reply->errorString()).arg(reply->rawResult().exceptionCode(), -1, 16), 5000); } else if (reply->error() != QModbusDevice::NoError) { statusBar()->showMessage(tr("Write response error: %1 (code: 0x%2)"). arg(reply->errorString()).arg(reply->error(), -1, 16), 5000); } reply->deleteLater(); }); } else { // broadcast replies return immediately reply->deleteLater(); } } else { statusBar()->showMessage(tr("Write error: ") + modbusDevice->errorString(), 5000); } } void ModbusTcpClient::on_connectButton_clicked() { if (!modbusDevice) return; statusBar()->clearMessage(); if (modbusDevice->state() != QModbusDevice::ConnectedState) {//如果处在非连接状态，进行连接 const QUrl url = QUrl::fromUserInput(ui->lineEdit->text());//获取IP和端口号 modbusDevice->setConnectionParameter(QModbusDevice::NetworkPortParameter, url.port()); modbusDevice->setConnectionParameter(QModbusDevice::NetworkAddressParameter, url.host()); modbusDevice->setTimeout(1000);//连接超时1S modbusDevice->setNumberOfRetries(3);//连接失败重试三次连接 if (!modbusDevice->connectDevice()) { statusBar()->showMessage(tr("Connect failed: ") + modbusDevice->errorString(), 5000); } }else{//处在连接状态进行断开连接的操作 modbusDevice->disconnectDevice(); } } void ModbusTcpClient::onStateChanged(int state)//更新connect按钮的显示状态 { if (state == QModbusDevice::UnconnectedState) ui->connectButton->setText(tr("Connect")); else if (state == QModbusDevice::ConnectedState) ui->connectButton->setText(tr("Disconnect")); } void ModbusTcpClient::on_readButton_clicked() { if (!modbusDevice) return; statusBar()->clearMessage(); QModbusDataUnit readUnit(QModbusDataUnit::HoldingRegisters,0,10); if (auto *reply = modbusDevice->sendReadRequest(readUnit, 1)) { if (!reply->isFinished()) connect(reply, &QModbusReply::finished, this, &ModbusTcpClient::readReady); else delete reply; // broadcast replies return immediately } else { statusBar()->showMessage(tr("Read error: ") + modbusDevice->errorString(), 5000); } } void ModbusTcpClient::readReady()//在这里读的数据 { auto reply = qobject_cast<QModbusReply *>(sender());//QModbusReply这个类存储了来自client的数据,sender()返回发送信号的对象的指针 if (!reply) return; //数据从QModbusReply这个类的resuil方法中获取,也就是本程序中的reply->result() if (reply->error() == QModbusDevice::NoError) { const QModbusDataUnit unit = reply->result(); for (uint i = 0; i < unit.valueCount(); i++) { const QString entry = tr("Address: %1, Value: %2").arg(unit.startAddress()) .arg(QString::number(unit.value(i), unit.registerType() <= QModbusDataUnit::Coils ? 10 : 16)); // ui->readValue->addItem(entry);//把数据放在QListWidget中 ui->textEdit_2->append(entry); } } else if (reply->error() == QModbusDevice::ProtocolError) { statusBar()->showMessage(tr("Read response error: %1 (Mobus 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(); }