大家好：
我在使用 QModbusTcpClient 用以太網 modbus tcp 讀資料時能正常。但發現不停增加記憶體使用。
只要有資料接收到就會幾K記憶體增加。半天不到程式使用記憶體120M＋ 了。啟動時是8M。
而我用QModbusRtuSerialMaster 用RS485 一切很正常，記憶體不會增加！
#ifndef CMODBUS_H
#define CMODBUS_H
#include <QModbusTcpClient>
#include <CSerialPortConfig.h>
#include <QModbusRtuSerialMaster>
class CModBus : public CSerialPortConfig
{
Q_OBJECT
public:
explicit CModBus(const QString &capstr);
~CModBus();
void portOpen();
void portClose();
bool portIsOpen();
void read(const QModbusDataUnit &mdu, const int &address);
void write(const QModbusDataUnit &mdu, const int &address);
signals:
void linkState(const int &address, const bool &st);
void dataReady(const int &address, const QModbusDataUnit &mdu);
private:
void readReady();
void writeFinished();
void newSetttings(const Settings &ns);
void errorOccurred(const QModbusDevice::Error &error);
int m_lastAddress = 0;
QModbusClient *m_device = nullptr;
};
#endif // CMODBUS_H
#include "CModBus.h"
CModBus::CModBus(const QString &capstr) : CSerialPortConfig(capstr)
{
newSetttings(curSettings());
connect(this, &CSerialPortConfig::sigNewSetttings, this, &CModBus::newSetttings);
connect(m_device, &QModbusClient::errorOccurred, this, &CModBus::errorOccurred);
m_device->connectDevice();
if(m_device->state() != QModbusDevice::ConnectedState)
{
errorAppend(capstr + " : " + portName() + tr(" : port error!"));
}
}
CModBus::~CModBus()
{
}
void CModBus::newSetttings(const Settings &ns)
{
bool isopen = false;
if(m_device != nullptr)
{
isopen = (m_device->state() == QModbusDevice::ConnectedState);
delete m_device;
m_device = nullptr;
}
if(ns.tcpEnable)
{
m_device = new QModbusTcpClient(this);
const QUrl url = QUrl::fromUserInput(ns.tcpHost);
m_device->setConnectionParameter(QModbusDevice::NetworkPortParameter, url.port());
m_device->setConnectionParameter(QModbusDevice::NetworkAddressParameter, url.host());
}
else
{
m_device = new QModbusRtuSerialMaster(this);
m_device->setConnectionParameter(QModbusDevice::SerialPortNameParameter, ns.portName);
m_device->setConnectionParameter(QModbusDevice::SerialParityParameter, ns.parity);
m_device->setConnectionParameter(QModbusDevice::SerialBaudRateParameter, ns.baud);
m_device->setConnectionParameter(QModbusDevice::SerialDataBitsParameter, ns.dataBits);
m_device->setConnectionParameter(QModbusDevice::SerialStopBitsParameter, ns.stopBits);
}
m_device->setTimeout(ns.responseTime);
m_device->setNumberOfRetries(ns.numberOfRetries);
if(isopen)
{
m_device->connectDevice();
}
}
void CModBus::read(const QModbusDataUnit &mdu, const int &address)
{
if((!m_device) || (m_device->state() != QModbusDevice::ConnectedState))
{
emit linkState(address, false);
return;
}
QModbusReply *reply = m_device->sendReadRequest(mdu, address);
if(reply)
{
m_lastAddress = address;
if(!reply->isFinished())
{
connect(reply, &QModbusReply::finished, this, &CModBus::readReady);
}
else
{
emit linkState(address, false);
delete reply;
}
}
else
{
emit linkState(address, false);
}
}
void CModBus::write(const QModbusDataUnit &mdu, const int &address)
{
if((!m_device) || (m_device->state() != QModbusDevice::ConnectedState))
{
emit linkState(address, false);
return;
}
QModbusReply *reply = m_device->sendWriteRequest(mdu, address);
if(reply)
{
m_lastAddress = address;
if(!reply->isFinished())
{
connect(reply, &QModbusReply::finished, this, &CModBus::writeFinished);
}
else
{
emit linkState(address, false);
delete reply;
}
}
else
{
emit linkState(address, false);
}
}
void CModBus::readReady()
{
QModbusReply *reply = qobject_cast<QModbusReply *>(sender());
if(!reply)
{
emit linkState(m_lastAddress, false);
return;
}
const int address = reply->serverAddress();
const QModbusDataUnit mdu = reply->result();
if(reply->error() == QModbusDevice::NoError)
{
emit dataReady(address, mdu);
emit linkState(address, true);
}
else
{
emit linkState(m_lastAddress, false);
}
reply->deleteLater();
}
void CModBus::writeFinished()
{
auto *reply = qobject_cast<QModbusReply *>(sender());
if(!reply)
{
emit linkState(m_lastAddress, false);
return;
}
if(reply->error() == QModbusDevice::NoError)
{
emit linkState(reply->serverAddress(), true);
}
else
{
emit linkState(m_lastAddress, false);
}
reply->deleteLater();
}
void CModBus::errorOccurred(const QModbusDevice::Error &error)
{
Q_UNUSED(error)
emit linkState(m_lastAddress, false);
}
void CModBus::portOpen()
{
m_device->connectDevice();
}
void CModBus::portClose()
{
m_device->disconnectDevice();
}
bool CModBus::portIsOpen()
{
return (m_device->state() == QModbusDevice::ConnectedState);
}
轉載請註明出處，本文鏈接：https://www.uj5u.com/yidong/277552.html
標籤：Qt
上一篇：wx.request函式呼叫的回呼函式中對于page頁的data呼叫問題？
下一篇：提交HTTP請求程式崩潰