C# modbus rtu master协议类源码

C# 上位机开发 modbus rtu master 通讯协议类源码
1、读取保持型寄存器 功能码0x03
2、预置单字保持型寄存器 功能码0x06
3、预置双字保持型寄存器 功能码0x10
4、读取输出线圈 功能码0x01
5、读取输入线圈 功能码0x02
6、强制单线圈 功能码0x05

using System;
using System.Collections.Generic;
using System.IO.Ports;
using System.Linq;
using System.Text;
using System.Threading;
using System.Threading.Tasks;

namespace IProgram
{
    public class Modbus
    {
        //定义串口类对象
        private SerialPort MyCom;
         //定义CRC校验高低位
        private byte ucCRCHi = 0xFF;
        private byte ucCRCLo = 0xFF;
        //定义接收字节数组
        byte[] bData = new byte[1024];
        //byte mReceiveByte;
        //int mReceiveByteCount = 0;
        //定义设备地址
        int CurrentAddr;
        int iMWordLen;
        int iMBitLen;
        //定义返回报文
        string strUpData = string.Empty;
        public Modbus(ComPort sp)
        {
           // MyCom = new SerialPort();
            MyCom = sp;
        }
      
        #region 打开关闭串口方法
        /// <summary>
        /// 打开串口方法【9600 N 8 1】
        /// </summary>
        /// <param name="iBaudRate">波特率</param>
        /// <param name="iPortNo">端口号</param>
        /// <param name="iDataBits">数据位</param>
        /// <param name="iParity">校验位</param>
        /// <param name="iStopBits">停止位</param>
        /// <returns></returns>
        public bool OpenMyComm(int iBaudRate, string iPortNo, int iDataBits, Parity iParity, StopBits iStopBits)
        {
            try
            {
                //关闭已打开串口
                MyCom.Close();
                if (MyCom.IsOpen)
                {
                   MyCom.Close();
                }
                //设置串口属性
                MyCom.BaudRate = iBaudRate;
                MyCom.PortName = iPortNo;
                MyCom.DataBits = iDataBits;
                MyCom.Parity = iParity;
                MyCom.StopBits = iStopBits;
                MyCom.ReceivedBytesThreshold = 1;
                MyCom.DataReceived += new SerialDataReceivedEventHandler(MyCom_DataReceived);

                MyCom.Open();
                return true;
            }
            catch
            {
                return false;
            }
        }

        /// <summary>
        /// 关闭串口方法
        /// </summary>
        /// <returns></returns>
        public void ClosePort()
        {
            
                MyCom.Close();      

        }
        #endregion

        #region  //所有输出口打开
        /// <summary>
        /// 所以输出口打开
        /// </summary>
        public void SetAllOn()
        {
            byte[] SendCommand = new byte[11] { 0x01,0x0F,0x00,0x00,0x00,0x10,0x02,0xFF,0xFF,0xE3,0x90 };
            MyCom.QueryBytes(SendCommand, 8, 2000);
        }
        #endregion
        #region //所有输出口关闭
        public void SetAllOff()
        {
            byte[] SendCommand = new byte[11] { 0x01, 0x0F, 0x00, 0x00, 0x00, 0x10, 0x02, 0x00, 0x00, 0xE2, 0x20 };
            MyCom.QueryBytes(SendCommand, 8, 2000);
        }
        #endregion
        #region //获取输入状态
        /// <summary>
        /// 获取输入信号状态
        /// </summary>
        /// <param name="X">输入口位</param>
        /// <returns></returns>
        public bool GetInput(int X)
        {
            int my_cmd = 0;
            byte[] Static = ReadInputStatus(0x01, 0x00, 0x08);
            my_cmd = 1 << (X);
            if ((Static[3] & my_cmd) == my_cmd)
            {
                Thread.Sleep(100);
                if ((Static[3] & my_cmd) == my_cmd)
                {
                    return true;
                }                  
            }
            return false;
        }
        #endregion

