当前位置:网站首页>Utiliser nmodbus4 pour lire les données à la fois RTU et TCP

Utiliser nmodbus4 pour lire les données à la fois RTU et TCP

2022-01-15 02:11:41 La lave de Rodinia

ÉtablissementModbusTCPBibliothèque de communications

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using Modbus.Device;
using System.Net.Sockets;
using thinger.cn.DataConvertHelper;
using System.Net;

namespace NModbusHelper
{
    
    public class NmodbusTCPhelper
    {
    
        private TcpClient tcpClient = null;
        private ModbusIpMaster master;
        //private Socket tcpClient = null; //Définir un objet de classe de port série
        #region Ouverture et fermetureSocket 
        public bool Connect(string ip, int port)
        {
    
            //tcpclient = new Socket(AddressFamily.InterNetwork,SocketType.Stream,ProtocolType.Tcp);
            try
            {
    
                tcpClient = new TcpClient();
                tcpClient.Connect(IPAddress.Parse(ip), port);
                //IPEndPoint ie = new IPEndPoint(IPAddress.Parse(ip), port);
                //tcpClient.Connect(ie);
                master = ModbusIpMaster.CreateIp(tcpClient);
            }
            catch (Exception)
            {
    
                return false;
            }
            return true;
        }

        public bool Disconnect()
        {
    
            if (tcpClient != null)
            {
    
                tcpClient.Close();
                return true;
            }
            else
            {
    
                return false;
            }
        }
        #endregion

        public ushort[] ReadKeepReg(string iAddress, int iLength)//Offset,Nombre de registres
        {
    
            try
            {
    
                ushort[] des = master.ReadHoldingRegisters(Convert.ToUInt16(iAddress), Convert.ToUInt16(iLength));
                byte[] res = ByteArrayLib.GetByteArrayFromUShortArray(des);
                return des;
            }
            catch (Exception)
            {
    
                return null;
            }
        }

        public List<float> AnalyseData_4x(ushort[] des, string iAddress)
        {
    
            int StartByte;
            StartByte = int.Parse(iAddress) * 2;
            List<float> floatArray = new List<float>();
            byte[] byteArray = ByteArrayLib.GetByteArrayFromUShortArray(des);

            for (int i = StartByte; i < byteArray.Length; i += 4)
            {
    
                floatArray.Add(FloatLib.GetFloatFromByteArray(byteArray, i));
            }
            return floatArray;
        }
    }
}

UtiliserModbusTCP Lire

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Windows.Forms;
using System.Net.Sockets;
using System.Net;
using Modbus.Device;
using thinger.cn.DataConvertHelper;
using NModbusHelper;

namespace NmodbusPractice2
{
    
    public partial class FrmMain : Form
    {
    
        public FrmMain()
        {
    
            InitializeComponent();
        }
        string ip = "127.0.0.1";
        int port = 502;

        NmodbusTCPhelper objTcp = new NmodbusTCPhelper();
        private bool IsConnected = false;
        private System.Windows.Forms.Timer updateTimer = new System.Windows.Forms.Timer();
        ushort[] res;
        List<float> floatArray;
        private void Addinfo(string info)
        {
    
            this.isInfo.Items.Insert(
                0, DateTime.Now.ToString("HH:mm:ss") + " " + info + Environment.NewLine);
        }
        private void btnConnect_Click(object sender, EventArgs e)
        {
    
            IsConnected = objTcp.Connect(ip, port);
            Addinfo(IsConnected ? "Connexion réussie" : "La connexion a échoué");
        }

        private void btnRead_Click(object sender, EventArgs e)
        {
    
            this.updateTimer.Interval = 1000;
            this.updateTimer.Tick += UpdateTimer_Tick;
            this.updateTimer.Start();
            if (res != null)
            {
    
                Addinfo("Lecture réussie");
            }
        }

        private void UpdateTimer_Tick(object sender, EventArgs e)
        {
    
            string iAddress = this.txtVarAdd.Text;
            int iLength = Convert.ToUInt16(this.numCount.Text);

            res = objTcp.ReadKeepReg(iAddress, iLength);

            //Uint
            //this.isInfo.Items.Add(res.ToString());
            //for (int i = 0; i < res.Length; i++)
            //{
    
            // this.isInfo.Items.Add(res[i].ToString());
            //}

            //float

            floatArray = objTcp.AnalyseData_4x(res,iAddress);
            for (int i = 0; i < floatArray.ToArray().Length; i++)
            {
    
                this.isInfo.Items.Add(floatArray.ToArray()[i].ToString());
            }

        }

