一、创建一个Moudbus类,引入NModbus和Modbus这两个包
#region ModbusTCPpublic class NmodbusTcpHelper{// 静态成员变量,用于存储TcpClient实例private static TcpClient tcpClient = null;// 静态成员变量,用于存储ModbusIpMaster实例private static ModbusIpMaster master;// 连接到指定的IP和端口public static void Connect(string ip, int port, int MaxConnectTime){try{// 创建一个新的TcpClient实例tcpClient = new TcpClient();// 尝试异步连接到指定的IP和端口,最多等待3000毫秒if (!tcpClient.ConnectAsync(ip, port).Wait(3000)){// 如果连接失败,则抛出一个异常throw new Exception(string.Format("客户端连接在{0}:{1}失败", ip, port));}else{// 连接成功,创建ModbusIpMaster实例master = ModbusIpMaster.CreateIp(tcpClient);// 设置Modbus通信的读取超时时间为2000毫秒master.Transport.ReadTimeout = 2000;// 设置Modbus通信的写入超时时间为2000毫秒master.Transport.WriteTimeout = 2000;// 设置Modbus通信的重试次数为3次master.Transport.Retries = 3;// 设置Modbus通信的重试等待时间为1000毫秒master.Transport.WaitToRetryMilliseconds = 1000;}}catch (Exception ex){// 捕获异常并输出连接失败的消息Console.WriteLine("连接失败:" + ex.Message);}}/// <summary>/// 从指定的寄存器地址读取浮点数值(小字端)/// </summary>/// <param name="Adrss">寄存器地址的字符串表示</param>/// <returns>读取的浮点数值</returns>public static float Readfloat(string Adrss){try{ushort Address = ushort.Parse(Adrss); // 将地址字符串转换为ushort类型ushort[] registers = master.ReadHoldingRegisters(1, Address, 2); // 读取指定寄存器数量(2个寄存器)的数据byte[] floatBytes = new byte[4]; // 创建一个字节数组用于存储浮点数的字节Buffer.BlockCopy(registers, 0, floatBytes, 0, 4); // 从寄存器中拷贝数据到字节数组float floatValue = BitConverter.ToSingle(floatBytes, 0); // 将字节数组转换为浮点数return floatValue;}catch (Exception){Console.WriteLine("读取浮点数失败");}return 0; // 出现异常时返回0作为默认值}/// <summary>/// 将浮点数值写入指定的寄存器地址(小字端)/// </summary>/// <param name="Adrss">寄存器地址的字符串表示</param>/// <param name="Value">要写入的浮点数值的字符串表示</param>public static void Writefloat(string Adrss, float Value){try{ushort Address = ushort.Parse(Adrss); // 将地址字符串转换为ushort类型ushort[] registers = new ushort[2]; // 创建一个ushort数组用于存储浮点数的寄存器值byte[] floatBytes = BitConverter.GetBytes(Value); // 将浮点数值转换为字节数组registers[0] = BitConverter.ToUInt16(floatBytes, 0); // 获取低位寄存器的值registers[1] = BitConverter.ToUInt16(floatBytes, 2); // 获取高位寄存器的值master.WriteMultipleRegisters(1, Address, registers); // 将寄存器值写入到指定地址}catch (Exception){Console.WriteLine("写入浮点数失败");}}/// <summary>/// 将整数值写入指定的寄存器地址/// </summary>/// <param name="Adrss">寄存器地址的字符串表示</param>/// <param name="Value">要写入的整数值</param>public static void WriteInt(string Adrss, int Value){try{ushort Address = ushort.Parse(Adrss); // 将地址字符串转换为ushort类型ushort[] registers = new ushort[1]; // 创建一个ushort数组用于存储整数值registers[0] = (ushort)Value; // 将整数值转换为ushort,并存储到寄存器数组中master.WriteMultipleRegisters(1, Address, registers); // 将寄存器值写入到指定地址}catch (Exception){// 捕获并忽略异常,这里可以添加错误处理逻辑}}/// <summary>/// 从指定的寄存器地址读取整数值/// </summary>/// <param name="Adrss">寄存器地址的字符串表示</param>/// <returns>读取的整数值</returns>public static int ReadInt(string Adrss){try{ushort Address = ushort.Parse(Adrss); // 将地址字符串转换为ushort类型ushort[] registers = master.ReadHoldingRegisters(1, Address, 1); // 读取一个寄存器int result = (int)registers[0]; // 将寄存器值转换为整数return result;}catch (Exception){return -1; // 出现异常时返回-1作为默认值,或可以选择其他适当的默认值}}/// <summary>/// 将单个线圈的状态写入到指定的寄存器地址/// </summary>/// <param name="Adress">寄存器地址的字符串表示</param>/// <param name="status">要写入的线圈状态</param>public static void WriteCoil(string Adress, bool status){try{byte SlaveID = Convert.ToByte(1); // 从站ID(假设为1)ushort Address = ushort.Parse(Adress); // 将地址字符串转换为ushort类型master.WriteSingleCoil(SlaveID, Address, status); // 写入线圈状态到指定地址}catch (Exception){Console.WriteLine("写入线圈失败");}}/// <summary>/// 从指定的地址读取输入状态/// </summary>/// <param name="Address">输入地址的字符串表示</param>/// <returns>读取的输入状态</returns>public static bool ReadInput(string Address){try{ushort CoilAddress = ushort.Parse(Address); // 将地址字符串转换为ushort类型byte SlaveID = Convert.ToByte(1); // 从站ID(假设为1)return master.ReadInputs(SlaveID, CoilAddress, 1)[0]; // 读取输入状态}catch (Exception){throw; // 重新抛出异常,或可以选择其他异常处理机制}}/// <summary>/// 从指定的地址读取线圈状态/// </summary>/// <param name="Address">线圈地址的字符串表示</param>/// <returns>读取的线圈状态</returns>public static bool ReadCoil(string Address){try{ushort CoilAddress = ushort.Parse(Address); // 将地址字符串转换为ushort类型byte SlaveID = Convert.ToByte(1); // 从站ID(假设为1)return master.ReadCoils(SlaveID, CoilAddress, 1)[0]; // 读取线圈状态}catch (Exception){Console.WriteLine("读取线圈失败");return false; // 出现异常时返回false作为默认值}}}#endregion
二、以button按钮的点击事件为例连接PLC,根据实际情况填写IP、端口、和响应超时时间
private void PLC_Open_btn_Click(object sender, EventArgs e){NmodbusTcpHelper.Connect("192.168.1.1",502,2000);}
三、使用读写方法来实现对PLC寄存器的读写,本文以1000的寄存器地址为例,并且PLC的Slave ID为1(请根据实际情况来!)
private void Operate_btn_Click(object sender, EventArgs e){NmodbusTcpHelper.ReadInt("1000");NmodbusTcpHelper.WriteInt("1000",20);NmodbusTcpHelper.Readfloat("1000");NmodbusTcpHelper.Writefloat("1000", 20.00f);NmodbusTcpHelper.ReadCoil("1000");NmodbusTcpHelper.WriteCoil("1000",true);}