        public void DioOutput(int Y,int time)         
        {
            SetOut(Y, true);
            Thread.Sleep(time);
            SetOut(Y, false);
        }
        #region //指定端口输出
        /// <summary>
        /// 设置端口输出
        /// </summary>
        /// <param name="Y">输出端口位</param>
        /// <param name="En"></param>
        /// <returns></returns>
        public bool SetOut(int Y,bool En)
        {
           int my_cmd;
           if ( ForceCoil(0x01,Y,En))
            {
                Thread.Sleep(200);
                byte[] Static = ReadOutputStatus(0x01, 0, 10);
                if(En)
                {
                    my_cmd = 0;
                    my_cmd = 1 << (Y);
                    if ((Static[3] & my_cmd) == my_cmd)
                    {
                        return true;
                    }
                }
                else
                {
                    my_cmd = 0xFFFF;
                    my_cmd = 0 << (Y);
                    if ((Static[3] & my_cmd) == my_cmd)
                    {
                        return true;
                    }
                }               
            }
            return false;
        }
        #endregion
        //#region 串口接受数据事件
        ///// <summary>
        ///// 串口接受数据事件
        ///// </summary>
        ///// <param name="sender"></param>
        ///// <param name="e"></param>
        void MyCom_DataReceived(object sender, SerialDataReceivedEventArgs e)
        {
           while (MyCom.BytesToRead > 0)
            {
               mReceiveByte = (byte)MyCom.ReadByte();
               bData[mReceiveByteCount] = mReceiveByte;
                mReceiveByteCount += 1;
               if (mReceiveByteCount >= 1024)
                {
                   mReceiveByteCount = 0;
                   //清除输入缓存区
                    MyCom.DiscardInBuffer();
                    return;
               }
            }
   
        #region 读取保持型寄存器 功能码0x03
        /// <summary>
        /// 读取保持型寄存器 功能码0x03
        /// </summary>
        /// <param name="iDevAdd">从站地址</param>
        /// <param name="iAddress">起始地址</param>
        /// <param name="iLength">长度</param>
        /// <returns></returns>
        public byte[] ReadKeepReg(int iDevAdd, int iAddress, int iLength)
        {
            //byte[] ResByte = null;
            iMWordLen = iLength;
            CurrentAddr = iDevAdd;
            //第一步：拼接报文
            byte[] SendCommand = new byte[8];
            SendCommand[0] = (byte)iDevAdd;
            SendCommand[1] = 0x03;
            SendCommand[2] = (byte)((iAddress - iAddress % 256) / 256);
            SendCommand[3] = (byte)(iAddress % 256);
            SendCommand[4] = (byte)((iLength - iLength % 256) / 256);
            SendCommand[5] = (byte)(iLength % 256);
            Crc16(SendCommand, 6);
            SendCommand[6] = ucCRCLo;
            SendCommand[7] = ucCRCHi;

            //第二步：发送报文
            try
            {
                //MyCom.Write(SendCommand, 0, 8);
                return MyCom.QueryBytes(SendCommand, 8, 2000);
            }
            catch (Exception)
            {
                return null;
            }
            //第三步：解析报文
            //mReceiveByteCount = 0;
            //Thread.Sleep(300);

            //ResByte = HexStringToByteArray(this.strUpData, 3, 2);

            //return ResByte;

        }
        #endregion

        #region 预置单字保持型寄存器 功能码0x06
        /// <summary>
        /// 预置单字保持型寄存器  功能码0x06
        /// </summary>
        /// <param name="iDevAdd"></param>
        /// <param name="iAddress"></param>
        /// <param name="SetValue"></param>
        /// <returns></returns>
        public bool PreSetKeepReg(int iDevAdd, int iAddress, int SetValue)
        {
            byte[] ResByte;
            byte[] SendCommand = new byte[8];
            CurrentAddr = iDevAdd;
            //第一步：拼接报文
            SendCommand[0] = (byte)iDevAdd;
            SendCommand[1] = 0x06;
            SendCommand[2] = (byte)((iAddress - iAddress % 256) / 256);
            SendCommand[3] = (byte)(iAddress % 256);
            SendCommand[4] = (byte)((SetValue - SetValue % 256) / 256);
            SendCommand[5] = (byte)(SetValue % 256);
            Crc16(SendCommand, 6);
            SendCommand[6] = ucCRCLo;
            SendCommand[7] = ucCRCHi;
            try
            {
                //第二步：发送报文
                MyCom.Write(SendCommand, 0, 8);
            }
            catch (Exception)
            {
                return false;
            }
            //mReceiveByteCount = 0;
            Thread.Sleep(100);
            //第三步：解析报文
            ResByte = HexStringToByteArray(this.strUpData, 0, 0);
            return ByteArrayEquals(SendCommand, ResByte);
        }
        #endregion

        #region 预置双字保持型寄存器 功能码0x10
        /// <summary>
        /// 预置双字保持型寄存器 功能码0x10
        /// </summary>
        /// <param name="iDevAdd"></param>
        /// <param name="iAddress"></param>
        /// <param name="SetValue"></param>
        /// <returns></returns>
        public bool PreSetFloatKeepReg(int iDevAdd, int iAddress, float SetValue)
        {
            byte[] ResByte;
            byte[] SendCommand = new byte[13];
            CurrentAddr = iDevAdd;
            SendCommand[0] = (byte)iDevAdd;
            SendCommand[1] = 0x10;
            SendCommand[2] = (byte)((iAddress - iAddress % 256) / 256);
            SendCommand[3] = (byte)(iAddress % 256);
            SendCommand[4] = 0x00;
            SendCommand[5] = 0x02;
            SendCommand[6] = 0x04;
            byte[] bSetValue = BitConverter.GetBytes(SetValue);
            SendCommand[7] = bSetValue[3];
            SendCommand[8] = bSetValue[2];
            SendCommand[9] = bSetValue[1];
            SendCommand[10] = bSetValue[0];
            Crc16(SendCommand, 11);
            SendCommand[11] = ucCRCLo;
            SendCommand[12] = ucCRCHi;
            try
            {
                MyCom.Write(SendCommand, 0, 13);
            }
            catch (Exception)
            {
                return false;
            }
            //mReceiveByteCount = 0;
            Thread.Sleep(100);
            ResByte = HexStringToByteArray(this.strUpData, 0, 0);

            byte[] byteTemp = GetByteArray(ResByte, 0, 6);
            Crc16(byteTemp, 6);
            byte[] bytecrc = GetByteArray(ResByte, 6, 2);
            if (ByteArrayEquals(GetByteArray(SendCommand, 0, 6), byteTemp) && bytecrc[0] == ucCRCLo && bytecrc[1] == ucCRCHi)
            {
                return true;
            }
            else
            {
                return false;
            }

        }
        #endregion

        #region 读取输出线圈  功能码0x01
        /// <summary>
        /// 读取输出线圈  功能码0x01
        /// </summary>
        /// <param name="iDevAdd"></param>
        /// <param name="iAddress"></param>
        /// <param name="iLength"></param>
        /// <returns></returns>
        public byte[] ReadOutputStatus(int iDevAdd, int iAddress, int iLength)
        {
            byte[] SendCommand = new byte[8];
            CurrentAddr = iDevAdd;
            if (iLength % 8 == 0)
            {
                iMBitLen = iLength / 8;
            }
            else
            {
                iMBitLen = iLength / 8 + 1;
            }

            //第一步：拼接报文
            SendCommand[0] = (byte)iDevAdd;
            SendCommand[1] = 0x01;
            SendCommand[2] = (byte)((iAddress - iAddress % 256) / 256);
            SendCommand[3] = (byte)(iAddress % 256);
            SendCommand[4] = (byte)((iLength - iLength % 256) / 256);
            SendCommand[5] = (byte)(iLength % 256);
            Crc16(SendCommand, 6);
            SendCommand[6] = ucCRCLo;
            SendCommand[7] = ucCRCHi;
            try
            {
                //MyCom.Write(SendCommand, 0, 8);
                return MyCom.QueryBytes(SendCommand, 7, 2000);
            }
            catch (Exception)
            {
                return null;
            }
            //mReceiveByteCount = 0;
            //Thread.Sleep(100);
            //return HexStringToByteArray(this.strUpData, 3, 2);
        }
        #endregion

        #region 读取输入线圈  功能码0x02
        /// <summary>
        /// 读取输入线圈  功能码0x02
        /// </summary>
        /// <param name="iDevAdd"></param>
        /// <param name="iAddress"></param>
        /// <param name="iLength"></param>
        /// <returns></returns>
        public byte[] ReadInputStatus(int iDevAdd, int iAddress, int iLength)
        {
            byte[] SendCommand = new byte[8];
            CurrentAddr = iDevAdd;
            if (iLength % 8 == 0)
            {
                iMBitLen = iLength / 8;
            }
            else
            {
                iMBitLen = iLength / 8 + 1;
            }

            //第一步：拼接报文
            SendCommand[0] = (byte)iDevAdd;
            SendCommand[1] = 0x02;
            SendCommand[2] = (byte)((iAddress - iAddress % 256) / 256);
            SendCommand[3] = (byte)(iAddress % 256);
            SendCommand[4] = (byte)((iLength - iLength % 256) / 256);
            SendCommand[5] = (byte)(iLength % 256);
            Crc16(SendCommand, 6);
            SendCommand[6] = ucCRCLo;
            SendCommand[7] = ucCRCHi;
            try
            {
                //MyCom.Write(SendCommand, 0, 8);
                return MyCom.QueryBytes(SendCommand, 6, 2000);
            }
            catch (Exception)
            {
                return null;
            }
            //mReceiveByteCount = 0;
            //Thread.Sleep(100);
            //return HexStringToByteArray(this.strUpData, 3, 2);
            //return MyCom.QueryBytes(SendCommand, 8, 2000);
        }
        #endregion

        #region 强制单线圈  功能码0x05
        /// <summary>
        /// 强制单线圈  功能码0x05
        /// </summary>
        /// <param name="iDevAdd"></param>
        /// <param name="iAddress"></param>
        /// <param name="SetValue"></param>
        /// <returns></returns>
        public bool ForceCoil(int iDevAdd,int iAddress,bool SetValue)
        {
            //byte[] ResByte;
            byte[] SendCommand = new byte[8];
            CurrentAddr = iDevAdd;
            SendCommand[0] = (byte)iDevAdd;
            SendCommand[1] = 0x05;
            SendCommand[2] = (byte)((iAddress - iAddress % 256) / 256);
            SendCommand[3] = (byte)(iAddress % 256);
            if (SetValue)
            {
                SendCommand[4] = 0xFF;
            }
            else
            {
                SendCommand[4] = 0x00;
            }
            SendCommand[5] = 0x00;
            Crc16(SendCommand, 6);
            SendCommand[6] = ucCRCLo;
            SendCommand[7] = ucCRCHi;

            try
            {
                MyCom.Write(SendCommand, 0, 8);
            }
            catch (Exception)
            {
                return false;
            }
            //mReceiveByteCount = 0;
            Thread.Sleep(100);
            // ResByte = HexStringToByteArray(this.strUpData,0,0);  //接收的数组数据
            //  return ByteArrayEquals(SendCommand, ResByte);
            return true;
        }
        #endregion

        #region 自定义方法
        /// <summary>
        /// 报文转换字节数组（自定义截取）
        /// </summary>
        /// <param name="S"></param>
        /// <param name="start"></param>
        /// <param name="end"></param>
        /// <returns></returns>
        private byte[] HexStringToByteArray(string S, int start, int end)
        {
            byte[] Res = null;
            if (S != null && S.Length > start + end)
            {
                string[] str = S.Trim().Split(' ');
                string[] Result = new string[str.Length - start - end];
                for (int i = 0; i < Result.Length; i++)
                {
                    Result[i] = str[i + start];
                }
                Res = new byte[Result.Length];
                for (int i = 0; i < Result.Length; i++)
                {
                    Res[i] = Convert.ToByte(Result[i], 16);
                }
            }
            return Res;
        }

        /// <summary>
        /// 判断两个字节数组是否完全一致
        /// </summary>
        /// <param name="b1"></param>
        /// <param name="b2"></param>
        /// <returns></returns>
        private bool ByteArrayEquals(byte[] b1, byte[] b2)
        {
            if (b1.Length != b2.Length) return false;
            if (b1 == null || b2 == null) return false;
            for (int i = 0; i < b1.Length; i++)
                if (b1[i] != b2[i])
                    return false;
            return true;
        }

        /// <summary>
        /// 自定义截取字节数组
        /// </summary>
        /// <param name="byteArr"></param>
        /// <param name="start"></param>
        /// <param name="length"></param>
        /// <returns></returns>
        private byte[] GetByteArray(byte[] byteArr, int start, int length)
        {
            byte[] Res = new byte[length];
            if (byteArr != null && byteArr.Length > length)
            {
                for (int i = 0; i < length; i++)
                {
                    Res[i] = byteArr[i + start];
                }

            }
            return Res;
        }
        #endregion

        #region  CRC校验
        private static readonly byte[] 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
         };
        private static readonly byte[] 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
         };
        private void Crc16(byte[] pucFrame, int usLen)
        {
            int i = 0;
            ucCRCHi = 0xFF;
            ucCRCLo = 0xFF;
            UInt16 iIndex = 0x0000;

            while (usLen-- > 0)
            {
                iIndex = (UInt16)(ucCRCLo ^ pucFrame[i++]);
                ucCRCLo = (byte)(ucCRCHi ^ aucCRCHi[iIndex]);
                ucCRCHi = aucCRCLo[iIndex];
            }

        }

        #endregion

    }
}

版权声明：本文内容来源于网络搜集无法获知原创作者，仅供个人学习用途，若侵犯到您的权益请联系我们及时删除。邮箱：1370723259@qq.com