基于 QT5 的 modbus rtu 主机通讯库

创建文件mcmodbusrtu.h

#ifndef MCMODBUSRTU_H
#define MCMODBUSRTU_H

#include <QObject>
#include <QSerialPort>
#include <QTimer>
// CRC16码表
#define UCHAR unsigned char
static const UCHAR aucCRCHi[] = {
    0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x01, 0xC0, 0x80, 0x41,
    0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40,
    0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x01, 0xC0, 0x80, 0x41,
    0x00, 0xC1, 0x81, 0x40, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41,
    0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x01, 0xC0, 0x80, 0x41,
    0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40,
    0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40,
    0x01, 0xC0, 0x80, 0x41, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40,
    0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x01, 0xC0, 0x80, 0x41,
    0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40,
    0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x01, 0xC0, 0x80, 0x41,
    0x00, 0xC1, 0x81, 0x40, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41,
    0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x01, 0xC0, 0x80, 0x41,
    0x00, 0xC1, 0x81, 0x40, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41,
    0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41,
    0x00, 0xC1, 0x81, 0x40, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41,
    0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x01, 0xC0, 0x80, 0x41,
    0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40,
    0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x01, 0xC0, 0x80, 0x41,
    0x00, 0xC1, 0x81, 0x40, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41,
    0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x01, 0xC0, 0x80, 0x41,
    0x00, 0xC1, 0x81, 0x40};

static const UCHAR aucCRCLo[] = {
    0x00, 0xC0, 0xC1, 0x01, 0xC3, 0x03, 0x02, 0xC2, 0xC6, 0x06, 0x07, 0xC7,
    0x05, 0xC5, 0xC4, 0x04, 0xCC, 0x0C, 0x0D, 0xCD, 0x0F, 0xCF, 0xCE, 0x0E,
    0x0A, 0xCA, 0xCB, 0x0B, 0xC9, 0x09, 0x08, 0xC8, 0xD8, 0x18, 0x19, 0xD9,
    0x1B, 0xDB, 0xDA, 0x1A, 0x1E, 0xDE, 0xDF, 0x1F, 0xDD, 0x1D, 0x1C, 0xDC,
    0x14, 0xD4, 0xD5, 0x15, 0xD7, 0x17, 0x16, 0xD6, 0xD2, 0x12, 0x13, 0xD3,
    0x11, 0xD1, 0xD0, 0x10, 0xF0, 0x30, 0x31, 0xF1, 0x33, 0xF3, 0xF2, 0x32,
    0x36, 0xF6, 0xF7, 0x37, 0xF5, 0x35, 0x34, 0xF4, 0x3C, 0xFC, 0xFD, 0x3D,
    0xFF, 0x3F, 0x3E, 0xFE, 0xFA, 0x3A, 0x3B, 0xFB, 0x39, 0xF9, 0xF8, 0x38,
    0x28, 0xE8, 0xE9, 0x29, 0xEB, 0x2B, 0x2A, 0xEA, 0xEE, 0x2E, 0x2F, 0xEF,
    0x2D, 0xED, 0xEC, 0x2C, 0xE4, 0x24, 0x25, 0xE5, 0x27, 0xE7, 0xE6, 0x26,
    0x22, 0xE2, 0xE3, 0x23, 0xE1, 0x21, 0x20, 0xE0, 0xA0, 0x60, 0x61, 0xA1,
    0x63, 0xA3, 0xA2, 0x62, 0x66, 0xA6, 0xA7, 0x67, 0xA5, 0x65, 0x64, 0xA4,
    0x6C, 0xAC, 0xAD, 0x6D, 0xAF, 0x6F, 0x6E, 0xAE, 0xAA, 0x6A, 0x6B, 0xAB,
    0x69, 0xA9, 0xA8, 0x68, 0x78, 0xB8, 0xB9, 0x79, 0xBB, 0x7B, 0x7A, 0xBA,
    0xBE, 0x7E, 0x7F, 0xBF, 0x7D, 0xBD, 0xBC, 0x7C, 0xB4, 0x74, 0x75, 0xB5,
    0x77, 0xB7, 0xB6, 0x76, 0x72, 0xB2, 0xB3, 0x73, 0xB1, 0x71, 0x70, 0xB0,
    0x50, 0x90, 0x91, 0x51, 0x93, 0x53, 0x52, 0x92, 0x96, 0x56, 0x57, 0x97,
    0x55, 0x95, 0x94, 0x54, 0x9C, 0x5C, 0x5D, 0x9D, 0x5F, 0x9F, 0x9E, 0x5E,
    0x5A, 0x9A, 0x9B, 0x5B, 0x99, 0x59, 0x58, 0x98, 0x88, 0x48, 0x49, 0x89,
    0x4B, 0x8B, 0x8A, 0x4A, 0x4E, 0x8E, 0x8F, 0x4F, 0x8D, 0x4D, 0x4C, 0x8C,
    0x44, 0x84, 0x85, 0x45, 0x87, 0x47, 0x46, 0x86, 0x82, 0x42, 0x43, 0x83,
    0x41, 0x81, 0x80, 0x40};

