diff --git a/ModbusDemo/Device/IStreamResource.cs b/ModbusDemo/Device/IStreamResource.cs new file mode 100644 index 0000000..1678ced --- /dev/null +++ b/ModbusDemo/Device/IStreamResource.cs @@ -0,0 +1,45 @@ +using System; +using System.Collections.Generic; +using System.Linq; +using System.Text; +using System.Threading.Tasks; + +namespace ModbusDemo.Device +{ + public interface IStreamResource : IDisposable + { + int InfiniteTimeout { get; } + + /// + /// Gets or sets the number of milliseconds before a timeout occurs when a read operation does not finish. + /// + int ReadTimeout { get; set; } + + /// + /// Gets or sets the number of milliseconds before a timeout occurs when a write operation does not finish. + /// + int WriteTimeout { get; set; } + + /// + /// Purges the receive buffer. + /// + void DiscardInBuffer(); + + /// + /// Reads a number of bytes from the input buffer and writes those bytes into a byte array at the specified offset. + /// + /// The byte array to write the input to. + /// The offset in the buffer array to begin writing. + /// The number of bytes to read. + /// The number of bytes read. + int Read(byte[] buffer, int offset, int count); + + /// + /// Writes a specified number of bytes to the port from an output buffer, starting at the specified offset. + /// + /// The byte array that contains the data to write to the port. + /// The offset in the buffer array to begin writing. + /// The number of bytes to write. + void Write(byte[] buffer, int offset, int count); + } +} diff --git a/ModbusDemo/Device/ModbusRTU.cs b/ModbusDemo/Device/ModbusRTU.cs index afd944f..93803dc 100644 --- a/ModbusDemo/Device/ModbusRTU.cs +++ b/ModbusDemo/Device/ModbusRTU.cs @@ -17,11 +17,14 @@ namespace ModbusDemo.Device private SerialPort _serialPort; //用于操作数据库 private ModbusDbContext _modbusDbContext; + //TODO,修改 + private SerialPortAdapter _portAdapter; public ModbusRTU(SerialPort serialPort, ModbusDbContext modbusDbContext) { _serialPort = serialPort; _modbusDbContext = modbusDbContext; + _portAdapter = new SerialPortAdapter(serialPort); } /// /// 用来发送读写线圈的指令 @@ -94,15 +97,24 @@ namespace ModbusDemo.Device } } - //将操作失败的指令，插入数据库 - string RequestStr = ByteArrayToString(sendByte); + try + { + //将操作失败的指令，插入数据库 + string RequestStr = ByteArrayToString(sendByte); + + ModbusLog m = new ModbusLog(); + m.OperationType = "读线圈"; + m.ResponseData = ""; + m.RequestData = RequestStr; + _modbusDbContext.Add(m); + _modbusDbContext.SaveChanges(); + } + catch (Exception) + { - ModbusLog m = new ModbusLog(); - m.OperationType = "读线圈"; - m.ResponseData = ""; - m.RequestData = RequestStr; - _modbusDbContext.Add(m); - _modbusDbContext.SaveChanges(); + MessageBox.Show("0x15:数据库插入错误"); + } + return resultValue; } @@ -115,15 +127,24 @@ namespace ModbusDemo.Device /// public bool[] ParseCoilresponse(byte[] sendByte, byte[] response, ushort numberOfPoints) { - //将操作的指令，插入数据库 - string RequestStr = ByteArrayToString(sendByte); - string responseStr = ByteArrayToString(response); - ModbusLog m = new ModbusLog(); - m.OperationType = "读线圈"; - m.ResponseData = responseStr; - m.RequestData = RequestStr; - _modbusDbContext.Add(m); - _modbusDbContext.SaveChanges(); + try + { + //将操作的指令，插入数据库 + string RequestStr = ByteArrayToString(sendByte); + string responseStr = ByteArrayToString(response); + ModbusLog m = new ModbusLog(); + m.OperationType = "读线圈"; + m.ResponseData = responseStr; + m.RequestData = RequestStr; + _modbusDbContext.Add(m); + _modbusDbContext.SaveChanges(); + } + catch (Exception) + { + + MessageBox.Show("0x15:数据库插入错误"); + } + //判断发送回来的数据是否正确 @@ -255,21 +276,29 @@ namespace ModbusDemo.Device } } - //将操作的指令，插入数据库 - string RequestStr = ByteArrayToString(sendByte); - string responseStr = ByteArrayToString(response); - ModbusLog m = new ModbusLog(); - m.OperationType = "写线圈"; - m.ResponseData = responseStr; - m.RequestData = RequestStr; - _modbusDbContext.Add(m); - _modbusDbContext.SaveChanges(); - //判断发送回来的数据是否正确 - if (CheckData.CheckResponse(response)) + try { + //将操作的指令，插入数据库 + string RequestStr = ByteArrayToString(sendByte); + string responseStr = ByteArrayToString(response); + ModbusLog m = new ModbusLog(); + m.OperationType = "写线圈"; + m.ResponseData = responseStr; + m.RequestData = RequestStr; + _modbusDbContext.Add(m); + _modbusDbContext.SaveChanges(); + } + catch (Exception) + { + MessageBox.Show("0x15:数据库插入错误"); } + + + //判断发送回来的数据是否正确 + CheckData.CheckResponse(response); + } /// @@ -347,12 +376,21 @@ namespace ModbusDemo.Device //将操作失败的指令，插入数据库 string RequestStr = ByteArrayToString(sendByte); - ModbusLog m = new ModbusLog(); - m.OperationType = "读寄存器"; - m.ResponseData = ""; - m.RequestData = RequestStr; - _modbusDbContext.Add(m); - _modbusDbContext.SaveChanges(); + try + { + ModbusLog m = new ModbusLog(); + m.OperationType = "读寄存器"; + m.ResponseData = ""; + m.RequestData = RequestStr; + _modbusDbContext.Add(m); + _modbusDbContext.SaveChanges(); + } + catch (Exception) + { + + MessageBox.Show("0x15:数据库插入错误"); + } + return resultValue; @@ -367,15 +405,24 @@ namespace ModbusDemo.Device /// public ushort[] ParseRegistersresponse(byte[] sendByte, byte[] response, ushort numberOfPoints) { - //将操作的指令，插入数据库 - string RequestStr = ByteArrayToString(sendByte); - string responseStr = ByteArrayToString(response); - ModbusLog m = new ModbusLog(); - m.OperationType = "读寄存器"; - m.ResponseData = responseStr; - m.RequestData = responseStr; - _modbusDbContext.Add(m); - _modbusDbContext.SaveChanges(); + try + { + //将操作的指令，插入数据库 + string RequestStr = ByteArrayToString(sendByte); + string responseStr = ByteArrayToString(response); + ModbusLog m = new ModbusLog(); + m.OperationType = "读寄存器"; + m.ResponseData = responseStr; + m.RequestData = RequestStr; + _modbusDbContext.Add(m); + _modbusDbContext.SaveChanges(); + } + catch (Exception) + { + MessageBox.Show("0x15:数据库插入错误"); + + } + //判断发送回来的数据是否正确 if (CheckData.CheckResponse(response)) @@ -479,16 +526,25 @@ namespace ModbusDemo.Device attempt++; } } + try + { + //将操作的指令，插入数据库 + string RequestStr = ByteArrayToString(sendByte); + string responseStr = ByteArrayToString(response); + ModbusLog m = new ModbusLog(); + m.OperationType = "写寄存器"; + m.ResponseData = responseStr; + m.RequestData = RequestStr; + _modbusDbContext.Add(m); + _modbusDbContext.SaveChanges(); + } + catch (Exception) + { - //将操作的指令，插入数据库 - string RequestStr = ByteArrayToString(sendByte); - string responseStr = ByteArrayToString(response); - ModbusLog m = new ModbusLog(); - m.OperationType = "写寄存器"; - m.ResponseData = responseStr; - m.RequestData = RequestStr; - _modbusDbContext.Add(m); - _modbusDbContext.SaveChanges(); + MessageBox.Show("0x15:数据库插入错误"); + } + + //判断发送回来的数据是否正确 CheckData.CheckResponse(response); @@ -506,7 +562,7 @@ namespace ModbusDemo.Device if (byteArray == null || byteArray.Length == 0) return string.Empty; - System.Text.StringBuilder sb = new System.Text.StringBuilder(); + StringBuilder sb = new StringBuilder(); // 处理第一个元素（无前导空格） sb.Append(byteArray[0].ToString("X2")); diff --git a/ModbusDemo/Device/SerialPortAdapter.cs b/ModbusDemo/Device/SerialPortAdapter.cs new file mode 100644 index 0000000..5a1da48 --- /dev/null +++ b/ModbusDemo/Device/SerialPortAdapter.cs @@ -0,0 +1,71 @@ +using System; +using System.Collections.Generic; +using System.Diagnostics; +using System.IO.Ports; +using System.Linq; +using System.Text; +using System.Threading.Tasks; + +namespace ModbusDemo.Device +{ + public class SerialPortAdapter:IStreamResource + { + private string NewLine = Environment.NewLine; + private SerialPort _serialPort; + + public SerialPortAdapter(SerialPort serialPort) + { + Debug.Assert(serialPort != null, "Argument serialPort cannot be null."); + + _serialPort = serialPort; + _serialPort.NewLine = NewLine; + } + + public int InfiniteTimeout + { + get { return SerialPort.InfiniteTimeout; } + } + + public int ReadTimeout + { + get { return _serialPort.ReadTimeout; } + set { _serialPort.ReadTimeout = value; } + } + + public int WriteTimeout + { + get { return _serialPort.WriteTimeout; } + set { _serialPort.WriteTimeout = value; } + } + + public void DiscardInBuffer() + { + _serialPort.DiscardInBuffer(); + } + + public int Read(byte[] buffer, int offset, int count) + { + return _serialPort.Read(buffer, offset, count); + } + + public void Write(byte[] buffer, int offset, int count) + { + _serialPort.Write(buffer, offset, count); + } + + public void Dispose() + { + Dispose(true); + GC.SuppressFinalize(this); + } + + protected virtual void Dispose(bool disposing) + { + if (disposing) + { + _serialPort?.Dispose(); + _serialPort = null; + } + } + } +} diff --git a/ModbusDemo/ModbusDemo.csproj b/ModbusDemo/ModbusDemo.csproj index 6ff48c3..02d9860 100644 --- a/ModbusDemo/ModbusDemo.csproj +++ b/ModbusDemo/ModbusDemo.csproj @@ -6,8 +6,15 @@ disable enable true + ModbusRTU_64x64.ico + + + Always + + + @@ -24,4 +31,8 @@ + + + + diff --git a/ModbusDemo/ModbusRTU_64x64.ico b/ModbusDemo/ModbusRTU_64x64.ico new file mode 100644 index 0000000..97c1b9e Binary files /dev/null and b/ModbusDemo/ModbusRTU_64x64.ico differ diff --git a/ModbusDemo/Model/ModbusDbContext.cs b/ModbusDemo/Model/ModbusDbContext.cs index e37d7dd..068adb4 100644 --- a/ModbusDemo/Model/ModbusDbContext.cs +++ b/ModbusDemo/Model/ModbusDbContext.cs @@ -7,6 +7,9 @@ using System.Threading.Tasks; namespace ModbusDemo.Model { + /// + /// 操作数据库的上下文 + /// public class ModbusDbContext:DbContext { protected ModbusDbContext() diff --git a/ModbusDemo/Model/ModbusLog.cs b/ModbusDemo/Model/ModbusLog.cs index fc0e255..59dbc20 100644 --- a/ModbusDemo/Model/ModbusLog.cs +++ b/ModbusDemo/Model/ModbusLog.cs @@ -7,6 +7,9 @@ using System.Threading.Tasks; namespace ModbusDemo.Model { + /// + /// 表的映射 + /// public class ModbusLog { //数据库主键 @@ -17,6 +20,7 @@ namespace ModbusDemo.Model //请求的字节信息 public string RequestData { get; set; } //返回的字节信息 + public string ResponseData { get; set; } //操作的时间 diff --git a/ModbusDemo/Uitls/CheckData.cs b/ModbusDemo/Uitls/CheckData.cs index 31854d5..ec4b836 100644 --- a/ModbusDemo/Uitls/CheckData.cs +++ b/ModbusDemo/Uitls/CheckData.cs @@ -9,7 +9,11 @@ namespace ModbusDemo.Uitls { public static class CheckData { - + /// + /// 检测返回的数据格式是否正确 + /// + /// + /// public static bool CheckResponse(byte[] response) { if (response.Length == 0) diff --git a/ModbusDemo/VIew/CoilUC.xaml b/ModbusDemo/VIew/CoilUC.xaml index 951336f..a0a0489 100644 --- a/ModbusDemo/VIew/CoilUC.xaml +++ b/ModbusDemo/VIew/CoilUC.xaml @@ -88,8 +88,8 @@ Grid.Column="4" Width="80" Height="40" - IsEnabled="{Binding IsEnable}" materialDesign:ButtonAssist.CornerRadius="20" + IsEnabled="{Binding IsEnable}" Command="{Binding ReadCoilCmm}" Content="读取" Style="{StaticResource MaterialDesignRaisedDarkButton}"> @@ -154,16 +154,16 @@ - + - + - + diff --git a/ModbusDemo/VIew/RegisterUC.xaml b/ModbusDemo/VIew/RegisterUC.xaml index e19a195..57330b4 100644 --- a/ModbusDemo/VIew/RegisterUC.xaml +++ b/ModbusDemo/VIew/RegisterUC.xaml @@ -88,8 +88,8 @@ Grid.Column="4" Width="80" Height="40" - IsEnabled="{Binding IsEnable}" materialDesign:ButtonAssist.CornerRadius="20" + IsEnabled="{Binding IsEnable}" Command="{Binding ReadRegisterCmm}" Content="读取" Style="{StaticResource MaterialDesignRaisedDarkButton}"> @@ -142,8 +142,8 @@ Grid.Column="4" Width="80" Height="40" - IsEnabled="{Binding IsEnable}" materialDesign:ButtonAssist.CornerRadius="20" + IsEnabled="{Binding IsEnable}" Command="{Binding WriteRegisterCmm}" Content="写入" Style="{StaticResource MaterialDesignRaisedDarkButton}"> diff --git a/ModbusDemo/VIewModel/AttachUCViewModel.cs b/ModbusDemo/VIewModel/AttachUCViewModel.cs index 248d0f4..c5c851c 100644 --- a/ModbusDemo/VIewModel/AttachUCViewModel.cs +++ b/ModbusDemo/VIewModel/AttachUCViewModel.cs @@ -1,4 +1,6 @@ using Modbus.Device; +using ModbusDemo.Model; +using ModbusDemo.Uitls; using Prism.Commands; using Prism.Mvvm; using System; @@ -51,11 +53,12 @@ namespace ModbusDemo.VIewModel ReadOddRegisterCmm = new DelegateCommand(ReadOddRegister); _serialPort = serialPort; } - + /// + /// 读1000个寄存器 + /// private void ReadOddRegister() { // 创建 Modbus RTU 主站 - IModbusSerialMaster master = ModbusSerialMaster.CreateRtu(_serialPort); byte slaveId = 1; ushort totalRegisters = 1000; @@ -80,7 +83,7 @@ namespace ModbusDemo.VIewModel } catch (Exception ex) { - Console.WriteLine($"线程 {chunkIndex} 读取寄存器时出错: {ex.Message}"); + MessageBox.Show($"线程 {chunkIndex} 读取寄存器时出错: {ex.Message}"); } }); } @@ -102,6 +105,150 @@ namespace ModbusDemo.VIewModel ReadResult = result.ToString(); } + + private void ReadOddRegister2() + { + byte slaveId = 1; + ushort totalRegisters = 1000; + ushort chunkSize = 100; + int numChunks = (int)Math.Ceiling((double)totalRegisters / chunkSize); + + ushort[] allRegisters = new ushort[totalRegisters]; + Task[] tasks = new Task[numChunks]; + DateTime startTime = DateTime.Now; + for (int i = 0; i < numChunks; i++) + { + ushort startAddress = (ushort)(10300 + i * chunkSize); + ushort currentChunkSize = 100; + + int chunkIndex = i; + tasks[i] = Task.Run(() => + { + + ushort[] registers = ReadRegisters(slaveId, startAddress, currentChunkSize); + Array.Copy(registers, 0, allRegisters, chunkIndex * chunkSize, currentChunkSize); + + + }); + } + + // 等待所有任务完成 + Task.WaitAll(tasks); + Time = (int)(DateTime.Now - startTime).TotalMilliseconds; + StringBuilder result = new StringBuilder(); + int count = 0; + for (int i = 1; i < totalRegisters; i += 2) + { + result.Append(allRegisters[i].ToString() + " "); + count++; + if (count % 50 == 0) + { + result.AppendLine(); + } + } + ReadResult = result.ToString(); + } + + + public ushort[] ReadRegisters(byte slaveAddress, ushort startAddress, ushort numberOfPoints) + { + object _lock = new object(); + ushort[] resultValue = null; + if (!_serialPort.IsOpen) + { + MessageBox.Show("串口没有链接，请先链接"); + return resultValue; + } + List sendByteList = new List(); + //设置从站地址 + sendByteList.Add(slaveAddress); + //设置功能码 + sendByteList.Add(0x03); + //设置起始地址的高位和低位 + sendByteList.Add(BitConverter.GetBytes(startAddress)[1]); + sendByteList.Add(BitConverter.GetBytes(startAddress)[0]); + //设置读取几个线圈的高位和低位 + sendByteList.Add(BitConverter.GetBytes(numberOfPoints)[1]); + sendByteList.Add(BitConverter.GetBytes(numberOfPoints)[0]); + //获取CRC校验码 + byte[] getCRC = sendByteList.ToArray(); + byte[] resultCRC = CRCUitl.CalculateCRC(getCRC, getCRC.Length); + sendByteList.Add(resultCRC[0]); + sendByteList.Add(resultCRC[1]); + + byte[] sendByte = sendByteList.ToArray(); + int maxRetries = 3; // 最大重试次数 + int attempt = 0; + List responseData = new List(); + byte[] response = null; + _serialPort.Write(sendByte, 0, sendByte.Length); + while (attempt < maxRetries) + { + try + { + lock (_lock) + { + + + //使用时间去轮询查询数据 + DateTime startTime = DateTime.Now; + while ((DateTime.Now - startTime).TotalMilliseconds < _serialPort.ReadTimeout) + { + int bytesToRead = _serialPort.BytesToRead; + if (bytesToRead > 0) + { + byte[] buffer = new byte[bytesToRead]; + int bytesRead = _serialPort.Read(buffer, 0, bytesToRead); + responseData.AddRange(buffer.Take(bytesRead)); + } + //延迟20毫秒，节约cpu资源 + Task.Delay(20); + } + response = responseData.ToArray(); + if (response[0] == 0x00) + { + continue; + } + resultValue = ParseRegistersresponse(sendByte, response, numberOfPoints); + return resultValue; + } + } + catch (Exception) + { + + attempt++; + } + + } + + return resultValue; + + + + } + + public ushort[] ParseRegistersresponse(byte[] sendByte, byte[] response, ushort numberOfPoints) + { + + + //判断发送回来的数据是否正确 + if (CheckData.CheckResponse(response)) + { + ushort[] registers = new ushort[numberOfPoints]; + for (int i = 0; i < numberOfPoints; i++) + { + int pos = 3 + i * 2; + // 大端序转换 (高位在前) + registers[i] = (ushort)((response[pos] << 8) | response[pos + 1]); + } + + return registers; + } + else + { + return null; + } + } } } diff --git a/ModbusDemo/VIewModel/CoilUCViewModel.cs b/ModbusDemo/VIewModel/CoilUCViewModel.cs index 6f7012b..c2eee20 100644 --- a/ModbusDemo/VIewModel/CoilUCViewModel.cs +++ b/ModbusDemo/VIewModel/CoilUCViewModel.cs @@ -50,6 +50,8 @@ namespace ModbusDemo.VIewModel + "，数据位：" + _serialPort.DataBits + "，校验位：" + _serialPort.Parity + "，停止位：" + _serialPort.StopBits; } + + } #region 读取定义 diff --git a/ModbusDemo/VIewModel/MainWindowViewModel.cs b/ModbusDemo/VIewModel/MainWindowViewModel.cs index abad9e2..fc5f8b6 100644 --- a/ModbusDemo/VIewModel/MainWindowViewModel.cs +++ b/ModbusDemo/VIewModel/MainWindowViewModel.cs @@ -66,7 +66,7 @@ namespace ModbusDemo.VIewModel LeftMenusList.Add(new MenusInfo() { Icon = "AllInclusive", MenuName = "线圈操作", ViewName = "CoilUC" }); LeftMenusList.Add(new MenusInfo() { Icon = "BlurCircular", MenuName = "寄存器操作", ViewName = "RegisterUC" }); LeftMenusList.Add(new MenusInfo() { Icon = "Settings", MenuName = "串口设置", ViewName = "SettingsUC" }); - LeftMenusList.Add(new MenusInfo() { Icon = "Settings", MenuName = "附加功能", ViewName = "AttachUC" }); + LeftMenusList.Add(new MenusInfo() { Icon = "AddCircle", MenuName = "附加功能", ViewName = "AttachUC" }); } public void DefultNaigation() diff --git a/ModbusTest/ModbusRTUTest.cs b/ModbusTest/ModbusRTUTest.cs index 79fee9e..1d6c982 100644 --- a/ModbusTest/ModbusRTUTest.cs +++ b/ModbusTest/ModbusRTUTest.cs @@ -29,7 +29,7 @@ namespace ModbusTest _serialport.StopBits = StopBits.One; _serialport.ReadTimeout = 500; _serialport.WriteTimeout = 500; - _serialport.Open(); + _serialport.Open(); _mockDbContext = new Mock(); _modbusRtu = new ModbusRTU(_serialport, _mockDbContext.Object); } @@ -47,7 +47,6 @@ namespace ModbusTest { var result = _modbusRtu.ReadCoil(1, 300, 5); - // 创建包含5个true的预期数组 var expected = new bool[5]; Array.Fill(expected, false); CollectionAssert.AreEqual(expected, result); @@ -57,21 +56,23 @@ namespace ModbusTest public void ReadCoil2() { var result = _modbusRtu.ReadCoil(1, 305, 5); - // 创建包含5个flase的预期数组 + var expected = new bool[5]; Array.Fill(expected, true); CollectionAssert.AreEqual(expected, result); } - + /// + /// 测试写入线圈 + /// [Test] public void WriteCoil1() { var data = new bool[5]; Array.Fill(data, true); _modbusRtu.WriteCoil(1, 310, data); - // 创建包含5个true的预期数组 + var expected = _modbusRtu.ReadCoil(1, 310, 5); CollectionAssert.AreEqual(data, expected); @@ -85,13 +86,15 @@ namespace ModbusTest var data = new bool[5]; Array.Fill(data, false); _modbusRtu.WriteCoil(1, 315, data); - // 创建包含5个flase的预期数组 + var expected = _modbusRtu.ReadCoil(1, 315, 5); CollectionAssert.AreEqual(data, expected); } - + /// + /// 测试读取寄存器 + /// [Test] public void ReadRegister1() { @@ -108,13 +111,15 @@ namespace ModbusTest { ushort[] data = new ushort[5]; Array.Fill(data, (ushort)1); - + var expected = _modbusRtu.ReadRegisters(1, 305, 5); CollectionAssert.AreEqual(data, expected); } - + /// + /// 测试写入寄存器 + /// [Test] public void WriteRegister1() { @@ -137,5 +142,59 @@ namespace ModbusTest var expected = _modbusRtu.ReadRegisters(1, 315, 5); CollectionAssert.AreEqual(data, expected); } + + /// + /// 解析线圈的返回值 + /// + [Test] + public void ParseCoilresponse1() + { + var data = new bool[5]; + Array.Fill(data, true); + byte[] response = new byte[] { 0x01, 0x01, 0x01, 0x7f, 0x10, 0x68 }; + bool[] bools = _modbusRtu.ParseCoilresponse(new byte[] { }, response, 5); + + CollectionAssert.AreEqual(data, bools); + } + + [Test] + public void ParseCoilresponse2() + { + var data = new bool[5]; + Array.Fill(data, false); + byte[] response = new byte[] { 0x01, 0x01, 0x01, 0x00, 0x51, 0x88 }; + bool[] result = _modbusRtu.ParseCoilresponse(new byte[] { }, response, 5); + + CollectionAssert.AreEqual(data, result); + } + + /// + /// 解析寄存器的返回值 + /// + [Test] + public void ParseRegistersresponse1() + { + ushort[] data = new ushort[5]; + Array.Fill(data, (ushort)1); + byte[] response = new byte[] {0x01, 0x03, 0x0a, 0x00, 0x01, 0x00, 0x01, 0x00, + 0x01, 0x00, 0x01, 0x00, 0x01, 0x94, 0x26 }; + + ushort[] result = _modbusRtu.ParseRegistersresponse(new byte[] {},response, 5); + + CollectionAssert.AreEqual(data, result); + } + + [Test] + public void ParseRegistersresponse2() + { + ushort[] data = new ushort[2]; + Array.Fill(data, (ushort)10); + byte[] response = new byte[] {0x01, 0x03, 0x04, 0x00,0x0a, 0x00, 0x0a, 0x5a, 0x36 }; + + ushort[] result = _modbusRtu.ParseRegistersresponse(new byte[] { }, response, 2); + + CollectionAssert.AreEqual(data, result); + } + } }