        private void btnDisconnect_Click(object sender, EventArgs e)
        {
    
            objTcp.Disconnect();
            Addinfo("Déconnecter");
        }

        private void ChangeRTU_Click(object sender, EventArgs e)
        {
    
            FrmRTU frmRTU = new FrmRTU();
            frmRTU.Show();
        }
    }
 
}

ÉtablissementModbusRTU Objet et bibliothèque de communication pour

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

namespace NModbusHelper
{
    
    public class ModbusRTUEntity
    {
    
        public string Port {
     get; set; }

        //Taux de Baud
        public int Paud {
     get; set; }

        //Bits de données
        public int DataBit {
     get; set; }

        //Bit de contrôle
        public Parity IParity {
     get; set; }

        //Stop bit
        public StopBits IStopBit {
     get; set; }
    }
}

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using thinger.cn.DataConvertHelper;
using System.IO.Ports;
using Modbus.Device;
using System.Threading;

namespace NModbusHelper
{
    
    public class NmodbusRTUhelper
    {
    
        private SerialPort MyCom = new SerialPort();
        IModbusSerialMaster master;
        //DéfinitionCRC Vérifier Haut bas 
        private byte ucCRCHi = 0xFF;
        private byte ucCRCLo = 0xFF;

        public bool OpenMyComm(int iBaudRate, string iPortNo, int iDataBits, Parity iParity, StopBits iStopBits)
        {
    
            try
            {
    
                if (MyCom.IsOpen)
                {
    
                    MyCom.Close();
                }
                //MyCom.BaudRate = iBaudRate;
                //MyCom.PortName = iPortNo;
                //MyCom.DataBits = iDataBits;
                //MyCom.Parity = iParity;
                //MyCom.StopBits = iStopBits;
                MyCom.BaudRate = iBaudRate;
                MyCom.PortName = iPortNo;
                MyCom.DataBits = iDataBits;
                MyCom.Parity = iParity;
                MyCom.StopBits = iStopBits;

                MyCom.Open();

                return true;
            }
            catch (Exception)
            {
    
                return false;
            }
        }

        public bool ClosePort()
        {
    
            if (MyCom.IsOpen)
            {
    
                MyCom.Close();
                return true;
            }
            else
            {
    
                return false;
            }
        }
        /// <summary>
        /// 
        /// </summary>
        /// <param name="iDevAdd">Adresse de la station esclave</param>
        /// <param name="iAddress">Offset</param>
        /// <param name="iLength">Nombre de registres</param>
        /// <returns></returns>
        public ushort[] ReadKeepReg(int iDevAdd, int iAddress, int iLength)
        {
    
            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);
            }
            catch (Exception)
            {
    

                return null;
            }
            MyCom.ReadTimeout = 500;
            Thread.Sleep(500);
            if (MyCom.BytesToRead>0)
            {
    
                master = ModbusSerialMaster.CreateRtu(MyCom);
            }
            //Convert.ToByte(iDevAdd), (ushort)iAddress, (ushort)iLength
            ushort[] des = master.ReadHoldingRegisters(Convert.ToByte(iDevAdd), (ushort)iAddress, (ushort)iLength);
            //byte[] res = ByteArrayLib.GetByteArrayFromUShortArray(des);
            return des;
        }

        public List<float> AnalyseData_4x(ushort[] des, string iAddress)
        {
    
            int StartByte;
            StartByte = int.Parse(iAddress) * 2;
            List<float> floatArray = new List<float>();
            byte[] byteArray = ByteArrayLib.GetByteArrayFromUShortArray(des);

            for (int i = StartByte; i < byteArray.Length; i += 4)
            {
    
                floatArray.Add(FloatLib.GetFloatFromByteArray(byteArray, i));
            }
            return floatArray;
        }

        #region CRCVérification
        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
    }
}

Lire

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Windows.Forms;
using Modbus.Device;
using thinger.cn.DataConvertHelper;
using NModbusHelper;
using System.IO.Ports;
using System.Threading;

namespace NmodbusPractice2
{
    
    public partial class FrmRTU : Form
    {
    