class McModbusRTU : public QObject
{
    Q_OBJECT
public:
    explicit McModbusRTU(QObject *parent = NULL);
    int LinkUart(QString Port);//连接串口
    void CloseUart();//关闭串口
    void Request03(unsigned char id, unsigned int address, unsigned short dLong);//批量读保持寄存器
    void Request04(unsigned char id, unsigned int address, unsigned short dLong);//批量读输入寄存器
    void Request06(unsigned char id, unsigned int address, unsigned short data);//单个写保持寄存器
    void Request16(unsigned char id, unsigned int address, int dLong, unsigned short *data);//批量写保持寄存器
private:
    void McMBCRC16(unsigned char *pDataIn, int iLenIn, unsigned int *pCRCOut);
signals:
    void McModbusRTUMessage(unsigned char mID,int mFunction,QByteArray Data);//消息返回函数，注意“高位对应内存地位”

public slots:
    void Read_Data();//串口数据读取函数
    void Tick_Server();//串口分时接收
private:
    bool serial_enable;
    QByteArray Read_Temp;
    int Read_TempLong;
    QTimer *Tick;

    QByteArray Datatemp;
public:
    QSerialPort* myserial;//串口句柄
};

#endif // MCMODBUSRTU_H

创建文件mcmodbusrtu.cpp

