引用NModbus 在NuGet搜索NModbus，添加引用。 封裝ModbusTcp類 public class ModbusTCP { private ModbusFactory modbusFactory; private IModbusMaster master; private TcpCl ...
引用NModbus
在NuGet搜索NModbus，添加引用。
封裝ModbusTcp類
public class ModbusTCP
{
private ModbusFactory modbusFactory;
private IModbusMaster master;
private TcpClient tcpClient;
public string IPAdress { get; set; }
public int Port { get; set; }
public bool Connected
{
get => tcpClient.Connected;
}
public ModbusTCP(string ip, int port)
{
IPAdress = ip;
Port = port;
modbusFactory = new ModbusFactory();
tcpClient = new TcpClient(IPAdress, Port);
master = modbusFactory.CreateMaster(tcpClient);
master.Transport.ReadTimeout = 2000;
master.Transport.Retries = 10;
}
public bool[] ReadCoils(byte slaveAddress, ushort startAddress, ushort num)
{
return master.ReadCoils(slaveAddress, startAddress, num);
}
public bool[] ReadInputs(byte slaveAddress, ushort startAddress, ushort num)
{
return master.ReadInputs(slaveAddress, startAddress, num);
}
public ushort[] ReadHoldingRegisters(byte slaveAddress, ushort startAddress, ushort num)
{
return master.ReadHoldingRegisters(slaveAddress, startAddress, num);
}
public ushort[] ReadInputRegisters(byte slaveAddress, ushort startAddress, ushort num)
{
return master.ReadInputRegisters(slaveAddress, startAddress, num);
}
public void WriteSingleCoil(byte slaveAddress, ushort startAddress, bool value)
{
master.WriteSingleCoil(slaveAddress, startAddress, value);
}
public void WriteSingleRegister(byte slaveAddress, ushort startAddress, ushort value)
{
master.WriteSingleRegister(slaveAddress, startAddress, value);
}
public void WriteMultipleCoils(byte slaveAddress, ushort startAddress, bool[] value)
{
master.WriteMultipleCoils(slaveAddress, startAddress, value);
}
public void WriteMultipleRegisters(byte slaveAddress, ushort startAddress, ushort[] value)
{
master.WriteMultipleRegisters(slaveAddress, startAddress, value);
}
}
連接測試
下載 Modbus Slave
鏈接：https://pan.baidu.com/s/1ydX_9KElkOTA7h-E3SIadw
提取碼：7fh5
設置
連接
private ModbusTCP modbus;
private void ConnectExecute()
{
try
{
modbus = new ModbusTCP(IP, Port);
pollingTimer.Start();
}
catch (Exception ex)
{
Msg.Info(ex.Message);
}
}
寫入測試
NModbus提供的對寄存器讀寫方法，只包括ushort類型，需要對ushort進行進行轉換。
封裝轉換類型
public class MODBUS
{
/// <summary>
/// 賦值string
/// </summary>
/// <param name="src"></param>
/// <param name="start"></param>
/// <param name="value"></param>
/// <returns></returns>
public static void SetString(ushort[] src, int start, string value)
{
byte[] bytesTemp = Encoding.UTF8.GetBytes(value);
ushort[] dest = Bytes2Ushorts(bytesTemp);
dest.CopyTo(src, start);
}
/// <summary>
/// 獲取string
/// </summary>
/// <param name="src"></param>
/// <param name="start"></param>
/// <param name="len"></param>
/// <returns></returns>
public static string GetString(ushort[] src, int start, int len)
{
ushort[] temp = new ushort[len];
for (int i = 0; i < len; i++)
{
temp[i] = src[i + start];
}
byte[] bytesTemp = Ushorts2Bytes(temp);
string res = Encoding.UTF8.GetString(bytesTemp).Trim(new char[] { '\0' });
return res;
}
/// <summary>
/// 賦值Real類型數據
/// </summary>
/// <param name="src"></param>
/// <param name="start"></param>
/// <param name="value"></param>
public static void SetReal(ushort[] src, int start, float value)
{
byte[] bytes = BitConverter.GetBytes(value);
ushort[] dest = Bytes2Ushorts(bytes);
dest.CopyTo(src, start);
}
/// <summary>
/// 獲取float類型數據
/// </summary>
/// <param name="src"></param>
/// <param name="start"></param>
/// <returns></returns>
public static float GetReal(ushort[] src, int start)
{
ushort[] temp = new ushort[2];
for (int i = 0; i < 2; i++)
{
temp[i] = src[i + start];
}
byte[] bytesTemp = Ushorts2Bytes(temp);
float res = BitConverter.ToSingle(bytesTemp, 0);
return res;
}
/// <summary>
/// 賦值Short類型數據
/// </summary>
/// <param name="src"></param>
/// <param name="start"></param>
/// <param name="value"></param>
public static void SetShort(ushort[] src, int start, short value)
{
byte[] bytes = BitConverter.GetBytes(value);
ushort[] dest = Bytes2Ushorts(bytes);
dest.CopyTo(src, start);
}
/// <summary>
/// 獲取short類型數據
/// </summary>
/// <param name="src"></param>
/// <param name="start"></param>
/// <returns></returns>
public static short GetShort(ushort[] src, int start)
{
ushort[] temp = new ushort[1];
temp[0] = src[start];
byte[] bytesTemp = Ushorts2Bytes(temp);
short res = BitConverter.ToInt16(bytesTemp, 0);
return res;
}
public static bool[] GetBools(ushort[] src, int start, int num)
{
ushort[] temp = new ushort[num];
for (int i = start; i < start + num; i++)
{
temp[i] = src[i + start];
}
byte[] bytes = Ushorts2Bytes(temp);
bool[] res = Bytes2Bools(bytes);
return res;
}
private static bool[] Bytes2Bools(byte[] b)
{
bool[] array = new bool[8*b.Length];
for (int i = 0; i < b.Length; i++)
{
for (int j = 0; j < 8; j++)
{
array[i * 8 + j] = (b[i] & 1) == 1;//判定byte的最後一位是否為1，若為1，則是true；否則是false
b[i] = (byte)(b[i] >> 1);//將byte右移一位
}
}
return array;
}
private static byte Bools2Byte(bool[] array)
{
if (array != null && array.Length > 0)
{
byte b = 0;
for (int i = 0; i < 8; i++)
{
if (array[i])
{
byte nn = (byte)(1 << i);//左移一位，相當於×2
b += nn;
}
}
return b;
}
return 0;
}
private static ushort[] Bytes2Ushorts(byte[] src, bool reverse = false)
{
int len = src.Length;
byte[] srcPlus = new byte[len + 1];
src.CopyTo(srcPlus, 0);
int count = len >> 1;
if (len % 2 != 0)
{
count += 1;
}
ushort[] dest = new ushort[count];
if(reverse)
{
for (int i = 0; i < count; i++)
{
dest[i] = (ushort)(srcPlus[i * 2] << 8 | srcPlus[2 * i + 1] & 0xff);
}
}
else
{
for (int i = 0; i < count; i++)
{
dest[i] = (ushort)(srcPlus[i * 2] & 0xff | srcPlus[2 * i + 1] << 8 );
}
}
return dest;
}
private static byte[] Ushorts2Bytes(ushort[] src, bool reverse = false)
{
int count = src.Length;
byte[] dest = new byte[count << 1];
if(reverse)
{
for (int i = 0; i < count; i++)
{
dest[i * 2] = (byte)(src[i] >> 8);
dest[i * 2 + 1] = (byte)(src[i] >> 0);
}
}
else
{
for (int i = 0; i < count; i++)
{
dest[i * 2] = (byte)(src[i] >> 0);
dest[i * 2 + 1] = (byte)(src[i] >> 8);
}
}
return dest;
}
}
根據選擇的類型寫入
private void WriteExecute()
{
try
{
if(VariableType == "real")
{
ushort[] buff = new ushort[2];
float value = float.Parse(WriteValue);
MODBUS.SetReal(buff, 0, value);
modbus.WriteMultipleRegisters(SlaveID, WriteAddress, buff);
}
else if(VariableType == "string")
{
ushort[] buff = new ushort[10];
MODBUS.SetString(buff, 0, WriteValue);
modbus.WriteMultipleRegisters(SlaveID, WriteAddress, buff);
}
else if(VariableType == "Int16")
{
ushort[] buff = new ushort[1];
short value = short.Parse(WriteValue);
MODBUS.SetShort(buff, 0, value);
modbus.WriteMultipleRegisters(SlaveID, WriteAddress, buff);
}
}
catch (Exception ex)
{
Msg.Info(ex.Message);
}
}
可以看到ModbusSlave上面的數據，一個浮點型數據占用兩個寄存器，4個byte。按照下圖設置後，可以看到，已經寫入成功。
讀取測試
private void ReadExecute()
{
try
{
if (VariableType == "real")
{
ushort[] buff = modbus.ReadHoldingRegisters(SlaveID, ReadAddress, 2);
float value = MODBUS.GetReal(buff, 0);
ReadValue = value.ToString();
}
else if(VariableType == "string")
{
ushort[] buff = modbus.ReadHoldingRegisters(SlaveID, ReadAddress, 10);
ReadValue = MODBUS.GetString(buff, 0, 10);
}
else if(VariableType == "Int16")
{
ushort[] buff = modbus.ReadHoldingRegisters(SlaveID, ReadAddress, 1);
short value = MODBUS.GetShort(buff, 0);
ReadValue = value.ToString();
}
}
catch (Exception ex)
{
Msg.Info(ex.Message);
}
}
字元串寫入和讀取
參照VariableType=="string"部分代碼。