        public FrmRTU()
        {
    
            InitializeComponent();
            this.RTUPort.Text = "COM3";
            this.RTUPaud.Text = "9600";
            this.RTUIParity.Text = "None";
            this.RTUDataBit.Text = "8";
            this.RTUIStopBit.Text = "1";
            this.RTUiDevAdd.Text = "1";
            this.RTUiAddress.Text = "0";
            this.RTUiLength.Text = "20";
        }

        ModbusRTUEntity rTUEntity = new ModbusRTUEntity();
        NmodbusRTUhelper rTUhelper = new NmodbusRTUhelper();
        private System.Windows.Forms.Timer upDateTimer = new System.Windows.Forms.Timer();

        CancellationTokenSource cts = new CancellationTokenSource();
        private bool IsConnected = false;
        ushort[] res;
        

        private void Addinfo(string info)
        {
    
            this.isInfo.Items.Insert(
                0, DateTime.Now.ToString("HH:mm:ss") + " " + info + Environment.NewLine);
        }

        private void btnConnect_Click(object sender, EventArgs e)
        {
    
            rTUEntity.Port = this.RTUPort.Text.Trim();
            rTUEntity.Paud = Convert.ToInt32(this.RTUPaud.Text.Trim());
            rTUEntity.DataBit = Convert.ToInt32(this.RTUDataBit.Text.Trim());
            switch (this.RTUIStopBit.Text.Trim())
            {
    
                case "1":
                    rTUEntity.IStopBit = StopBits.One;
                    break;
                case "2":
                    rTUEntity.IStopBit = StopBits.Two;
                    break;
                default:
                    rTUEntity.IStopBit = StopBits.One;
                    break;
            }

            switch (this.RTUIParity.Text.Trim())// Informations sur la validation 
            {
    
                case "None":
                    rTUEntity.IParity = Parity.None;
                    break;
                case "Even":
                    rTUEntity.IParity = Parity.Even;
                    break;
                case "Odd":
                    rTUEntity.IParity = Parity.Odd;
                    break;
                default:
                    rTUEntity.IParity = Parity.None;
                    break;
            }

            IsConnected = rTUhelper.OpenMyComm(rTUEntity.Paud, rTUEntity.Port, rTUEntity.DataBit, rTUEntity.IParity, rTUEntity.IStopBit);
            Addinfo(IsConnected ? "Connexion réussie" : "La connexion a échoué");
        }

        private void btnRead_Click(object sender, EventArgs e)
        {
    
            this.upDateTimer.Interval = 1000;
            this.upDateTimer.Tick += UpDateTimer_Tick;
            this.upDateTimer.Start();
        }

        private void UpDateTimer_Tick(object sender, EventArgs e)
        {
    
            string RTUiDevAdd = this.RTUiDevAdd.Text.Trim();
            string RTUiAddress = this.RTUiAddress.Text.Trim();
            string RTUiLength = this.RTUiLength.Text.Trim();
            res = rTUhelper.ReadKeepReg(int.Parse(RTUiDevAdd), int.Parse(RTUiAddress), int.Parse(RTUiLength));
            for (int i = 0; i < res.Length; i++)
            {
    
                this.isInfo.Items.Add(res[i].ToString());
            }
        }

        private void btnDisconnect_Click(object sender, EventArgs e)
        {
    
            IsConnected = rTUhelper.ClosePort();
            Addinfo(IsConnected ? "La déconnexion a échoué" : "Déconnexion réussie");
        }

        private void btnTaskRead_Click(object sender, EventArgs e)
        {
    
            string RTUiDevAdd = this.RTUiDevAdd.Text.Trim();
            string RTUiAddress = this.RTUiAddress.Text.Trim();
            string RTUiLength = this.RTUiLength.Text.Trim();
            Task.Run(() =>
            {
    
                while (true)
                {
    
                    res = rTUhelper.ReadKeepReg(int.Parse(RTUiDevAdd), int.Parse(RTUiAddress), int.Parse(RTUiLength));
                    for (int i = 0; i < res.Length; i++)
                    {
    
                        this.isInfo.Invoke(new Action<ushort>(t =>
                        {
    
                            this.isInfo.Items.Add(t.ToString());
                        }), res[i]);
                    }
                }

            }, cts.Token);
        }
    }
}

版权声明
本文为[La lave de Rodinia]所创,转载请带上原文链接,感谢
https://chowdera.com/2022/01/202201080558306907.html

随机推荐