在好例子网,分享、交流、成长!
您当前所在位置:首页C# 开发实例C#语言基础 → Modbus类库C#版本

Modbus类库C#版本

C#语言基础

下载此实例
  • 开发语言:C#
  • 实例大小:0.11M
  • 下载次数:27
  • 浏览次数:107
  • 发布时间:2021-10-15
  • 实例类别:C#语言基础
  • 发 布 人:260869504
  • 文件格式:.rar
  • 所需积分:3
 相关标签: Modbus MOD bus OD 版本

实例介绍

【实例简介】

      主要针对Modbus协议进行整理,形成类库方便大家使用

【实例截图】

from clipboard

from clipboard

【核心代码】

 /// <summary>
        /// Read coil registers
        /// </summary>
        /// <param name="unit_id">Slave device address</param>
        /// <param name="start_address">Address of first register to be read</param>
        /// <param name="len">Number of registers to be read</param>
        /// <returns>Array of readed registers</returns>
        public bool[] ReadCoils(byte unit_id, ushort start_address, ushort len)
        {
            if (len < 1)
            {
                error = Errors.ZERO_REGISTERS_REQUESTED;
                return null;
            }
            if (len > MAX_COILS_IN_READ_MSG)
            {
                error = Errors.TOO_MANY_REGISTERS_REQUESTED;
                return null;
            }
            ushort msg_len = 6;
            InitTCPUDPMasterMessage();
            send_buffer.Add((byte)ModbusCodes.READ_COILS);
            send_buffer.AddRange(GetBytes(start_address));
            send_buffer.AddRange(GetBytes(len));
            Query(unit_id, msg_len);
            if (error != Errors.NO_ERROR)
                return null;
            BitArray ba = new BitArray(receive_buffer.GetRange(2, receive_buffer.Count - 2).ToArray());
            bool[] ret = new bool[ba.Count];
            ba.CopyTo(ret, 0);
            return ret;
        }

        /// <summary>
        /// Read a set of discrete inputs
        /// </summary>
        /// <param name="unit_id">Slave device address</param>
        /// <param name="start_address">Address of first register to be read</param>
        /// <param name="len">Number of registers to be read</param>
        /// <returns>Array of readed registers</returns>
        public bool[] ReadDiscreteInputs(byte unit_id, ushort start_address, ushort len)
        {
            if (len < 1)
            {
                error = Errors.ZERO_REGISTERS_REQUESTED;
                return null;
            }
            if (len > MAX_DISCRETE_INPUTS_IN_READ_MSG)
            {
                error = Errors.TOO_MANY_REGISTERS_REQUESTED;
                return null;
            }
            ushort msg_len = 6;
            InitTCPUDPMasterMessage();
            send_buffer.Add((byte)ModbusCodes.READ_DISCRETE_INPUTS);
            send_buffer.AddRange(GetBytes(start_address));
            send_buffer.AddRange(GetBytes(len));
            Query(unit_id, msg_len);
            if (error != Errors.NO_ERROR)
                return null;
            BitArray ba = new BitArray(receive_buffer.GetRange(2, receive_buffer.Count - 2).ToArray());
            bool[] ret = new bool[ba.Count];
            ba.CopyTo(ret, 0);
            return ret;
        }

        /// <summary>
        /// Read a set of holding registers
        /// </summary>
        /// <param name="unit_id">Slave device address</param>
        /// <param name="start_address">Address of first register to be read</param>
        /// <param name="len">Number of registers to be read</param>
        /// <returns>Array of readed registers</returns>
        public ushort[] ReadHoldingRegisters(byte unit_id, ushort start_address, ushort len)
        {
            if (len < 1)
            {
                error = Errors.ZERO_REGISTERS_REQUESTED;
                return null;
            }
            if (len > MAX_HOLDING_REGISTERS_IN_READ_MSG)
            {
                error = Errors.TOO_MANY_REGISTERS_REQUESTED;
                return null;
            }
            ushort msg_len = 6;
            InitTCPUDPMasterMessage();
            send_buffer.Add((byte)ModbusCodes.READ_HOLDING_REGISTERS);
            send_buffer.AddRange(GetBytes(start_address));
            send_buffer.AddRange(GetBytes(len));
            Query(unit_id, msg_len);
            if (error != Errors.NO_ERROR)
                return null;
            List<ushort> ret = new List<ushort>();
            for (int ii = 0; ii < receive_buffer[1]; ii = 2)
                ret.Add(ToUInt16(receive_buffer.ToArray(), ii 2));
            return ret.ToArray();
        }

        /// <summary>
        /// Read a set of input registers
        /// </summary>
        /// <param name="unit_id">Slave device address</param>
        /// <param name="start_address">Address of first register to be read</param>
        /// <param name="len">Number of registers to be read</param>
        /// <returns>Array of readed registers</returns>
        public ushort[] ReadInputRegisters(byte unit_id, ushort start_address, ushort len)
        {
            if (len < 1)
            {
                error = Errors.ZERO_REGISTERS_REQUESTED;
                return null;
            }
            if (len > MAX_INPUT_REGISTERS_IN_READ_MSG)
            {
                error = Errors.TOO_MANY_REGISTERS_REQUESTED;
                return null;
            }
            ushort msg_len = 6;
            InitTCPUDPMasterMessage();
            send_buffer.Add((byte)ModbusCodes.READ_INPUT_REGISTERS);
            send_buffer.AddRange(GetBytes(start_address));
            send_buffer.AddRange(GetBytes(len));
            Query(unit_id, msg_len);
            if (error != Errors.NO_ERROR)
                return null;
            List<ushort> ret = new List<ushort>();
            for (int ii = 0; ii < receive_buffer[1]; ii = 2)
                ret.Add(ToUInt16(receive_buffer.ToArray(), ii 2));
            return ret.ToArray();
        }

        /// <summary>
        /// Write a coil register
        /// </summary>
        /// <param name="unit_id">Slave device address</param>
        /// <param name="address">Register address</param>
        /// <param name="value">Value to write</param>
        public void WriteSingleCoil(byte unit_id, ushort address, bool value)
        {
            ushort msg_len = 6;
            InitTCPUDPMasterMessage();
            send_buffer.Add((byte)ModbusCodes.WRITE_SINGLE_COIL);
            send_buffer.AddRange(GetBytes(address));
            send_buffer.AddRange(GetBytes((ushort)(value == true ? 0xFF00 : 0x0000)));
            Query(unit_id, msg_len);
            if (error == Errors.NO_ERROR)
            {
                ushort addr = ToUInt16(receive_buffer.ToArray(), 1);
                ushort regval = ToUInt16(receive_buffer.ToArray(), 3);
                if (addr != address)
                {
                    error = Errors.WRONG_RESPONSE_ADDRESS;
                    return;
                }
                if ((regval == 0xFF00) && !value)
                {
                    error = Errors.WRONG_RESPONSE_VALUE;
                    return;
                }
            }
        }

        /// <summary>
        /// Write an holding register
        /// </summary>
        /// <param name="unit_id">Slave device address</param>
        /// <param name="address">Register address</param>
        /// <param name="value">Value to write</param>
        public void WriteSingleRegister(byte unit_id, ushort address, ushort value)
        {
            ushort msg_len = 6;
            InitTCPUDPMasterMessage();
            send_buffer.Add((byte)ModbusCodes.WRITE_SINGLE_REGISTER);
            send_buffer.AddRange(GetBytes(address));
            send_buffer.AddRange(GetBytes(value));
            Query(unit_id, msg_len);
            if (error == Errors.NO_ERROR)
            {
                ushort addr = ToUInt16(receive_buffer.ToArray(), 1);
                if (addr != address)
                {
                    error = Errors.WRONG_RESPONSE_ADDRESS;
                    return;
                }
            }
        }

        /// <summary>
        /// Write a set of coil registers
        /// </summary>
        /// <param name="unit_id">Slave device address</param>
        /// <param name="start_address">Address of first register to be write</param>
        /// <param name="values">Array of values to write</param>
        public void WriteMultipleCoils(byte unit_id, ushort start_address, bool[] values)
        {
            if (values == null)
            {
                error = Errors.ZERO_REGISTERS_REQUESTED;
                return;
            }
            if (values.Length < 1)
            {
                error = Errors.ZERO_REGISTERS_REQUESTED;
                return;
            }
            if (values.Length > MAX_COILS_IN_WRITE_MSG)
            {
                error = Errors.TOO_MANY_REGISTERS_REQUESTED;
                return;
            }
            byte byte_cnt = (byte)((values.Length / 8) ((values.Length % 8) == 0 ? 0 : 1));
            ushort msg_len = (ushort)(1 6 byte_cnt);
            byte[] data = new byte[byte_cnt];
            BitArray ba = new BitArray(values);
            ba.CopyTo(data, 0);
            InitTCPUDPMasterMessage();
            send_buffer.Add((byte)ModbusCodes.WRITE_MULTIPLE_COILS);
            send_buffer.AddRange(GetBytes(start_address));
            send_buffer.AddRange(GetBytes((ushort)values.Length));
            send_buffer.Add(byte_cnt);
            send_buffer.AddRange(data);
            Query(unit_id, msg_len);
            if (error == Errors.NO_ERROR)
            {
                ushort sa = ToUInt16(receive_buffer.ToArray(), 1);
                ushort nr = ToUInt16(receive_buffer.ToArray(), 3);
                if (sa != start_address)
                {
                    error = Errors.WRONG_RESPONSE_ADDRESS;
                    return;
                }
                if (nr != values.Length)
                {
                    error = Errors.WRONG_RESPONSE_REGISTERS;
                    return;
                }
            }
        }

        /// <summary>
        /// Write a set of holding registers
        /// </summary>
        /// <param name="unit_id">Slave device address</param>
        /// <param name="start_address">Address of first register to be write</param>
        /// <param name="values">Array of values to write</param>
        public void WriteMultipleRegisters(byte unit_id, ushort start_address, ushort[] values)
        {
            if (values == null)
            {
                error = Errors.ZERO_REGISTERS_REQUESTED;
                return;
            }
            if (values.Length < 1)
            {
                error = Errors.ZERO_REGISTERS_REQUESTED;
                return;
            }
            if (values.Length > MAX_HOLDING_REGISTERS_IN_WRITE_MSG)
            {
                error = Errors.TOO_MANY_REGISTERS_REQUESTED;
                return;
            }
            ushort msg_len = (ushort)(7 (values.Length * 2));
            InitTCPUDPMasterMessage();
            send_buffer.Add((byte)ModbusCodes.WRITE_MULTIPLE_REGISTERS);
            send_buffer.AddRange(GetBytes(start_address));
            send_buffer.AddRange(GetBytes((ushort)values.Length));
            send_buffer.Add((byte)(values.Length * 2));
            for (int ii = 0; ii < values.Length; ii )
                send_buffer.AddRange(GetBytes(values[ii]));
            Query(unit_id, msg_len);
            if (error == Errors.NO_ERROR)
            {
                ushort sa = ToUInt16(receive_buffer.ToArray(), 1);
                ushort nr = ToUInt16(receive_buffer.ToArray(), 3);
                if (sa != start_address)
                {
                    error = Errors.WRONG_RESPONSE_ADDRESS;
                    return;
                }
                if (nr != values.Length)
                {
                    error = Errors.WRONG_RESPONSE_REGISTERS;
                    return;
                }
            }
        }



标签: Modbus MOD bus OD 版本

实例下载地址

Modbus类库C#版本

不能下载?内容有错? 点击这里报错 + 投诉 + 提问

好例子网口号:伸出你的我的手 — 分享

网友评论

发表评论

(您的评论需要经过审核才能显示)

查看所有0条评论>>

小贴士

感谢您为本站写下的评论,您的评论对其它用户来说具有重要的参考价值,所以请认真填写。

  • 类似“顶”、“沙发”之类没有营养的文字,对勤劳贡献的楼主来说是令人沮丧的反馈信息。
  • 相信您也不想看到一排文字/表情墙,所以请不要反馈意义不大的重复字符,也请尽量不要纯表情的回复。
  • 提问之前请再仔细看一遍楼主的说明,或许是您遗漏了。
  • 请勿到处挖坑绊人、招贴广告。既占空间让人厌烦,又没人会搭理,于人于己都无利。
;
报警