#include "mcmodbusrtu.h"
#include <QtSerialPort/QSerialPort>
#include <QtSerialPort/QSerialPortInfo>
#include "qdebug.h"
#include <QTimer>
/*
 * 20181206维护 接受部分CRC完善，数据操作位数完善
 * 备注：
 *      由于mb发送的是16位数字所以接受过来需要将其
 * 先转换为16位数字然后再转换成其他数据类型可以参考
 * 如下使用方法
 *      typedef union{
            int mint;
            float mfloat;
            unsigned short mshort[2];
            unsigned char mchar[4];
        }ShortToOther;
 *      ShortToOther ChangeTemp;
 *      ChangeTemp.mshort[0]=(Data[i*2+ii*4]<<8)|(Data[i*2+ii*4+1]&0xFF);
 *
*/
McModbusRTU::McModbusRTU(QObject *parent) : QObject(parent)
{
    Tick=new QTimer(this);
    connect(Tick, SIGNAL(timeout()), this, SLOT(Tick_Server()));
    serial_enable=0;//情况连接状态
    Read_TempLong=0;//接收数据长度备份
}
/*
 * 连接设备
 * Port设备端口号或者设备地址
 * 返回 大于5则连接成功，否则连接失败
*/
int McModbusRTU::LinkUart(QString Port){
    int Err=0;
    myserial = new QSerialPort;
    //设置串口名
    myserial->setPortName(Port);
    //打开串口
    Err += myserial->open(QIODevice::ReadWrite);
    //设置波特率
    Err += myserial->setBaudRate(QSerialPort::Baud115200);
    //设置数据位数
    Err += myserial->setDataBits(QSerialPort::Data8);
     //设置奇偶校验
    Err += myserial->setParity(QSerialPort::NoParity);
    //设置停止位
    Err += myserial->setStopBits(QSerialPort::OneStop);
    //设置流控制
    Err += myserial->setFlowControl(QSerialPort::NoFlowControl);
    //连接信号量
    connect(myserial, &QSerialPort::readyRead, this, &McModbusRTU::Read_Data);

    if(Err>5){
        Tick->start(5);
        serial_enable=1;//标记当前已连接
    }
    return Err;
}
//分时处理消息
void McModbusRTU::Tick_Server(){
    int i,LenTemp;
    unsigned int CRC16temp;
    unsigned short MBCRCreturn;
    if(Read_Temp.length()>0){
        if(Read_Temp.length()>Read_TempLong){
            Read_TempLong=Read_Temp.length();
        }else{
            //CRC校验
            LenTemp=Read_Temp.length();
            unsigned char Read_TempP[LenTemp];
            for(i=0;i<LenTemp;i++)Read_TempP[i]=Read_Temp[i];
            McMBCRC16(Read_TempP,LenTemp-2,&CRC16temp);
            MBCRCreturn=(Read_TempP[LenTemp-1]<<8)|((Read_TempP[LenTemp-2])&0xFF);
            if(CRC16temp!=MBCRCreturn){//CRC失败
                Read_TempLong=0;
                Read_Temp.clear();
                return;
            }
            //数据接收
            Datatemp.clear();
            for(i=3;i<Read_Temp.length()-2;i++)Datatemp.append(Read_Temp[i]);
            emit McModbusRTUMessage(Read_Temp[0],Read_Temp[1],Datatemp);
            Read_TempLong=0;
            Read_Temp.clear();
        }
    }
}
void McModbusRTU::Request06(unsigned char id, unsigned int address, unsigned short data){
    if(serial_enable==0)return;
    unsigned char SenData[8];
    unsigned int CrcTemp;
    int i;
    SenData[0]=id;
    SenData[1]=06;
    SenData[2]=address>>8;
    SenData[3]=address&0xFF;
    SenData[4]=data>>8;
    SenData[5]=data&0xFF;
    McMBCRC16(SenData,6,&CrcTemp);
    SenData[6]=CrcTemp&0xFF;
    SenData[7]=CrcTemp>>8;
    myserial->write((const char *)SenData,8);
}
void McModbusRTU::Request03(unsigned char id, unsigned int address, unsigned short dLong){
    if(serial_enable==0)return;
    unsigned char SenData[8];
    unsigned int CrcTemp;
    int i;
    SenData[0]=id;
    SenData[1]=03;
    SenData[2]=address>>8;
    SenData[3]=address&0xFF;
    SenData[4]=dLong>>8;
    SenData[5]=dLong&0xFF;
    McMBCRC16(SenData,6,&CrcTemp);
    SenData[6]=CrcTemp&0xFF;
    SenData[7]=CrcTemp>>8;
    myserial->write((const char *)SenData,8);
}
void McModbusRTU::Request16(unsigned char id, unsigned int address, int dLong, unsigned short *data){
    if(serial_enable==0)return;
    unsigned char SenData[9+dLong*2];
    unsigned int CrcTemp;
    int i;

    SenData[0]=id;
    SenData[1]=16;
    SenData[2]=address>>8;
    SenData[3]=address&0xFF;

    SenData[4]=dLong>>8;
    SenData[5]=dLong&0xFF;

    SenData[6]=dLong*2;

    for(i=0;i<dLong;i++){
        SenData[7+2*i]=data[i]>>8;
        SenData[8+2*i]=data[i]&0xFF;
    }

    McMBCRC16(SenData,7+dLong*2,&CrcTemp);
    SenData[7+dLong*2]=CrcTemp&0xFF;
    SenData[8+dLong*2]=CrcTemp>>8;
    myserial->write((const char *)SenData,9+dLong*2);
}
void McModbusRTU::Request04(unsigned char id, unsigned int address, unsigned short dLong){
    if(serial_enable==0)return;
    unsigned char SenData[8];
    unsigned int CrcTemp;
    int i;
    SenData[0]=id;
    SenData[1]=04;
    SenData[2]=address>>8;
    SenData[3]=address&0xFF;
    SenData[4]=dLong>>8;
    SenData[5]=dLong&0xFF;
    McMBCRC16(SenData,6,&CrcTemp);
    SenData[6]=CrcTemp&0xFF;
    SenData[7]=CrcTemp>>8;
    myserial->write((const char *)SenData,8);
}
//串口数据接收
void McModbusRTU::Read_Data(){
    Read_Temp.append(myserial->readAll());
    if(Read_Temp.length()>1000)Read_Temp.clear();
}
//关闭串口，释放资源
void McModbusRTU::CloseUart(){
    if(serial_enable){
        myserial->clear();
        myserial->close();
        myserial->deleteLater();
        Tick->stop();
    }
}
// CRC MODBUS 效验
// 输入参数: pDataIn: 数据地址
//           iLenIn: 数据长度
// 输出参数: pCRCOut: 2字节校验值
void McModbusRTU::McMBCRC16(unsigned char *pDataIn, int iLenIn, unsigned int *pCRCOut){
    UCHAR ucCRCHi = 0xFF;
    UCHAR ucCRCLo = 0xFF;
    int iIndex;
    while(iLenIn-- )
    {
        iIndex = ucCRCLo ^ *( pDataIn++ );
        ucCRCLo = ( UCHAR )( ucCRCHi ^ aucCRCHi[iIndex] );
        ucCRCHi = aucCRCLo[iIndex];
    }
    *pCRCOut = ( ucCRCHi << 8 | ucCRCLo );
}

使用

#ifndef MAINWINDOW_H
#define MAINWINDOW_H

#include <QMainWindow>
#include "mcmodbusrtu.h"
typedef union{
            int mint;
            float mfloat;
            unsigned short mshort[2];
            unsigned char mchar[4];
        }ShortToOther;
        
namespace Ui {
class MainWindow;
}

class MainWindow : public QMainWindow
{
    Q_OBJECT

public:
    explicit MainWindow(QWidget *parent = 0);
    ~MainWindow();

private slots:
    void on_pushButton_clicked();
    void McModbusRTUMessage(unsigned char mID,int mFunction,QByteArray Data);

private:
    Ui::MainWindow *ui;
    McModbusRTU *mmrtu;
};

#endif // MAINWINDOW_H

#include "mainwindow.h"
#include "ui_mainwindow.h"

MainWindow::MainWindow(QWidget *parent) :
    QMainWindow(parent),
    ui(new Ui::MainWindow)
{
    ui->setupUi(this);

    mmrtu=new McModbusRTU();
    connect(mmrtu,&McModbusRTU::McModbusRTUMessage,this,&MainWindow::McModbusRTUMessage);
}

MainWindow::~MainWindow()
{
    delete ui;
}
void MainWindow::closeEvent(QCloseEvent *ev){
    linkserver->LinkServerClose();
}

void MainWindow::McModbusRTUMessage(unsigned char mID, int mFunction, QByteArray Data){
    //若采集数据为普通数据时候
    //ShortToOther ChangeTemp;
    //ChangeTemp.mshort[0]=(Data[i*2+ii*4]<<8)|(Data[i*2+ii*4+1]&0xFF);
    //qDebug()<<"bbb" + QString::number(ChangeTemp.mshort[0]);
    //所采集数据是Float数据类型时候
     for(i=0;i<2;i++){
         ChangeTemp.mshort[i]=(Data[i*2]<<8)|(Data[i*2+1]&0xFF);
     }
     DataTemp[ii]=ChangeTemp.mfloat;
     qDebug()<<ChangeTemp.mfloat;
}
void MainWindow::on_pushButton_4_clicked()
{
    //
    if(mmrtu->LinkUart(ui->lineEdit_3->text())>5){
        ui->statusBar->showMessage("连接成功");
    }
}

void MainWindow::on_pushButton_5_clicked()
{
    unsigned short SenDate[7];
    SenDate[0]=5;
    SenDate[1]=6;
    SenDate[2]=7;
    mmrtu->Request16(1,62,3,SenDate);
    //mmrtu->Request06(1,60,1);
}

才写了几个简单的功能，日后逐步完善