devbox
笔触狂放9
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

C#Modbus通信_modbustcp

作者：笔触狂放9 | 2024-07-10 11:43:45

赞

踩

modbustcp

目录

1，辅助工具。

2，初识Modbus。

3，基于ModbusRTU的通信。

3.1，RTU与ASCII模式区别

3.2，Modbus存储区

3.3，报文格式

3.4，异常代码

3.5，详细文档连接 。

3.6，代码

3.6.1，准备

3.6.2，UI部分

3.6.3，UI代码部分

3.6.4，Modbus类

3.6.5，校验码类

4，基于ModbusTCP通信。

4.1，ModbusTCP报文格式参考链接

4.2，代码

4.2.1，准备

4.2.2，UI部分

4.2.3，UI代码部分

5，基于OPC服务的Modbus通信

5.1，OPC介绍

5.2,OPCDAAuto.dll链接

5.3，配置OPC服务软件KEPServerEx V4.0

5.4，代码

6，Demo链接。

1，辅助工具。

  1. 1，虚拟串口工具（vspd.exe）
  2. 2，Modubus模拟主站(Modbus Poll)
  3. 3，Modbus模拟从站(Modbus Slave)
  4. 4，OPC服务软件(KEPServerEx V4.0)。

下载链接：https://download.csdn.net/download/lingxiao16888/89516857

2，初识Modbus。

  1. 1，Modbus协议是一种应用层报文传输协议，包含RTU，ASCII，TCP（分配的端口号为：502）三种报文类型。
  2.  
  3. 2，标准的Modbus协议物理层接口有RS232,RS485,RS422,以太网口。采用主从（Master/Slave）方式通信。
  4.  
  5. 3，Modbus主从站协议原理
  6.     Modubus串行链路协议是一种主从协议。在同一时刻，只有一个主站，一个从站或者多个从站（从站最大编号247）连接在同一串行总线。
  7.    Modbus通信由主站发起，从站在没有收到主站的请求时是不会发送数据。
  8.     从站之间互不通信。
  9.     主站在同一时刻只能发起一个Modbus事务请求。
  10.     主站有两种模式对从站发起请求：广播，单播。
  11.  
  12. 4，Modbus帧结构
  13.     Modbus串行链路协议是一种主从协议。
  14.     网络上的每个从站必须有唯一的地址（从1到247）
  15.     从站地址用于寻址从站设备，由主站发起。
  16.     地址0用于广播模式，不需要响应。
  17.     RS-485，RS-232定义了标准的物理端口，提高了操作性。

3，基于ModbusRTU的通信。

3.1，RTU与ASCII模式区别

3.2，Modbus存储区

3.3，报文格式

 

 

 

3.4，异常代码

 

3.5，详细文档连接 。

https://download.csdn.net/download/lingxiao16888/89516928?spm=1001.2014.3001.5503

3.6，代码

目的：通过标准Modbus协议完成对线圈，寄存器的读写。

  • 效果展示：

3.6.1，准备

第1步，使用虚拟串口软件创建虚拟串口。

第2步，使用ModbusSlave软件建立虚拟Modbus从站。

配置通信连接参数

配置功能定义（是进行线圈读写还是寄存器读写）

定义数据显示格式

注明：此截图中的ID=1；F=01表示从站地址为01，功能码为01（即读取线圈，具体参考前面报文格式阐述）

3.6.2，UI部分

3.6.3，UI代码部分
  1.  public partial class Form1 : Form
  2.     {
  3.         ModbusSerial modbus;
  4.         int slaveStation = 10;
  5.         Timer timer = new Timer();
  6.         public Form1()
  7.         {
  8.             InitializeComponent();
  9.             UIControlStatusChange(false);
  10.             timer.Interval = 1000;
  11.             foreach (Control item in groupBox1.Controls)
  12.             {
  13.                 if (item is GroupBox)
  14.                 {
  15.                     foreach (Control c in item.Controls)
  16.                     {
  17.                         if (c is Button)
  18.                         {
  19.                             (c as Button).Click += Button_Click;
  20.                         }
  21.                     }
  22.                 }
  23.             }
  24.             InitDataLoad();
  25.         }
  26.         void InitDataLoad()
  27.         {
  28.             //获取串口号
  29.             comboPortName.DataSource = SerialPort.GetPortNames();
  30.             //波特率
  31.             comboBaudRate.DataSource = new int[] { 4800, 9600, 19200 };
  32.             comboBaudRate.SelectedIndex = 1;
  33.             //数据位
  34.             comboDataBits.DataSource = new int[] { 5, 6, 7, 8 };
  35.             comboDataBits.SelectedIndex = 3;
  36.             //校验位
  37.             comboParity.DataSource = Enum.GetNames(typeof(Parity));
  38.             //停止位----不支持None所以应该None去除
  39.             comboStopBits.DataSource = Enum.GetNames(typeof(StopBits)).Where(item => !item.Equals("None", StringComparison.CurrentCultureIgnoreCase)).ToArray();
  40.             modbus = new ModbusSerial();
  41.             modbus.ErrorMessage += Modbus_ErrorMessage;
  42.           
  43.         }
  44.         private void Button_Click(object sender, EventArgs e)
  45.         {
  46.             lblErrorMsg.Text = "";
  47.         }
  48.         private void Modbus_ErrorMessage(int arg1, string arg2)
  49.         {
  50.             this.Invoke(new Action(() =>
  51.             {
  52.                 lblErrorMsg.Text = $"从站[{arg1}]出现异常，原因：{arg2}";
  53.             }));
  54.         }
  55.         /// <summary>
  56.         /// 变更UI控件状态
  57.         /// </summary>
  58.         /// <param name="status">True:已连接，False：连接断开</param>
  59.         void UIControlStatusChange(bool status)
  60.         {
  61.             if (status)
  62.             {
  63.                 gbParam.Enabled = false;
  64.                 btnConnect.BackColor = Color.LightGreen;
  65.                 btnConnect.Text = "断开连接";
  66.                 groupBox1.Enabled = true;
  67.             }
  68.             else
  69.             {
  70.                 gbParam.Enabled = true;
  71.                 btnConnect.BackColor = Color.Red;
  72.                 btnConnect.Text = "连接";
  73.                 groupBox1.Enabled = false;
  74.             }
  75.         }
  76.         private void btnConnect_Click(object sender, EventArgs e)
  77.         {
  78.             if (btnConnect.Text.Equals("连接"))
  79.             {
  80.                 if (modbus.IsOpen)
  81.                 {
  82.                     modbus.Close();
  83.                 }
  84.                 //更新端口的设置
  85.                 if (comboPortName.DataSource == null || comboPortName.Items.Count==0)
  86.                 {
  87.                     MessageBox.Show("没有可用的串口！", "提示", MessageBoxButtons.OK, MessageBoxIcon.Information);
  88.                     return;
  89.                 }
  90.                 string portName = comboPortName.Text;
  91.                 int baudRate = Convert.ToInt32(comboBaudRate.Text);
  92.                 int dataBits = Convert.ToInt32(comboDataBits.Text);
  93.                 Parity parity = (Parity)Enum.Parse(typeof(Parity), comboParity.Text);
  94.                 StopBits stopBits = (StopBits)Enum.Parse(typeof(StopBits), comboStopBits.Text);
  95.                 modbus.BaudRate = baudRate;
  96.                 modbus.DataBits = dataBits;
  97.                 modbus.Parity = parity;
  98.                 modbus.StopBits = stopBits;
  99.                 modbus.Open(portName);
  100.             }
  101.             else
  102.             {
  103.                 if (modbus.IsOpen)
  104.                 {
  105.                     modbus.Close();
  106.                 }
  107.             }
  108.             UIControlStatusChange(modbus.IsOpen);
  109.         }
  110.         //读取多个线圈
  111.         private void btnReadCoils_Click(object sender, EventArgs e)
  112.         {
  113.             int address; int len;
  114.             if (!int.TryParse(txtCoilsAddress.Text.Trim(), out address))
  115.             {
  116.                 txtCoilsAddress.Focus();
  117.                 MessageBox.Show("线圈地址错误！");
  118.                 return;
  119.             }
  120.             if (!int.TryParse(txtCoilsCount.Text.Trim(), out len))
  121.             {
  122.                 txtCoilsCount.Focus();
  123.                 MessageBox.Show("线圈数量只能为正整数！");
  124.                 return;
  125.             }
  126.             bool[] reuslt = modbus.ReadCoils(slaveStation, address, len);
  127.             if (reuslt == null) return;
  128.             StringBuilder sb = new StringBuilder();
  129.             foreach (var item in reuslt)
  130.             {
  131.                 if (item)
  132.                 {
  133.                     sb.Append(" 1");
  134.                 }
  135.                 else
  136.                 {
  137.                     sb.Append(" 0");
  138.                 }
  139.             }
  140.             lblCoilsResult.Text = sb.ToString();
  141.         }
  142.         private void txtSlave_TextChanged(object sender, EventArgs e)
  143.         {
  144.             if (!int.TryParse(txtSlave.Text.Trim(), out slaveStation))
  145.             {
  146.                 slaveStation = 10;
  147.             }
  148.         }
  149.         private void btnForced_Click(object sender, EventArgs e)
  150.         {
  151.             int address;
  152.             if (!int.TryParse(txtCoilsWriteAdress.Text.Trim(), out address))
  153.             {
  154.                 txtCoilsWriteAdress.Focus();
  155.                 MessageBox.Show("线圈写入地址错误！");
  156.                 return;
  157.             }
  158.             if (btnForced.Text.Equals("ON"))
  159.             {
  160.                 bool result = modbus.ForcedCoil(slaveStation, address, false);
  161.                 if (result)
  162.                 {
  163.                     btnForced.Text = "OFF";
  164.                     btnForced.BackColor = Color.Red;
  165.                 }
  166.             }
  167.             else
  168.             {
  169.                 bool result = modbus.ForcedCoil(slaveStation, address, true);
  170.                 if (result)
  171.                 {
  172.                     btnForced.Text = "ON";
  173.                     btnForced.BackColor = Color.LightGreen;
  174.                 }
  175.             }
  176.         }
  177.         private void btnRegistersRead_Click(object sender, EventArgs e)
  178.         {
  179.             int address; int len;
  180.             if (!int.TryParse(txtRegistersAdress.Text.Trim(), out address))
  181.             {
  182.                 txtRegistersAdress.Focus();
  183.                 MessageBox.Show("寄存器地址错误！");
  184.                 return;
  185.             }
  186.             if (!int.TryParse(txtRegistersCount.Text.Trim(), out len))
  187.             {
  188.                 txtRegistersCount.Focus();
  189.                 MessageBox.Show("寄存器数量只能为正整数！");
  190.                 return;
  191.             }
  192.             short[] result = modbus.ReadHoldingRegisters(slaveStation, address, len);
  193.             if (result == null) return;
  194.             StringBuilder sb = new StringBuilder();
  195.             foreach (var item in result)
  196.             {
  197.                 sb.Append(" " + item.ToString());
  198.             }
  199.             lblRegistersResult.Text = sb.ToString();
  200.         }
  201.         private void btnReadFloat_Click(object sender, EventArgs e)
  202.         {
  203.             int address; int len;
  204.             if (!int.TryParse(txtRegistersAdress.Text.Trim(), out address))
  205.             {
  206.                 txtRegistersAdress.Focus();
  207.                 MessageBox.Show("寄存器地址错误！");
  208.                 return;
  209.             }
  210.             if (!int.TryParse(txtRegistersCount.Text.Trim(), out len))
  211.             {
  212.                 txtRegistersCount.Focus();
  213.                 MessageBox.Show("寄存器数量只能为正整数！");
  214.                 return;
  215.             }
  216.             float[] result = modbus.ReadFloatRegisters(slaveStation, address, len);
  217.             if (result == null) return;
  218.             StringBuilder sb = new StringBuilder();
  219.             foreach (var item in result)
  220.             {
  221.                 sb.Append(" " + item.ToString());
  222.             }
  223.             lblRegistersResult.Text = sb.ToString();
  224.         }
  225.         private void btnWriteShort_Click(object sender, EventArgs e)
  226.         {
  227.             int address; short val;
  228.             if (!int.TryParse(txtWriteShortAdress.Text.Trim(), out address))
  229.             {
  230.                 txtWriteShortAdress.Focus();
  231.                 MessageBox.Show("寄存器地址错误！");
  232.                 return;
  233.             }
  234.             if (!short.TryParse(txtWriteShortVal.Text.Trim(), out val))
  235.             {
  236.                 txtWriteShortVal.Focus();
  237.                 MessageBox.Show("写入的值只能为正整数！");
  238.                 return;
  239.             }
  240.             if (modbus.WriteSingleRegister(slaveStation, address, val))
  241.             {
  242.                 MessageBox.Show("Short数已成功写入");
  243.             }
  244.             else
  245.             {
  246.                 MessageBox.Show("Short数写入失败");
  247.             }
  248.         }
  249.         private void btnWriteFloat_Click(object sender, EventArgs e)
  250.         {
  251.             int address; float val;
  252.             if (!int.TryParse(txtFloatWriteAddress.Text.Trim(), out address))
  253.             {
  254.                 txtFloatWriteAddress.Focus();
  255.                 MessageBox.Show("寄存器地址错误！");
  256.                 return;
  257.             }
  258.             if (!float.TryParse(txtWriteFloatVal.Text.Trim(), out val))
  259.             {
  260.                 txtWriteFloatVal.Focus();
  261.                 MessageBox.Show("写入的值只能为正整数！");
  262.                 return;
  263.             }
  264.             if (modbus.WriteFloatRegister(slaveStation, address, val))
  265.             {
  266.                 MessageBox.Show("Float数已成功写入");
  267.             }
  268.             else
  269.             {
  270.                 MessageBox.Show("Float数写入失败");
  271.             }
  272.         }
  273.         //给线圈批量赋值
  274.         private void btnBatch_Click(object sender, EventArgs e)
  275.         {
  276.             int address; short val;
  277.             if (!int.TryParse(txtCoils.Text.Trim(), out address))
  278.             {
  279.                 txtCoils.Focus();
  280.                 MessageBox.Show("线圈地址错误！");
  281.                 return;
  282.             }
  283.             if (!short.TryParse(txtCoilsVal.Text.Trim(), out val))
  284.             {
  285.                 txtCoilsVal.Focus();
  286.                 MessageBox.Show("写入的值只能为正整数！");
  287.                 return;
  288.             }
  289.             bool result = modbus.WriteMultipleCoils(slaveStation, address, 16, new short[] { val });
  290.             if (result)
  291.             {
  292.                 MessageBox.Show("线圈已批量写入");
  293.             }
  294.             else
  295.             {
  296.                 MessageBox.Show("线圈批量失败");
  297.             }
  298.         }
  299.         private void btnMulShortWrite_Click(object sender, EventArgs e)
  300.         {
  301.             int address; short val; int len;
  302.             if (!int.TryParse(txtMulAdress.Text.Trim(), out address))
  303.             {
  304.                 txtMulAdress.Focus();
  305.                 MessageBox.Show("寄存器地址错误！");
  306.                 return;
  307.             }
  308.             if (!short.TryParse(txtMulShortVal.Text.Trim(), out val))
  309.             {
  310.                 txtMulShortVal.Focus();
  311.                 MessageBox.Show("写入的值只能为正整数！");
  312.                 return;
  313.             }
  314.             if (!int.TryParse(txtMulCount.Text.Trim(), out len))
  315.             {
  316.                 txtMulCount.Focus();
  317.                 MessageBox.Show("寄存器数量只能为正整数！");
  318.                 return;
  319.             }
  320.             if (modbus.WriteMultipleRegisters(slaveStation, address, len, Enumerable.Repeat(val, len).ToArray()))
  321.             {
  322.                 MessageBox.Show("寄存器已批量写入");
  323.             }
  324.             else
  325.             {
  326.                 MessageBox.Show("寄存器批量写入失败");
  327.             }
  328.         }
  329.  
  330.         private void comboPortName_DropDown(object sender, EventArgs e)
  331.         {
  332.             comboPortName.DataSource = SerialPort.GetPortNames();
  333.         }
  334.     }
3.6.4，Modbus类
  1.  public class ModbusSerial : IDisposable
  2.     {
  3.         SerialPort serialPortObject = null;
  4.         /// <summary>
  5.         /// 目标站点号
  6.         /// </summary>
  7.         int targetStation = 0;
  8.         /// <summary>
  9.         /// 消息接收到标志位
  10.         /// </summary>
  11.         bool msgRecFlag = false;
  12.         /// <summary>
  13.         /// 接收到有效的数据
  14.         /// </summary>
  15.         byte[] RecBytes = null;
  16.         AutoResetEvent slim = new AutoResetEvent(true);
  17.         /// <summary>
  18.         /// 返回的异常信息
  19.         /// </summary>
  20.         public event Action<int, string> ErrorMessage;
  21.         /// <summary>
  22.         /// 构建基于SerialPort的Modbus
  23.         /// </summary>
  24.         /// <param name="baudRate">波特率</param>
  25.         /// <param name="dataBits">数据位</param>
  26.         /// <param name="parity">校验位</param>
  27.         /// <param name="stopBits">停止位</param>
  28.         public ModbusSerial(int baudRate, int dataBits, Parity parity, StopBits stopBits)
  29.         {
  30.             serialPortObject = new SerialPort();
  31.             serialPortObject.BaudRate = baudRate;
  32.             serialPortObject.DataBits = dataBits;
  33.             serialPortObject.Parity = parity;
  34.             serialPortObject.StopBits = stopBits;
  35.             serialPortObject.DataReceived += SerialPortObject_DataReceived;
  36.         }
  37.         /// <summary>
  38.         /// 该构造方法需通过属性设置串口参数
  39.         /// </summary>
  40.         public ModbusSerial()
  41.         {
  42.             serialPortObject = new SerialPort();
  43.             serialPortObject.DataReceived += SerialPortObject_DataReceived;
  44.         }
  45.         ModbusSerial(SerialPort port)
  46.         {
  47.             serialPortObject = port;
  48.             serialPortObject.DataReceived += SerialPortObject_DataReceived;
  49.  
  50.         }
  51.         static ModbusSerial modbus;
  52.         /// <summary>
  53.         /// 获取Modbus
  54.         /// </summary>
  55.         /// <param name="port"></param>
  56.         /// <returns></returns>
  57.         public static ModbusSerial CreateModbus(SerialPort port)
  58.         {
  59.             if (modbus == null)
  60.             {
  61.                 modbus = new ModbusSerial(port);
  62.             }
  63.             return modbus;
  64.         }
  65.         private void SerialPortObject_DataReceived(object sender, SerialDataReceivedEventArgs e)
  66.         {
  67.  
  68.             int num = serialPortObject.BytesToRead;
  69.  
  70.             if (num == 0) return;
  71.             byte[] bytes = new byte[num];
  72.             //需要通过事件监听不可采用循环阻塞接收，如果采用循环阻塞将抛出异常
  73.             serialPortObject.Read(bytes, 0, num);
  74.             //对消息进行解析
  75.             //检查报文是否正确
  76.             msgRecFlag = true;
  77.             byte[] checkSum = Checkhelper.CrcModbus(bytes, 0, bytes.Length - 2);
  78.             if (checkSum[0] == bytes[bytes.Length - 1] && checkSum[1] == bytes[bytes.Length - 2])
  79.             {
  80.                 //验证通过
  81.                 byte stationNo = bytes[0];
  82.                 targetStation = stationNo;
  83.                 byte commandCode = bytes[1];
  84.                 if (commandCode > 80)
  85.                 {
  86.                     //异常信息
  87.                     ErrorCode errorCode = (ErrorCode)bytes[2];
  88.                     //这里使用异步调用如果使用同步调用将大大增加阻塞时间导致后面的AutoResetEvent等待超时
  89.                     ErrorMessage?.BeginInvoke(stationNo, errorCode.ToString(), null, null);
  90.                 }
  91.                 else
  92.                 {
  93.                     FunctionCode function = (FunctionCode)commandCode;
  94.                     byte length = bytes[2];
  95.                     switch (function)
  96.                     {
  97.                         case FunctionCode.ReadCoils:
  98.                         case FunctionCode.ReadDiscreteInputs:
  99.                             //返回字节长度
  100.                             RecBytes = new byte[length];
  101.                             Array.Copy(bytes, 3, RecBytes, 0, length);
  102.  
  103.                             break;
  104.                         case FunctionCode.ReadHoldingRegisters:
  105.                         case FunctionCode.ReadInputRegisters:
  106.                             //读取寄存器数据
  107.                             RecBytes = new byte[length];
  108.                             Array.Copy(bytes, 3, RecBytes, 0, length);
  109.  
  110.                             break;
  111.                         case FunctionCode.WriteSingleCoil:
  112.  
  113.                         case FunctionCode.WriteSingleRegister:
  114.  
  115.                         case FunctionCode.WriteMultipleCoils:
  116.  
  117.                         case FunctionCode.WriteMultipleRegisters:
  118.                             RecBytes = new byte[4];
  119.                             Array.Copy(bytes, 2, RecBytes, 0, RecBytes.Length);
  120.                             break;
  121.                         case FunctionCode.ReportSlaveID:
  122.                             break;
  123.                         case FunctionCode.MaskWriteRegister:
  124.                             break;
  125.                         case FunctionCode.ReadWriteRegister:
  126.                             break;
  127.                         default:
  128.                             break;
  129.                     }
  130.                 }
  131.             }
  132.             else
  133.             {
  134.                 ErrorMessage?.BeginInvoke(0, "报文校验未通过，可能传送中收到干扰！", null, null);
  135.             }
  136.             //接收完成，取消主线程阻塞
  137.             slim.Set();
  138.         }
  139.         /// <summary>
  140.         /// 串口波特率
  141.         /// </summary>
  142.         public int BaudRate
  143.         {
  144.             get
  145.             {
  146.                 return serialPortObject.BaudRate;
  147.             }
  148.             set
  149.             {
  150.                 serialPortObject.BaudRate = value;
  151.             }
  152.         }
  153.         /// <summary>
  154.         /// 数据位长度
  155.         /// </summary>
  156.         public int DataBits
  157.         {
  158.             get
  159.             {
  160.                 return serialPortObject.DataBits;
  161.             }
  162.             set
  163.             {
  164.                 serialPortObject.DataBits = value;
  165.             }
  166.         }
  167.         /// <summary>
  168.         /// 奇偶校验协议
  169.         /// </summary>
  170.         public Parity Parity
  171.         {
  172.             get
  173.             {
  174.                 return serialPortObject.Parity;
  175.             }
  176.             set
  177.             {
  178.                 serialPortObject.Parity = value;
  179.             }
  180.         }
  181.         /// <summary>
  182.         /// 停止位
  183.         /// </summary>
  184.         public StopBits StopBits
  185.         {
  186.             get
  187.             {
  188.                 return serialPortObject.StopBits;
  189.             }
  190.             set
  191.             {
  192.                 serialPortObject.StopBits = value;
  193.             }
  194.         }
  195.         /// <summary>
  196.         /// 当前的SerialPort对象
  197.         /// </summary>
  198.         public SerialPort SerialPortObject
  199.         {
  200.             get
  201.             {
  202.                 return serialPortObject;
  203.             }
  204.  
  205.         }
  206.         /// <summary>
  207.         /// 获取计算机所有的串行端口
  208.         /// </summary>
  209.         public string[] SerialPorts
  210.         {
  211.             get
  212.             {
  213.                 return SerialPort.GetPortNames();
  214.             }
  215.         }
  216.         /// <summary>
  217.         /// 打开指定的串口
  218.         /// </summary>
  219.         /// <param name="serialPortName"></param>
  220.         public void Open(string serialPortName)
  221.         {
  222.             if (serialPortObject.IsOpen)
  223.             {
  224.                 serialPortObject.Close();
  225.             }
  226.             serialPortObject.PortName = serialPortName;
  227.             serialPortObject.Open();
  228.         }
  229.         /// <summary>
  230.         /// 关闭串口
  231.         /// </summary>
  232.         public void Close()
  233.         {
  234.             if (serialPortObject.IsOpen)
  235.             {
  236.                 serialPortObject.Close();
  237.             }
  238.         }
  239.         /// <summary>
  240.         /// 串口是否打开
  241.         /// </summary>
  242.         public bool IsOpen
  243.         {
  244.             get
  245.             {
  246.                 return serialPortObject.IsOpen;
  247.             }
  248.         }
  249.         /// <summary>
  250.         ///发送报文
  251.         /// </summary>
  252.         /// <param name="bytes"></param>
  253.         /// <param name="protocol">报文协议</param>
  254.         void Send(string sendMsg)
  255.         {
  256.             //对消息进行判断是否合规
  257.             if (!Regex.IsMatch(sendMsg, @"^[0-9a-fA-F]+$"))
  258.             {
  259.                 throw new Exception("报文错误，存在非16进制字符");
  260.             }
  261.             byte[] bytes = new byte[sendMsg.Length / 2];
  262.             for (int i = 0; i < sendMsg.Length / 2; i++)
  263.             {
  264.                 bytes[i] = Convert.ToByte(sendMsg.Substring(i * 2, 2), 16);
  265.             }
  266.             //添加校验码，并发送
  267.             byte[] checkSum = Checkhelper.CrcModbus(bytes, 0, bytes.Length);
  268.             var checkarr = checkSum.Reverse().ToArray();
  269.             byte[] msgBytes = new byte[bytes.Length + checkSum.Length];
  270.             Array.Copy(bytes, msgBytes, bytes.Length);
  271.             Array.Copy(checkarr, 0, msgBytes, bytes.Length, checkarr.Length);
  272.             serialPortObject.Write(msgBytes, 0, msgBytes.Length);
  273.         }
  274.         /// <summary>
  275.         /// 编制报文
  276.         /// </summary>
  277.         /// <param name="slaveStation">从站站号</param>
  278.         /// <param name="function">功能代码</param>
  279.         /// <param name="devAdress">起始地址</param>
  280.         /// <param name="devLenght">数量</param>
  281.         /// <param name="values">写入的值</param>
  282.         ///  /// <param name="fromBase">如果写入的数值类型所占用的byte，例如short类型为2，int类型为4，flost类型为4，double类型为8</param>
  283.         /// <param name="set">强制线圈通断，true：ON ;false:OFF</param>
  284.         void ComposeMessage(int slaveStation, FunctionCode function, int devAdress, int devLenght = 1, byte[] values = null, int fromBase = 2, bool set = false)
  285.         {
  286.             lock (this)
  287.             {
  288.                 slim.Reset();
  289.                 StringBuilder sb = new StringBuilder();
  290.                 //添加从站点,功能代码，起始位置
  291.                 sb.AppendFormat("{0}{1}{2}", slaveStation.ToString("x2"), ((int)function).ToString("X2"), devAdress.ToString("X4"));
  292.                 switch (function)
  293.                 {
  294.                     case FunctionCode.ReadCoils:
  295.                     case FunctionCode.ReadDiscreteInputs:
  296.                     case FunctionCode.ReadHoldingRegisters:
  297.                     case FunctionCode.ReadInputRegisters:
  298.                         //读取的数量,占用2byte
  299.                         sb.Append(devLenght.ToString("X4"));
  300.                         break;
  301.                     case FunctionCode.WriteSingleCoil:
  302.                         if (set)
  303.                         {
  304.                             //线圈置ON
  305.                             sb.Append("FF00");
  306.                         }
  307.                         else
  308.                         {
  309.                             //线圈置OFF
  310.                             sb.Append("0000");
  311.                         }
  312.                         break;
  313.                     case FunctionCode.WriteSingleRegister:
  314.                         //向单个寄存器写入值,占用两个byte
  315.                         int curVal = BitConverter.ToInt16(values, 0);
  316.                         sb.Append(curVal.ToString("X4"));
  317.                         break;
  318.                     case FunctionCode.WriteMultipleCoils:
  319.                         //向多个线圈写入值
  320.                         //1,需操作的线圈数量,数值占用两个byte
  321.                         sb.Append(devLenght.ToString("X4"));
  322.                         //2,需要操作的寄存器占用的字节数，数值占用1个byte
  323.                         sb.Append(((int)Math.Ceiling(devLenght * 1.0 / 8)).ToString("X2"));
  324.                         //3,写入线圈状态值
  325.                         foreach (var item in values)
  326.                         {
  327.                             sb.Append(item.ToString("X2"));
  328.                         }
  329.                         break;
  330.                     case FunctionCode.WriteMultipleRegisters:
  331.                         //向多个寄存器写入值
  332.                         //1,需操作的寄存器数量,数值占用两个byte
  333.                         sb.Append((values.Length * 2 / fromBase).ToString("X4"));
  334.                         //2,需要操作的寄存器占用的字节数，数值占用1个byte
  335.                         sb.Append((values.Length).ToString("X2"));
  336.                         //3,写入寄存器的值,根据frombase判定值
  337.                         //此时姑且以占2个Byte计算
  338.                         for (int i = 0; i < values.Length; i++)
  339.                         {
  340.                             sb.Append(values[i].ToString("X2"));
  341.                         }
  342.                         break;
  343.                     case FunctionCode.ReportSlaveID:
  344.                         break;
  345.                     case FunctionCode.MaskWriteRegister:
  346.                         break;
  347.                     case FunctionCode.ReadWriteRegister:
  348.                         break;
  349.                     default:
  350.                         break;
  351.                 }
  352.  
  353.  
  354.                 RecBytes = null;
  355.                 Send(sb.ToString().Trim());
  356.                 serialPortObject.DiscardInBuffer();
  357.                 //100ms等待消息回复
  358.                 msgRecFlag = slim.WaitOne(3000);
  359.  
  360.                 System.Threading.Thread.Sleep(20);
  361.                 if (!msgRecFlag)
  362.                 {
  363.                     ErrorMessage?.Invoke(slaveStation, $"从站：{slaveStation}，回复超时");
  364.                 }
  365.             }
  366.  
  367.         }
  368.         /// <summary>
  369.         /// 强制指定单个线圈动作
  370.         /// </summary>
  371.         /// <param name="slaveStationNo">从站站号</param>
  372.         /// <param name="devAdress">线圈地址</param>
  373.         /// <param name="onOrOff">True为ON，false为Off</param>
  374.         /// <returns></returns>
  375.         public bool ForcedCoil(int slaveStationNo, int devAdress, bool set)
  376.         {
  377.             ComposeMessage(slaveStationNo, FunctionCode.WriteSingleCoil, devAdress, set: set);
  378.             if (slaveStationNo == targetStation && msgRecFlag && RecBytes != null)
  379.             {
  380.                 if (RecBytes[2] == 0xff && RecBytes[3] == 0 && set)
  381.                 {
  382.                     return true;
  383.                 }
  384.                 if (RecBytes[3] == 0 && RecBytes[2] == 0 && !set)
  385.                 {
  386.                     return true;
  387.  
  388.  
  389.                 }
  390.             }
  391.  
  392.             return false;
  393.         }
  394.         /// <summary>
  395.         /// 读取多个线圈状态
  396.         /// </summary>
  397.         /// <param name="slaveStationNo"></param>
  398.         /// <param name="devAdress"></param>
  399.         /// <param name="iLenght"></param>
  400.         public bool[] ReadCoils(int slaveStationNo, int devAdress, int iLenght)
  401.         {
  402.             ComposeMessage(slaveStationNo, FunctionCode.ReadCoils, devAdress, iLenght);
  403.             if (slaveStationNo == targetStation && msgRecFlag && RecBytes != null)
  404.             {
  405.                 BitArray array = new BitArray(RecBytes);
  406.                 if (iLenght > array.Count)
  407.                 {
  408.                     throw new Exception("线圈查询结果异常！");
  409.                 }
  410.                 bool[] coils = new bool[iLenght];
  411.                 for (int i = 0; i < iLenght; i++)
  412.                 {
  413.                     coils[i] = array[i];
  414.                 }
  415.                 return coils;
  416.             }
  417.             else
  418.             {
  419.                 return null;
  420.             }
  421.         }
  422.         /// <summary>
  423.         /// 向多个线圈写入值
  424.         /// </summary>
  425.         /// <param name="slaveStationNo">从站站号</param>
  426.         /// <param name="devAdress"></param>
  427.         /// <param name="iLenght">地址长度</param>
  428.         /// <param name="arr">写入的值</param>
  429.         public bool WriteMultipleCoils(int slaveStationNo, int devAdress, int iLenght, short[] arr)
  430.         {
  431.             if ((int)Math.Ceiling(iLenght * 1.0 / 16) != arr.Length)
  432.             {
  433.                 throw new Exception("线圈数量与所赋值数量不匹配");
  434.             }
  435.             byte[] bytes = new byte[arr.Length * 2];
  436.             int index = 0;
  437.             foreach (var item in arr)
  438.             {
  439.                 byte[] temBytes = BitConverter.GetBytes(item);
  440.                 Array.Copy(temBytes, 0, bytes, index, temBytes.Length);
  441.                 index += temBytes.Length;
  442.             }
  443.             ComposeMessage(slaveStationNo, FunctionCode.WriteMultipleCoils, devAdress, iLenght, bytes);
  444.             if (slaveStationNo == targetStation && msgRecFlag && RecBytes != null && RecBytes.Length == 4)
  445.             {
  446.                 int startAddress = BitConverter.ToInt16(new byte[] { RecBytes[1], RecBytes[0] }, 0);
  447.                 int addressLen = BitConverter.ToInt16(new byte[] { RecBytes[3], RecBytes[2] }, 0);
  448.  
  449.                 if (startAddress == devAdress && addressLen == iLenght)
  450.                 {
  451.                     return true;
  452.                 }
  453.                 else
  454.                 {
  455.                     return false;
  456.                 }
  457.             }
  458.             else
  459.             {
  460.                 return false;
  461.             }
  462.         }
  463.         /// <summary>
  464.         /// 读取从站多个寄存器的值
  465.         /// </summary>
  466.         /// <param name="slaveStationNo"></param>
  467.         /// <param name="devAdress">起始寄存器</param>
  468.         /// <param name="iLenght">寄存器数量</param>
  469.         public short[] ReadHoldingRegisters(int slaveStationNo, int devAdress, int iLenght)
  470.         {
  471.             ComposeMessage(slaveStationNo, FunctionCode.ReadHoldingRegisters, devAdress, iLenght);
  472.             if (slaveStationNo == targetStation && msgRecFlag && RecBytes != null)
  473.             {
  474.                 List<short> shortList = new List<short>();
  475.                 for (int i = 0; i < RecBytes.Length; i += 2)
  476.                 {
  477.                     shortList.Add(BitConverter.ToInt16(new byte[] { RecBytes[i + 1], RecBytes[i] }, 0));
  478.                 }
  479.                 return shortList.ToArray();
  480.             }
  481.             else
  482.             {
  483.                 return null;
  484.             }
  485.         }
  486.         /// <summary>
  487.         /// 读取单精度浮点数
  488.         /// </summary>
  489.         /// <param name="slaveStationNo">从站站点</param>
  490.         /// <param name="devAdress">起始地址</param>
  491.         /// <param name="iLenght">连续读取浮点数的个数</param>
  492.         /// <returns></returns>
  493.         public float[] ReadFloatRegisters(int slaveStationNo, int devAdress, int iLenght)
  494.         {
  495.             ComposeMessage(slaveStationNo, FunctionCode.ReadHoldingRegisters, devAdress, iLenght * 2);
  496.             if (slaveStationNo == targetStation && msgRecFlag && RecBytes != null)
  497.             {
  498.                 List<float> floatList = new List<float>();
  499.                 for (int i = 0; i < RecBytes.Length; i += 4)
  500.                 {
  501.                     floatList.Add(BitConverter.ToSingle(new byte[] { RecBytes[i + 1], RecBytes[i], RecBytes[i + 3], RecBytes[i + 2] }, 0));
  502.                 }
  503.                 return floatList.ToArray();
  504.             }
  505.             else
  506.             {
  507.                 return null;
  508.             }
  509.         }
  510.         /// <summary>
  511.         /// 向从站单个寄存器写入值
  512.         /// </summary>
  513.         /// <param name="slaveStationNo"></param>
  514.         /// <param name="devAdress"></param>
  515.         /// <param name="value"></param>
  516.         public bool WriteSingleRegister(int slaveStationNo, int devAdress, short value)
  517.         {
  518.             ComposeMessage(slaveStationNo, FunctionCode.WriteSingleRegister, devAdress, values: BitConverter.GetBytes(value));
  519.             if (slaveStationNo == targetStation && msgRecFlag && RecBytes != null && RecBytes.Length == 4)
  520.             {
  521.                 int startAddress = BitConverter.ToInt16(new byte[] { RecBytes[1], RecBytes[0] }, 0);
  522.                 int val = BitConverter.ToInt16(new byte[] { RecBytes[3], RecBytes[2] }, 0);
  523.                 if (startAddress == devAdress && val == value)
  524.                 {
  525.                     return true;
  526.                 }
  527.                 else
  528.                 {
  529.                     return false;
  530.                 }
  531.             }
  532.             else
  533.             {
  534.                 return false;
  535.             }
  536.         }
  537.         /// <summary>
  538.         /// 写入单精度浮点数
  539.         /// </summary>
  540.         /// <param name="slaveStationNo">从站站点</param>
  541.         /// <param name="devAdress">寄存器地址</param>
  542.         /// <param name="value">值</param>
  543.         /// <returns>true写入成功，false写入失败</returns>
  544.         public bool WriteFloatRegister(int slaveStationNo, int devAdress, float value)
  545.         {
  546.             //进行拆解组合
  547.             byte[] bytes = BitConverter.GetBytes(value);
  548.             byte[] valBytes = new byte[] { bytes[1], bytes[0], bytes[3], bytes[2] };
  549.             ComposeMessage(slaveStationNo, FunctionCode.WriteMultipleRegisters, devAdress, values: valBytes, fromBase: 4);
  550.             if (slaveStationNo == targetStation && msgRecFlag && RecBytes != null)
  551.             {
  552.                 short adress = BitConverter.ToInt16(new byte[] { RecBytes[1], RecBytes[0] }, 0);
  553.                 short registerCount = BitConverter.ToInt16(new byte[] { RecBytes[3], RecBytes[2] }, 0);
  554.                 if (adress == devAdress && registerCount == 2)
  555.                 {
  556.                     return true;
  557.                 }
  558.                 else
  559.                 {
  560.                     return false;
  561.                 }
  562.             }
  563.             else
  564.             {
  565.                 return false;
  566.             }
  567.         }
  568.         /// <summary>
  569.         /// 向从站多个寄存器写入值
  570.         /// </summary>
  571.         /// <param name="slaveStationNo"></param>
  572.         /// <param name="devAdress"></param>
  573.         /// <param name="iLenght"></param>
  574.         /// <param name="arr"></param>
  575.         public bool WriteMultipleRegisters(int slaveStationNo, int devAdress, int iLenght, short[] arr)
  576.         {
  577.             if (iLenght != arr.Length)
  578.             {
  579.                 throw new Exception("寄存器数量与所赋值数量不匹配");
  580.             }
  581.             byte[] bytes = new byte[arr.Length * 2];
  582.             int index = 0;
  583.             foreach (var item in arr)
  584.             {
  585.                 byte[] temBytes = BitConverter.GetBytes(item);
  586.                 byte[] temBytes2 = new byte[] { temBytes[1], temBytes[0] };
  587.                 Array.Copy(temBytes2, 0, bytes, index, temBytes2.Length);
  588.                 index += temBytes.Length;
  589.             }
  590.             ComposeMessage(slaveStationNo, FunctionCode.WriteMultipleRegisters, devAdress, iLenght, bytes, fromBase: 4);
  591.             if (slaveStationNo == targetStation && msgRecFlag && RecBytes != null && RecBytes.Length == 4)
  592.             {
  593.                 int startAddress = BitConverter.ToInt16(new byte[] { RecBytes[1], RecBytes[0] }, 0);
  594.                 int addressLen = BitConverter.ToInt16(new byte[] { RecBytes[3], RecBytes[2] }, 0);
  595.                 if (startAddress == devAdress && addressLen == iLenght)
  596.                 {
  597.                     return true;
  598.                 }
  599.                 else
  600.                 {
  601.                     return false;
  602.                 }
  603.             }
  604.             else
  605.             {
  606.                 return false;
  607.             }
  608.         }
  609.         public void Dispose()
  610.         {
  611.             serialPortObject?.Dispose();
  612.         }
  613. ｝
3.6.5，校验码类
  1. /// <summary>
  2.     /// 数据校验帮助类，计算常见的CRC校验；LRC校验；BCC校验；累加和校验
  3.     /// </summary>
  4.     public class Checkhelper
  5.     {
  6.         #region CRC校验说明
  7.         // CRC即循环冗余校验码（Cyclic Redundancy Check）：是数据通信领域中最常用的一种查错校验码，
  8.         //其特征是信息字段和校验字段的长度可以任意选定。循环冗余检查（CRC）是一种数据传输检错功能，对数据进行多项式计算，
  9.         //并将得到的结果附在帧的后面，接收设备也执行类似的算法，以保证数据传输的正确性和完整性。
  10.  
  11.         // CRC算法参数模型解释：
  12.         // NAME：参数模型名称。
  13.         //WIDTH：宽度，即CRC比特数。
  14.         // POLY：生成项的简写，以16进制表示。例如：CRC-32即是0x04C11DB7，忽略了最高位的"1"，即完整的生成项是0x104C11DB7。
  15.         //INIT：这是算法开始时寄存器（crc）的初始化预置值，十六进制表示。
  16.         //REFIN：待测数据的每个字节是否按位反转，True或False。
  17.         // REFOUT：在计算后之后，异或输出之前，整个数据是否按位反转，True或False。
  18.         // XOROUT：计算结果与此参数异或后得到最终的CRC值。
  19.         #endregion
  20.         // **********************************************************************
  21.         // Name: CRC-4/ITU    x4+x+1
  22.         // Poly: 0x03
  23.         // Init: 0x00
  24.         // Refin: true
  25.         // Refout: true
  26.         // Xorout: 0x00
  27.         //*************************************************************************
  28.  
  29.         /// <summary>
  30.         /// CRC-4/ITU
  31.         /// </summary>
  32.         /// <param name="buffer"></param>
  33.         /// <param name="start"></param>
  34.         /// <param name="len"></param>
  35.         /// <returns></returns>
  36.         public static byte[] Crc1(byte[] buffer, int start = 0, int len = 0)
  37.         {
  38.             if (buffer == null || buffer.Length == 0) return null;
  39.             if (start < 0) return null;
  40.             if (len == 0) len = buffer.Length - start;
  41.             int length = start + len;
  42.             if (length > buffer.Length) return null;
  43.             byte crc = 0;// Initial value
  44.             for (int i = start; i < length; i++)
  45.             {
  46.                 crc ^= buffer[i];
  47.                 for (int j = 0; j < 8; j++)
  48.                 {
  49.                     if ((crc & 1) > 0)
  50.                         crc = (byte)((crc >> 1) ^ 0x0C);//0x0C = (reverse 0x03)>>(8-4)
  51.                     else
  52.                         crc = (byte)(crc >> 1);
  53.                 }
  54.             }
  55.             return new byte[] { crc };
  56.         }
  57.         // **********************************************************************
  58.         // Name: CRC-5/EPC    x5+x3+1
  59.         // Poly: 0x09
  60.         // Init: 0x09
  61.         // Refin: false
  62.         // Refout: false
  63.         // Xorout: 0x00
  64.         //*************************************************************************
  65.         /// <summary>
  66.         /// CRC-5/EPC
  67.         /// </summary>
  68.         /// <param name="buffer"></param>
  69.         /// <param name="start"></param>
  70.         /// <param name="len"></param>
  71.         /// <returns></returns>
  72.         public static byte[] Crc2(byte[] buffer, int start = 0, int len = 0)
  73.         {
  74.             if (buffer == null || buffer.Length == 0) return null;
  75.             if (start < 0) return null;
  76.             if (len == 0) len = buffer.Length - start;
  77.             int length = start + len;
  78.             if (length > buffer.Length) return null;
  79.             byte crc = 0x48;// Initial value: 0x48 = 0x09<<(8-5)
  80.             for (int i = start; i < length; i++)
  81.             {
  82.                 crc ^= buffer[i];
  83.                 for (int j = 0; j < 8; j++)
  84.                 {
  85.                     if ((crc & 0x80) > 0)
  86.                         crc = (byte)((crc << 1) ^ 0x48);// 0x48 = 0x09<<(8-5)
  87.                     else
  88.                         crc = (byte)(crc << 1);
  89.                 }
  90.             }
  91.             return new byte[] { (byte)(crc >> 3) };
  92.         }
  93.         // **********************************************************************
  94.         // Name: CRC-5/ITU    x5+x4+x2+1
  95.         // Poly: 0x15
  96.         // Init: 0x00
  97.         // Refin: true
  98.         // Refout: true
  99.         // Xorout: 0x00
  100.         //*************************************************************************
  101.         /// <summary>
  102.         /// CRC-5/ITU 
  103.         /// </summary>
  104.         /// <param name="buffer"></param>
  105.         /// <param name="start"></param>
  106.         /// <param name="len"></param>
  107.         /// <returns></returns>
  108.         public static byte[] Crc3(byte[] buffer, int start = 0, int len = 0)
  109.         {
  110.             if (buffer == null || buffer.Length == 0) return null;
  111.             if (start < 0) return null;
  112.             if (len == 0) len = buffer.Length - start;
  113.             int length = start + len;
  114.             if (length > buffer.Length) return null;
  115.             byte crc = 0;// Initial value
  116.             for (int i = start; i < length; i++)
  117.             {
  118.                 crc ^= buffer[i];
  119.                 for (int j = 0; j < 8; j++)
  120.                 {
  121.                     if ((crc & 1) > 0)
  122.                         crc = (byte)((crc >> 1) ^ 0x15);// 0x15 = (reverse 0x15)>>(8-5)
  123.                     else
  124.                         crc = (byte)(crc >> 1);
  125.                 }
  126.             }
  127.             return new byte[] { crc };
  128.         }
  129.         // **********************************************************************
  130.         // Name: CRC-5/USB    x5+x2+1
  131.         // Poly: 0x05
  132.         // Init: 0x1F
  133.         // Refin: true
  134.         // Refout: true
  135.         // Xorout: 0x1F
  136.         //*************************************************************************
  137.         /// <summary>
  138.         /// CRC-5/USB
  139.         /// </summary>
  140.         /// <param name="buffer"></param>
  141.         /// <param name="start"></param>
  142.         /// <param name="len"></param>
  143.         /// <returns></returns>
  144.         public static byte[] Crc4(byte[] buffer, int start = 0, int len = 0)
  145.         {
  146.             if (buffer == null || buffer.Length == 0) return null;
  147.             if (start < 0) return null;
  148.             if (len == 0) len = buffer.Length - start;
  149.             int length = start + len;
  150.             if (length > buffer.Length) return null;
  151.             byte crc = 0x1F;// Initial value
  152.             for (int i = start; i < length; i++)
  153.             {
  154.                 crc ^= buffer[i];
  155.                 for (int j = 0; j < 8; j++)
  156.                 {
  157.                     if ((crc & 1) > 0)
  158.                         crc = (byte)((crc >> 1) ^ 0x14);// 0x14 = (reverse 0x05)>>(8-5)
  159.                     else
  160.                         crc = (byte)(crc >> 1);
  161.                 }
  162.             }
  163.             return new byte[] { (byte)(crc ^ 0x1F) };
  164.         }
  165.         // **********************************************************************
  166.         // Name: CRC-6/ITU    x6+x+1
  167.         // Poly: 0x03
  168.         // Init: 0x00
  169.         // Refin: true
  170.         // Refout: true
  171.         // Xorout: 0x00
  172.         //*************************************************************************
  173.  
  174.         /// <summary>
  175.         /// CRC-6/ITU
  176.         /// </summary>
  177.         /// <param name="buffer"></param>
  178.         /// <param name="start"></param>
  179.         /// <param name="len"></param>
  180.         /// <returns></returns>
  181.         public static byte[] Crc5(byte[] buffer, int start = 0, int len = 0)
  182.         {
  183.             if (buffer == null || buffer.Length == 0) return null;
  184.             if (start < 0) return null;
  185.             if (len == 0) len = buffer.Length - start;
  186.             int length = start + len;
  187.             if (length > buffer.Length) return null;
  188.             byte crc = 0;// Initial value
  189.             for (int i = start; i < length; i++)
  190.             {
  191.                 crc ^= buffer[i];
  192.                 for (int j = 0; j < 8; j++)
  193.                 {
  194.                     if ((crc & 1) > 0)
  195.                         crc = (byte)((crc >> 1) ^ 0x30);// 0x30 = (reverse 0x03)>>(8-6)
  196.                     else
  197.                         crc = (byte)(crc >> 1);
  198.                 }
  199.             }
  200.             return new byte[] { crc };
  201.         }
  202.         // **********************************************************************
  203.         // Name: CRC-7/MMC    x7+x3+1
  204.         // Poly: 0x09
  205.         // Init: 0x00
  206.         // Refin: false
  207.         // Refout: false
  208.         // Xorout: 0x00
  209.         //*************************************************************************
  210.         /// <summary>
  211.         /// CRC-7/MMC
  212.         /// </summary>
  213.         /// <param name="buffer"></param>
  214.         /// <param name="start"></param>
  215.         /// <param name="len"></param>
  216.         /// <returns></returns>
  217.         public static byte[] Crc6(byte[] buffer, int start = 0, int len = 0)
  218.         {
  219.             if (buffer == null || buffer.Length == 0) return null;
  220.             if (start < 0) return null;
  221.             if (len == 0) len = buffer.Length - start;
  222.             int length = start + len;
  223.             if (length > buffer.Length) return null;
  224.             byte crc = 0;// Initial value
  225.             for (int i = start; i < length; i++)
  226.             {
  227.                 crc ^= buffer[i];
  228.                 for (int j = 0; j < 8; j++)
  229.                 {
  230.                     if ((crc & 0x80) > 0)
  231.                         crc = (byte)((crc << 1) ^ 0x12);// 0x12 = 0x09<<(8-7)
  232.                     else
  233.                         crc = (byte)(crc << 1);
  234.                 }
  235.             }
  236.             return new byte[] { (byte)(crc >> 1) };
  237.         }
  238.         // **********************************************************************
  239.         // Name: CRC8    x8+x2+x+1
  240.         // Poly: 0x07
  241.         // Init: 0x00
  242.         // Refin: false
  243.         // Refout: false
  244.         // Xorout: 0x00
  245.         //*************************************************************************
  246.         /// <summary>
  247.         /// CRC8 
  248.         /// </summary>
  249.         /// <param name="buffer"></param>
  250.         /// <param name="start"></param>
  251.         /// <param name="len"></param>
  252.         /// <returns></returns>
  253.         public static byte[] Crc7(byte[] buffer, int start = 0, int len = 0)
  254.         {
  255.             if (buffer == null || buffer.Length == 0) return null;
  256.             if (start < 0) return null;
  257.             if (len == 0) len = buffer.Length - start;
  258.             int length = start + len;
  259.             if (length > buffer.Length) return null;
  260.             byte crc = 0;// Initial value
  261.             for (int i = start; i < length; i++)
  262.             {
  263.                 crc ^= buffer[i];
  264.                 for (int j = 0; j < 8; j++)
  265.                 {
  266.                     if ((crc & 0x80) > 0)
  267.                         crc = (byte)((crc << 1) ^ 0x07);
  268.                     else
  269.                         crc = (byte)(crc << 1);
  270.                 }
  271.             }
  272.             return new byte[] { crc };
  273.         }
  274.         // **********************************************************************
  275.         // Name: CRC-8/ITU    x8+x2+x+1
  276.         // Poly: 0x07
  277.         // Init: 0x00
  278.         // Refin: false
  279.         // Refout: false
  280.         // Xorout: 0x55
  281.         //*************************************************************************
  282.  
  283.         /// <summary>
  284.         /// CRC-8/ITU
  285.         /// </summary>
  286.         /// <param name="buffer"></param>
  287.         /// <param name="start"></param>
  288.         /// <param name="len"></param>
  289.         /// <returns></returns>
  290.         public static byte[] Crc8(byte[] buffer, int start = 0, int len = 0)
  291.         {
  292.             if (buffer == null || buffer.Length == 0) return null;
  293.             if (start < 0) return null;
  294.             if (len == 0) len = buffer.Length - start;
  295.             int length = start + len;
  296.             if (length > buffer.Length) return null;
  297.             byte crc = 0;// Initial value
  298.             for (int i = start; i < length; i++)
  299.             {
  300.                 crc ^= buffer[i];
  301.                 for (int j = 0; j < 8; j++)
  302.                 {
  303.                     if ((crc & 0x80) > 0)
  304.                         crc = (byte)((crc << 1) ^ 0x07);
  305.                     else
  306.                         crc = (byte)(crc << 1);
  307.                 }
  308.             }
  309.             return new byte[] { (byte)(crc ^ 0x55) };
  310.         }
  311.         // **********************************************************************
  312.         // Name: CRC-8/MAXIM    x8+x5+x4+1
  313.         // Poly: 0x31
  314.         // Init: 0x00
  315.         // Refin: true
  316.         // Refout: true
  317.         // Xorout: 0x00
  318.         //*************************************************************************
  319.         /// <summary>
  320.         /// CRC-8/MAXIM 
  321.         /// </summary>
  322.         /// <param name="buffer"></param>
  323.         /// <param name="start"></param>
  324.         /// <param name="len"></param>
  325.         /// <returns></returns>
  326.         public static byte[] Crc9(byte[] buffer, int start = 0, int len = 0)
  327.         {
  328.             if (buffer == null || buffer.Length == 0) return null;
  329.             if (start < 0) return null;
  330.             if (len == 0) len = buffer.Length - start;
  331.             int length = start + len;
  332.             if (length > buffer.Length) return null;
  333.             byte crc = 0;// Initial value
  334.             for (int i = start; i < length; i++)
  335.             {
  336.                 crc ^= buffer[i];
  337.                 for (int j = 0; j < 8; j++)
  338.                 {
  339.                     if ((crc & 1) > 0)
  340.                         crc = (byte)((crc >> 1) ^ 0x8C);// 0x8C = reverse 0x31
  341.                     else
  342.                         crc = (byte)(crc >> 1);
  343.                 }
  344.             }
  345.             return new byte[] { crc };
  346.         }
  347.         // **********************************************************************
  348.         // Name: CRC-8/ROHC    x8+x2+x+1
  349.         // Poly: 0x07
  350.         // Init: 0xFF
  351.         // Refin: true
  352.         // Refout: true
  353.         // Xorout: 0x00
  354.         //*************************************************************************
  355.         /// <summary>
  356.         /// CRC-8/ROHC
  357.         /// </summary>
  358.         /// <param name="buffer"></param>
  359.         /// <param name="start"></param>
  360.         /// <param name="len"></param>
  361.         /// <returns></returns>
  362.         public static byte[] Crc10(byte[] buffer, int start = 0, int len = 0)
  363.         {
  364.             if (buffer == null || buffer.Length == 0) return null;
  365.             if (start < 0) return null;
  366.             if (len == 0) len = buffer.Length - start;
  367.             int length = start + len;
  368.             if (length > buffer.Length) return null;
  369.             byte crc = 0xFF;// Initial value
  370.             for (int i = start; i < length; i++)
  371.             {
  372.                 crc ^= buffer[i];
  373.                 for (int j = 0; j < 8; j++)
  374.                 {
  375.                     if ((crc & 1) > 0)
  376.                         crc = (byte)((crc >> 1) ^ 0xE0);// 0xE0 = reverse 0x07
  377.                     else
  378.                         crc = (byte)(crc >> 1);
  379.                 }
  380.             }
  381.             return new byte[] { crc };
  382.         }
  383.         /// Z1协议校验码计算
  384.         static byte[] table = { 0x00, 0x1C, 0x38, 0x24, 0x70, 0x6C, 0x48, 0x54, 0xE0, 0xFC,
  385.                                 0xD8, 0xC4, 0x90, 0x8C, 0xA8, 0xB4, 0xDC, 0xC0, 0xE4, 0xF8,
  386.                                 0xAC, 0xB0, 0x94, 0x88, 0x3C, 0x20, 0x04, 0x18, 0x4C, 0x50,
  387.                                 0x74, 0x68, 0xA4, 0xB8, 0x9C, 0x80, 0xD4, 0xC8, 0xEC, 0xF0,
  388.                                 0x44, 0x58, 0x7C, 0x60, 0x34, 0x28, 0x0C, 0x10, 0x78, 0x64,
  389.                                 0x40, 0x5C, 0x08, 0x14, 0x30, 0x2C, 0x98, 0x84, 0xA0, 0xBC,
  390.                                 0xE8, 0xF4, 0xD0, 0xCC, 0x54, 0x48, 0x6C, 0x70, 0x24, 0x38,
  391.                                 0x1C, 0x00, 0xB4, 0xA8, 0x8C, 0x90, 0xC4, 0xD8, 0xFC, 0xE0,
  392.                                 0x88, 0x94, 0xB0, 0xAC, 0xF8, 0xE4, 0xC0, 0xDC, 0x68, 0x74,
  393.                                 0x50, 0x4C, 0x18, 0x04, 0x20, 0x3C, 0xF0, 0xEC, 0xC8, 0xD4,
  394.                                 0x80, 0x9C, 0xB8, 0xA4, 0x10, 0x0C, 0x28, 0x34, 0x60, 0x7C,
  395.                                 0x58, 0x44, 0x2C, 0x30, 0x14, 0x08, 0x5C, 0x40, 0x64, 0x78,
  396.                                 0xCC, 0xD0, 0xF4, 0xE8, 0xBC, 0xA0, 0x84, 0x98, 0xA8, 0xB4,
  397.                                 0x90, 0x8C, 0xD8, 0xC4, 0xE0, 0xFC, 0x48, 0x54, 0x70, 0x6C,
  398.                                 0x38, 0x24, 0x00, 0x1C, 0x74, 0x68, 0x4C, 0x50, 0x04, 0x18,
  399.                                 0x3C, 0x20, 0x94, 0x88, 0xAC, 0xB0, 0xE4, 0xF8, 0xDC, 0xC0,
  400.                                 0x0C, 0x10, 0x34, 0x28, 0x7C, 0x60, 0x44, 0x58, 0xEC, 0xF0,
  401.                                 0xD4, 0xC8, 0x9C, 0x80, 0xA4, 0xB8, 0xD0, 0xCC, 0xE8, 0xF4,
  402.                                 0xA0, 0xBC, 0x98, 0x84, 0x30, 0x2C, 0x08, 0x14, 0x40, 0x5C,
  403.                                 0x78, 0x64, 0xFC, 0xE0, 0xC4, 0xD8, 0x8C, 0x90, 0xB4, 0xA8,
  404.                                 0x1C, 0x00, 0x24, 0x38, 0x6C, 0x70, 0x54, 0x48, 0x20, 0x3C,
  405.                                 0x18, 0x04, 0x50, 0x4C, 0x68, 0x74, 0xC0, 0xDC, 0xF8, 0xE4,
  406.                                 0xB0, 0xAC, 0x88, 0x94, 0x58, 0x44, 0x60, 0x7C, 0x28, 0x34,
  407.                                 0x10, 0x0C, 0xB8, 0xA4, 0x80, 0x9C, 0xC8, 0xD4, 0xF0, 0xEC,
  408.                                 0x84, 0x98, 0xBC, 0xA0, 0xF4, 0xE8, 0xCC, 0xD0, 0x64, 0x78,
  409.                                 0x5C, 0x40, 0x14, 0x08, 0x2C, 0x30
  410.                               };
  411.         public static byte[] Crc11(byte[] buffer, int start = 0, int len = 0)
  412.         {
  413.             if (buffer == null || buffer.Length == 0) return null;
  414.             if (start < 0) return null;
  415.             if (len == 0) len = buffer.Length - start;
  416.             int length = start + len;
  417.             if (length > buffer.Length) return null;
  418.             int i;
  419.             byte crc = 0x00;
  420.             int tableIndex;
  421.             for (i = start; i < length; i++)
  422.             {
  423.                 tableIndex = crc ^ (buffer[i] & 0xFF);
  424.                 crc = table[tableIndex];
  425.             }
  426.             return new byte[] { crc };
  427.         }
  428.         // **********************************************************************
  429.         // Name: CRC-12    x16+x12+x5+1
  430.         // Poly: 0x80
  431.         // Init: 0x0000
  432.         // Refin: true
  433.         // Refout: true
  434.         // Xorout: 0x0000
  435.         //*************************************************************************
  436.         /// <summary>
  437.         /// CRC-12 
  438.         /// </summary>
  439.         /// <param name="buffer"></param>
  440.         /// <param name="start"></param>
  441.         /// <param name="len"></param>
  442.         /// <returns></returns>
  443.         public static byte[] Crc12(byte[] buffer, int start = 0, int len = 0)
  444.         {
  445.             if (buffer == null || buffer.Length == 0) return null;
  446.             if (start < 0) return null;
  447.             if (len == 0) len = buffer.Length - start;
  448.             int length = start + len;
  449.             if (length > buffer.Length) return null;
  450.             ushort crc = 0;// Initial value
  451.             short iQ = 0, iR = 0;
  452.             for (int i = start; i < length; i++)
  453.             {
  454.                 // 多项式除法
  455.                 // 如果该位为1
  456.                 if ((buffer[i] & (0x80 >> iR)) > 0)
  457.                 {
  458.                     // 则在余数尾部添1否则添0
  459.                     crc |= 0x01;
  460.                 }
  461.                 // 如果12位除数中的最高位为1，则够除
  462.                 if (crc >= 0x1000)
  463.                 {
  464.                     crc ^= 0x180D;
  465.                 }
  466.                 crc <<= 1;
  467.                 iR++;
  468.                 if (8 == iR)
  469.                 {
  470.                     iR = 0;
  471.                     iQ++;
  472.                 }
  473.             }
  474.             // 对后面添加的12个0做处理
  475.             for (int i = 0; i < 12; i++)
  476.             {
  477.                 if (crc >= 0x1000)
  478.                 {
  479.                     crc ^= 0x180D;
  480.                 }
  481.                 crc <<= 1;
  482.             }
  483.             crc >>= 1;
  484.             byte[] ret = BitConverter.GetBytes(crc);
  485.             Array.Reverse(ret);
  486.             return ret;
  487.         }
  488.         // **********************************************************************
  489.         // Name: CRC-16/CCITT    x16+x12+x5+1
  490.         // Poly: 0x1021
  491.         // Init: 0x0000
  492.         // Refin: true
  493.         // Refout: true
  494.         // Xorout: 0x0000
  495.         //*************************************************************************
  496.         /// <summary>
  497.         /// CRC-16/CCITT
  498.         /// </summary>
  499.         /// <param name="buffer"></param>
  500.         /// <param name="start"></param>
  501.         /// <param name="len"></param>
  502.         /// <returns></returns>
  503.         public static byte[] Crc13(byte[] buffer, int start = 0, int len = 0)
  504.         {
  505.             if (buffer == null || buffer.Length == 0) return null;
  506.             if (start < 0) return null;
  507.             if (len == 0) len = buffer.Length - start;
  508.             int length = start + len;
  509.             if (length > buffer.Length) return null;
  510.             ushort crc = 0;// Initial value
  511.             for (int i = start; i < length; i++)
  512.             {
  513.                 crc ^= buffer[i];
  514.                 for (int j = 0; j < 8; j++)
  515.                 {
  516.                     if ((crc & 1) > 0)
  517.                         crc = (ushort)((crc >> 1) ^ 0x8408);// 0x8408 = reverse 0x1021
  518.                     else
  519.                         crc = (ushort)(crc >> 1);
  520.                 }
  521.             }
  522.             byte[] ret = BitConverter.GetBytes(crc);
  523.             Array.Reverse(ret);
  524.             return ret;
  525.         }
  526.         // **********************************************************************
  527.         // Name: CRC-16/CCITT FALSE    x16+x12+x5+1
  528.         // Poly: 0x1021
  529.         // Init: 0xFFFF
  530.         // Refin: false
  531.         // Refout: false
  532.         // Xorout: 0x0000
  533.         //*************************************************************************
  534.         /// <summary>
  535.         /// CRC-16/CCITT FALSE
  536.         /// </summary>
  537.         /// <param name="buffer"></param>
  538.         /// <param name="start"></param>
  539.         /// <param name="len"></param>
  540.         /// <returns></returns>
  541.         public static byte[] Crc14(byte[] buffer, int start = 0, int len = 0)
  542.         {
  543.             if (buffer == null || buffer.Length == 0) return null;
  544.             if (start < 0) return null;
  545.             if (len == 0) len = buffer.Length - start;
  546.             int length = start + len;
  547.             if (length > buffer.Length) return null;
  548.             ushort crc = 0xFFFF;// Initial value
  549.             for (int i = start; i < length; i++)
  550.             {
  551.                 crc ^= (ushort)(buffer[i] << 8);
  552.                 for (int j = 0; j < 8; j++)
  553.                 {
  554.                     if ((crc & 0x8000) > 0)
  555.                         crc = (ushort)((crc << 1) ^ 0x1021);
  556.                     else
  557.                         crc = (ushort)(crc << 1);
  558.                 }
  559.             }
  560.             byte[] ret = BitConverter.GetBytes(crc);
  561.             Array.Reverse(ret);
  562.             return ret;
  563.         }
  564.  
  565.         // **********************************************************************
  566.         // Name: CRC-16/DNP    x16+x13+x12+x11+x10+x8+x6+x5+x2+1
  567.         // Poly: 0x3D65
  568.         // Init: 0x0000
  569.         // Refin: true
  570.         // Refout: true
  571.         // Xorout: 0xFFFF
  572.         //*************************************************************************
  573.         /// <summary>
  574.         /// CRC-16/DNP 
  575.         /// </summary>
  576.         /// <param name="buffer"></param>
  577.         /// <param name="start"></param>
  578.         /// <param name="len"></param>
  579.         /// <returns></returns>
  580.         public static byte[] Crc15(byte[] buffer, int start = 0, int len = 0)
  581.         {
  582.             if (buffer == null || buffer.Length == 0) return null;
  583.             if (start < 0) return null;
  584.             if (len == 0) len = buffer.Length - start;
  585.             int length = start + len;
  586.             if (length > buffer.Length) return null;
  587.             ushort crc = 0;// Initial value
  588.             for (int i = start; i < length; i++)
  589.             {
  590.                 crc ^= buffer[i];
  591.                 for (int j = 0; j < 8; j++)
  592.                 {
  593.                     if ((crc & 1) > 0)
  594.                         crc = (ushort)((crc >> 1) ^ 0xA6BC);// 0xA6BC = reverse 0x3D65
  595.                     else
  596.                         crc = (ushort)(crc >> 1);
  597.                 }
  598.             }
  599.             byte[] ret = BitConverter.GetBytes((ushort)~crc);
  600.             Array.Reverse(ret);
  601.             return ret;
  602.         }
  603.         // **********************************************************************
  604.         // Name: CRC-16/IBM    x16+x15+x2+1
  605.         // Poly: 0x8005
  606.         // Init: 0x0000
  607.         // Refin: true
  608.         // Refout: true
  609.         // Xorout: 0x0000
  610.         //*************************************************************************
  611.         /// <summary>
  612.         /// CRC-16/IBM
  613.         /// </summary>
  614.         /// <param name="buffer"></param>
  615.         /// <param name="start"></param>
  616.         /// <param name="len"></param>
  617.         /// <returns></returns>
  618.         public static byte[] Crc16(byte[] buffer, int start = 0, int len = 0)
  619.         {
  620.             if (buffer == null || buffer.Length == 0) return null;
  621.             if (start < 0) return null;
  622.             if (len == 0) len = buffer.Length - start;
  623.             int length = start + len;
  624.             if (length > buffer.Length) return null;
  625.             ushort crc = 0;// Initial value
  626.             for (int i = start; i < length; i++)
  627.             {
  628.                 crc ^= buffer[i];
  629.                 for (int j = 0; j < 8; j++)
  630.                 {
  631.                     if ((crc & 1) > 0)
  632.                         crc = (ushort)((crc >> 1) ^ 0xA001);// 0xA001 = reverse 0x8005
  633.                     else
  634.                         crc = (ushort)(crc >> 1);
  635.                 }
  636.             }
  637.             byte[] ret = BitConverter.GetBytes(crc);
  638.             Array.Reverse(ret);
  639.             return ret;
  640.         }
  641.         // **********************************************************************
  642.         // Name: CRC-16/MAXIM    x16+x15+x2+1
  643.         // Poly: 0x8005
  644.         // Init: 0x0000
  645.         // Refin: true
  646.         // Refout: true
  647.         // Xorout: 0xFFFF
  648.         //*************************************************************************
  649.         /// <summary>
  650.         /// CRC-16/MAXIM
  651.         /// </summary>
  652.         /// <param name="buffer"></param>
  653.         /// <param name="start"></param>
  654.         /// <param name="len"></param>
  655.         /// <returns></returns>
  656.         public static byte[] Crc17(byte[] buffer, int start = 0, int len = 0)
  657.         {
  658.             if (buffer == null || buffer.Length == 0) return null;
  659.             if (start < 0) return null;
  660.             if (len == 0) len = buffer.Length - start;
  661.             int length = start + len;
  662.             if (length > buffer.Length) return null;
  663.             ushort crc = 0;// Initial value
  664.             for (int i = start; i < length; i++)
  665.             {
  666.                 crc ^= buffer[i];
  667.                 for (int j = 0; j < 8; j++)
  668.                 {
  669.                     if ((crc & 1) > 0)
  670.                         crc = (ushort)((crc >> 1) ^ 0xA001);// 0xA001 = reverse 0x8005
  671.                     else
  672.                         crc = (ushort)(crc >> 1);
  673.                 }
  674.             }
  675.             byte[] ret = BitConverter.GetBytes((ushort)~crc);
  676.             Array.Reverse(ret);
  677.             return ret;
  678.         }
  679.         // **********************************************************************
  680.         // Name: CRC-16/MODBUS    x16+x15+x2+1
  681.         // Poly: 0x8005
  682.         // Init: 0xFFFF
  683.         // Refin: true
  684.         // Refout: true
  685.         // Xorout: 0x0000
  686.         //*************************************************************************
  687.         /// <summary>
  688.         /// CRC-16/MODBUS
  689.         /// </summary>
  690.         /// <param name="buffer"></param>
  691.         /// <param name="start"></param>
  692.         /// <param name="len"></param>
  693.         /// <returns></returns>
  694.         public static byte[] CrcModbus(byte[] buffer, int start = 0, int len = 0)
  695.         {
  696.             if (buffer == null || buffer.Length == 0) return null;
  697.             if (start < 0) return null;
  698.             if (len == 0) len = buffer.Length - start;
  699.             int length = start + len;
  700.             if (length > buffer.Length) return null;
  701.             ushort crc = 0xFFFF;// Initial value
  702.             for (int i = start; i < length; i++)
  703.             {
  704.                 crc ^= buffer[i];
  705.                 for (int j = 0; j < 8; j++)
  706.                 {
  707.                     if ((crc & 1) > 0)
  708.                         crc = (ushort)((crc >> 1) ^ 0xA001);// 0xA001 = reverse 0x8005
  709.                     else
  710.                         crc = (ushort)(crc >> 1);
  711.                 }
  712.             }
  713.             byte[] ret = BitConverter.GetBytes(crc);
  714.             Array.Reverse(ret);
  715.             return ret;
  716.         }
  717.         // **********************************************************************
  718.         // Name: CRC-16/USB    x16+x15+x2+1
  719.         // Poly: 0x8005
  720.         // Init: 0xFFFF
  721.         // Refin: true
  722.         // Refout: true
  723.         // Xorout: 0xFFFF
  724.         //*************************************************************************
  725.         /// <summary>
  726.         /// CRC-16/USB
  727.         /// </summary>
  728.         /// <param name="buffer"></param>
  729.         /// <param name="start"></param>
  730.         /// <param name="len"></param>
  731.         /// <returns></returns>
  732.         public static byte[] Crc19(byte[] buffer, int start = 0, int len = 0)
  733.         {
  734.             if (buffer == null || buffer.Length == 0) return null;
  735.             if (start < 0) return null;
  736.             if (len == 0) len = buffer.Length - start;
  737.             int length = start + len;
  738.             if (length > buffer.Length) return null;
  739.             ushort crc = 0xFFFF;// Initial value
  740.             for (int i = start; i < length; i++)
  741.             {
  742.                 crc ^= buffer[i];
  743.                 for (int j = 0; j < 8; j++)
  744.                 {
  745.                     if ((crc & 1) > 0)
  746.                         crc = (ushort)((crc >> 1) ^ 0xA001);// 0xA001 = reverse 0x8005
  747.                     else
  748.                         crc = (ushort)(crc >> 1);
  749.                 }
  750.             }
  751.             byte[] ret = BitConverter.GetBytes((ushort)~crc);
  752.             Array.Reverse(ret);
  753.             return ret;
  754.         }
  755.         // **********************************************************************
  756.         // Name: CRC-16/X25    x16+x12+x5+1
  757.         // Poly: 0x1021
  758.         // Init: 0xFFFF
  759.         // Refin: true
  760.         // Refout: true
  761.         // Xorout: 0xFFFF
  762.         //*************************************************************************
  763.         /// <summary>
  764.         /// CRC-16/X25
  765.         /// </summary>
  766.         /// <param name="buffer"></param>
  767.         /// <param name="start"></param>
  768.         /// <param name="len"></param>
  769.         /// <returns></returns>
  770.         public static byte[] Crc20(byte[] buffer, int start = 0, int len = 0)
  771.         {
  772.             if (buffer == null || buffer.Length == 0) return null;
  773.             if (start < 0) return null;
  774.             if (len == 0) len = buffer.Length - start;
  775.             int length = start + len;
  776.             if (length > buffer.Length) return null;
  777.             ushort crc = 0xFFFF;// Initial value
  778.             for (int i = start; i < length; i++)
  779.             {
  780.                 crc ^= buffer[i];
  781.                 for (int j = 0; j < 8; j++)
  782.                 {
  783.                     if ((crc & 1) > 0)
  784.                         crc = (ushort)((crc >> 1) ^ 0x8408);// 0x8408 = reverse 0x1021
  785.                     else
  786.                         crc = (ushort)(crc >> 1);
  787.                 }
  788.             }
  789.             byte[] ret = BitConverter.GetBytes((ushort)~crc);
  790.             Array.Reverse(ret);
  791.             return ret;
  792.         }
  793.         // **********************************************************************
  794.         // Name: CRC-16/XMODEM    x16+x12+x5+1
  795.         // Poly: 0x1021
  796.         // Init: 0x0000
  797.         // Refin: false
  798.         // Refout: false
  799.         // Xorout: 0x0000
  800.         //*************************************************************************
  801.         /// <summary>
  802.         /// CRC-16/XMODEM
  803.         /// </summary>
  804.         /// <param name="buffer"></param>
  805.         /// <param name="start"></param>
  806.         /// <param name="len"></param>
  807.         /// <returns></returns>
  808.         public static byte[] Crc21(byte[] buffer, int start = 0, int len = 0)
  809.         {
  810.             if (buffer == null || buffer.Length == 0) return null;
  811.             if (start < 0) return null;
  812.             if (len == 0) len = buffer.Length - start;
  813.             int length = start + len;
  814.             if (length > buffer.Length) return null;
  815.             ushort crc = 0;// Initial value
  816.             for (int i = start; i < length; i++)
  817.             {
  818.                 crc ^= (ushort)(buffer[i] << 8);
  819.                 for (int j = 0; j < 8; j++)
  820.                 {
  821.                     if ((crc & 0x8000) > 0)
  822.                         crc = (ushort)((crc << 1) ^ 0x1021);
  823.                     else
  824.                         crc = (ushort)(crc << 1);
  825.                 }
  826.             }
  827.             byte[] ret = BitConverter.GetBytes(crc);
  828.             Array.Reverse(ret);
  829.             return ret;
  830.         }
  831.         // **********************************************************************
  832.         // Name: CRC32    x32+x26+x23+x22+x16+x12+x11+x10+x8+x7+x5+x4+x2+x+1
  833.         // Poly: 0x04C11DB7
  834.         // Init: 0xFFFFFFFF
  835.         // Refin: true
  836.         // Refout: true
  837.         // Xorout: 0xFFFFFFFF
  838.         //*************************************************************************
  839.         /// <summary>
  840.         /// CRC32
  841.         /// </summary>
  842.         /// <param name="buffer"></param>
  843.         /// <param name="start"></param>
  844.         /// <param name="len"></param>
  845.         /// <returns></returns>
  846.         public static byte[] Crc22(byte[] buffer, int start = 0, int len = 0)
  847.         {
  848.             if (buffer == null || buffer.Length == 0) return null;
  849.             if (start < 0) return null;
  850.             if (len == 0) len = buffer.Length - start;
  851.             int length = start + len;
  852.             if (length > buffer.Length) return null;
  853.             uint crc = 0xFFFFFFFF;// Initial value
  854.             for (int i = start; i < length; i++)
  855.             {
  856.                 crc ^= buffer[i];
  857.                 for (int j = 0; j < 8; j++)
  858.                 {
  859.                     if ((crc & 1) > 0)
  860.                         crc = (crc >> 1) ^ 0xEDB88320;// 0xEDB88320= reverse 0x04C11DB7
  861.                     else
  862.                         crc = crc >> 1;
  863.                 }
  864.             }
  865.             byte[] ret = BitConverter.GetBytes(~crc);
  866.             Array.Reverse(ret);
  867.             return ret;
  868.         }
  869.         // **********************************************************************
  870.         // Name: CRC32/MPEG-2    x32+x26+x23+x22+x16+x12+x11+x10+x8+x7+x5+x4+x2+x+1
  871.         // Poly: 0x04C11DB7
  872.         // Init: 0xFFFFFFFF
  873.         // Refin: false
  874.         // Refout: false
  875.         // Xorout: 0x00000000
  876.         //*************************************************************************
  877.         /// <summary>
  878.         /// CRC32/MPEG-2
  879.         /// </summary>
  880.         /// <param name="buffer"></param>
  881.         /// <param name="start"></param>
  882.         /// <param name="len"></param>
  883.         /// <returns></returns>
  884.         public static byte[] Crc23(byte[] buffer, int start = 0, int len = 0)
  885.         {
  886.             if (buffer == null || buffer.Length == 0) return null;
  887.             if (start < 0) return null;
  888.             if (len == 0) len = buffer.Length - start;
  889.             int length = start + len;
  890.             if (length > buffer.Length) return null;
  891.             uint crc = 0xFFFFFFFF;// Initial value
  892.             for (int i = start; i < length; i++)
  893.             {
  894.                 crc ^= (uint)(buffer[i] << 24);
  895.                 for (int j = 0; j < 8; j++)
  896.                 {
  897.                     if ((crc & 0x80000000) > 0)
  898.                         crc = (crc << 1) ^ 0x04C11DB7;
  899.                     else
  900.                         crc = crc << 1;
  901.                 }
  902.             }
  903.             byte[] ret = BitConverter.GetBytes(crc);
  904.             Array.Reverse(ret);
  905.             return ret;
  906.         }
  907.         //***************************************************************
  908.         /* 纵向冗余校验（Longitudinal Redundancy Check，简称：LRC）是通信中常用的一种校验形式，也称LRC校验或纵向校验。 
  909.         它是一种从纵向通道上的特定比特串产生校验比特的错误检测方法。在行列格式中（如磁带），LRC经常是与VRC一起使用，这样就会
  910.         为每个字符校验码。在工业领域Modbus协议Ascii模式采用该算法。 LRC计算校验码,具体算法如下：*/
  911.         // 1、对需要校验的数据（2n个字符）两两组成一个16进制的数值求和。
  912.         // 2、将求和结果与256求模。
  913.         // 3、用256减去所得模值得到校验结果（另一种方法：将模值按位取反然后加1）。
  914.  
  915.  
  916.         /// <summary>
  917.         /// LRC校验(纵向冗余校验）工业领域Modbus协议Ascii模式采用该算法
  918.         /// </summary>
  919.         /// <param name="buffer"></param>
  920.         /// <param name="start"></param>
  921.         /// <param name="len"></param>
  922.         /// <returns></returns>
  923.         public static byte[] Lrc(byte[] buffer, int start = 0, int len = 0)
  924.         {
  925.             if (buffer == null || buffer.Length == 0) return null;
  926.             if (start < 0) return null;
  927.             if (len == 0) len = buffer.Length - start;
  928.             int length = start + len;
  929.             if (length > buffer.Length) return null;
  930.             byte lrc = 0;// Initial value
  931.             for (int i = start; i < len; i++)
  932.             {
  933.                 lrc += buffer[i];
  934.             }
  935.             lrc = (byte)((lrc ^ 0xFF) + 1);
  936.             return new byte[] { lrc };
  937.         }
  938.         /// <summary>
  939.         /// BCC(Block Check Character/信息组校验码)，因校验码是将所有数据异或得出，故俗称异或校验。具体算法是：将每一个字节的数据（一般是两个16进制的字符）进行异或后即得到校验码。
  940.         /// </summary>
  941.         /// <param name="buffer"></param>
  942.         /// <param name="start"></param>
  943.         /// <param name="len"></param>
  944.         /// <returns></returns>
  945.         public static byte[] Bcc(byte[] buffer, int start = 0, int len = 0)
  946.         {
  947.             if (buffer == null || buffer.Length == 0) return null;
  948.             if (start < 0) return null;
  949.             if (len == 0) len = buffer.Length - start;
  950.             int length = start + len;
  951.             if (length > buffer.Length) return null;
  952.             byte bcc = 0;// Initial value
  953.             for (int i = start; i < len; i++)
  954.             {
  955.                 bcc ^= buffer[i];
  956.             }
  957.             return new byte[] { bcc };
  958.         }
  959.         /// <summary>
  960.         ///  检验和(checksum)，在数据处理和数据通信领域中，用于校验目的地一组数据项的和。它通常是以十六进制为数制表示的形式。如果校验和的数值超过十六进制的FF,也就是255. 就要求其补码作为校验和。通常用来在通信中，尤其是远距离通信中保证数据的完整性和准确性。
  961.         /// </summary>
  962.         /// <param name="buffer"></param>
  963.         /// <param name="start"></param>
  964.         /// <param name="len"></param>
  965.         /// <returns></returns>
  966.         public static byte[] allAdd(byte[] buffer, int start = 0, int len = 0)
  967.         {
  968.             if (buffer == null || buffer.Length == 0) return null;
  969.             if (start < 0) return null;
  970.             if (len == 0) len = buffer.Length - start;
  971.             int length = start + len;
  972.             if (length > buffer.Length) return null;
  973.             byte bcc = 0;// Initial value
  974.             for (int i = start; i < len; i++)
  975.             {
  976.                 bcc ^= buffer[i];
  977.             }
  978.             return new byte[] { bcc };
  979.         }
  980.     }
  1.     /// <summary>
  2.     /// 操作功能码
  3.     /// </summary>
  4.     public enum FunctionCode
  5.     {
  6.         /// <summary>
  7.         /// 读写从站输出线圈状态0XXXX状态
  8.         /// </summary>
  9.         ReadCoils = 1,
  10.         /// <summary>
  11.         /// 只读从站输入线圈状态1XXXX状态
  12.         /// </summary>
  13.         ReadDiscreteInputs = 2,
  14.         /// <summary>
  15.         /// 读写从站保存寄存器4XXXX状态
  16.         /// </summary>
  17.         ReadHoldingRegisters = 3,
  18.         /// <summary>
  19.         /// 只读从站输入寄存器3XXXX值
  20.         /// </summary>
  21.         ReadInputRegisters = 4,
  22.         /// <summary>
  23.         /// 强制从站单个线圈状态
  24.         /// </summary>
  25.         WriteSingleCoil = 5,
  26.         /// <summary>
  27.         /// 向从站单个寄存器写入值
  28.         /// </summary>
  29.         WriteSingleRegister = 6,
  30.         /// <summary>
  31.         /// 强制从站多个线圈状态
  32.         /// </summary>
  33.         WriteMultipleCoils = 15,
  34.         /// <summary>
  35.         /// 向从站多个寄存器写入值
  36.         /// </summary>
  37.         WriteMultipleRegisters = 16,
  38.         ReportSlaveID = 17,
  39.         MaskWriteRegister = 22,
  40.         ReadWriteRegister = 23
  41.     }
  42.     /// <summary>
  43.     /// 从站返回异常代码
  44.     /// </summary>
  45.     public enum ErrorCode
  46.     {
  47.         /// <summary>
  48.         /// 非法功能
  49.         /// </summary>
  50.         IllegalFunction,
  51.         /// <summary>
  52.         /// 非法数据地址
  53.         /// </summary>
  54.         IllegalDataAddress,
  55.         /// <summary>
  56.         /// 非法数据
  57.         /// </summary>
  58.         IllegalData,
  59.         /// <summary>
  60.         /// 相关设备故障
  61.         /// </summary>
  62.         RelatedEquipmentFailure,
  63.         /// <summary>
  64.         /// 确认
  65.         /// </summary>
  66.         Verify,
  67.         /// <summary>
  68.         /// 忙碌、拒绝执行
  69.         /// </summary>
  70.         Busy,
  71.     }

4，基于ModbusTCP通信。

4.1，ModbusTCP报文格式参考链接

https://www.cnblogs.com/Kirito-Asuna-Yoyi/p/ModbusTCP.html

注明：ModbusTCP是基于以太网Socket通信的协议，无需校验码。

4.2，代码

4.2.1，准备

配置连接参数。

配置功能

4.2.2，UI部分

4.2.3，UI代码部分
  1.   public partial class Form1 : Form
  2.     {
  3.         ModbusTCP modbus;
  4.         int slaveStation = 10;
  5.         Timer timer = new Timer();
  6.         public Form1()
  7.         {
  8.             InitializeComponent();
  9.             UIControlStatusChange(false);
  10.             Socket socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
  11.             modbus = new ModbusTCP();
  12.             modbus.ErrorMessage += Modbus_ErrorMessage;
  13.             timer.Interval = 1000;
  14.             foreach (Control item in groupBox1.Controls)
  15.             {
  16.                 if (item is GroupBox)
  17.                 {
  18.                     foreach (Control c in item.Controls)
  19.                     {
  20.                         if (c is Button)
  21.                         {
  22.                             (c as Button).Click += Button_Click;
  23.                         }
  24.  
  25.                     }
  26.                 }
  27.             }
  28.         }
  29.  
  30.         private void Button_Click(object sender, EventArgs e)
  31.         {
  32.             lblErrorMsg.Text = "";
  33.         }
  34.  
  35.         private void Modbus_ErrorMessage(int arg1, string arg2)
  36.         {
  37.             this.Invoke(new Action(() =>
  38.             {
  39.                 lblErrorMsg.Text = $"从站[{arg1}]出现异常，原因：{arg2}";
  40.             }));
  41.  
  42.         }
  43.  
  44.         /// <summary>
  45.         /// 变更UI控件状态
  46.         /// </summary>
  47.         /// <param name="status">True:已连接，False：连接断开</param>
  48.         void UIControlStatusChange(bool status)
  49.         {
  50.             if (status)
  51.             {
  52.                 txtIP.Enabled = false;
  53.                 txtPort.Enabled = false;
  54.                 txtSlave.Enabled = false;
  55.                 btnConnect.BackColor = Color.LightGreen;
  56.                 btnConnect.Text = "断开连接";
  57.                 groupBox1.Enabled = true;
  58.             }
  59.             else
  60.             {
  61.                 txtIP.Enabled = true;
  62.                 txtPort.Enabled = true;
  63.                 txtSlave.Enabled = true;
  64.                 btnConnect.BackColor = Color.Red;
  65.                 btnConnect.Text = "连接";
  66.                 groupBox1.Enabled = false;
  67.             }
  68.         }
  69.  
  70.         private void btnConnect_Click(object sender, EventArgs e)
  71.         {
  72.             if (btnConnect.Text.Equals("连接"))
  73.             {
  74.                 if (modbus.IsConnected)
  75.                 {
  76.                     modbus.Disconnect();
  77.                 }
  78.                 IPEndPoint endPoint = new IPEndPoint(IPAddress.Parse(txtIP.Text.Trim()), int.Parse(txtPort.Text.Trim()));
  79.                 modbus.RemoteEndPoint = endPoint;
  80.                 modbus.Connect();
  81.  
  82.             }
  83.             else
  84.             {
  85.                 if (modbus.IsConnected)
  86.                 {
  87.                     modbus.Disconnect();
  88.  
  89.                 }
  90.             }
  91.  
  92.             UIControlStatusChange(modbus.IsConnected);
  93.  
  94.         }
  95.         //读取多个线圈
  96.         private void btnReadCoils_Click(object sender, EventArgs e)
  97.         {
  98.  
  99.             int address; int len;
  100.             if (!int.TryParse(txtCoilsAddress.Text.Trim(), out address))
  101.             {
  102.                 txtCoilsAddress.Focus();
  103.                 MessageBox.Show("线圈地址错误！");
  104.                 return;
  105.             }
  106.  
  107.             if (!int.TryParse(txtCoilsCount.Text.Trim(), out len))
  108.             {
  109.                 txtCoilsCount.Focus();
  110.                 MessageBox.Show("线圈数量只能为正整数！");
  111.                 return;
  112.             }
  113.             bool[] reuslt = modbus.ReadCoils(slaveStation, address, len);
  114.             if (reuslt == null) return;
  115.             StringBuilder sb = new StringBuilder();
  116.             foreach (var item in reuslt)
  117.             {
  118.                 if (item)
  119.                 {
  120.                     sb.Append(" 1");
  121.                 }
  122.                 else
  123.                 {
  124.                     sb.Append(" 0");
  125.                 }
  126.             }
  127.             lblCoilsResult.Text = sb.ToString();
  128.         }
  129.  
  130.         private void txtSlave_TextChanged(object sender, EventArgs e)
  131.         {
  132.             if (!int.TryParse(txtSlave.Text.Trim(), out slaveStation))
  133.             {
  134.                 slaveStation = 10;
  135.             }
  136.         }
  137.  
  138.  
  139.  
  140.         private void btnForced_Click(object sender, EventArgs e)
  141.         {
  142.  
  143.             int address;
  144.             if (!int.TryParse(txtCoilsWriteAdress.Text.Trim(), out address))
  145.             {
  146.                 txtCoilsWriteAdress.Focus();
  147.                 MessageBox.Show("线圈写入地址错误！");
  148.                 return;
  149.             }
  150.             if (btnForced.Text.Equals("ON"))
  151.             {
  152.                 bool result = modbus.ForcedCoil(slaveStation, address, false);
  153.                 if (result)
  154.                 {
  155.                     btnForced.Text = "OFF";
  156.                     btnForced.BackColor = Color.Red;
  157.                 }
  158.             }
  159.             else
  160.             {
  161.                 bool result = modbus.ForcedCoil(slaveStation, address, true);
  162.                 if (result)
  163.                 {
  164.                     btnForced.Text = "ON";
  165.                     btnForced.BackColor = Color.LightGreen;
  166.                 }
  167.             }
  168.  
  169.         }
  170.  
  171.         private void btnRegistersRead_Click(object sender, EventArgs e)
  172.         {
  173.  
  174.             int address; int len;
  175.             if (!int.TryParse(txtRegistersAdress.Text.Trim(), out address))
  176.             {
  177.                 txtRegistersAdress.Focus();
  178.                 MessageBox.Show("寄存器地址错误！");
  179.                 return;
  180.             }
  181.  
  182.             if (!int.TryParse(txtRegistersCount.Text.Trim(), out len))
  183.             {
  184.                 txtRegistersCount.Focus();
  185.                 MessageBox.Show("寄存器数量只能为正整数！");
  186.                 return;
  187.             }
  188.             short[] result = modbus.ReadHoldingRegisters(slaveStation, address, len);
  189.             if (result == null) return;
  190.             StringBuilder sb = new StringBuilder();
  191.             foreach (var item in result)
  192.             {
  193.                 sb.Append(" " + item.ToString());
  194.             }
  195.             lblRegistersResult.Text = sb.ToString();
  196.         }
  197.  
  198.         private void btnReadFloat_Click(object sender, EventArgs e)
  199.         {
  200.             int address; int len;
  201.             if (!int.TryParse(txtRegistersAdress.Text.Trim(), out address))
  202.             {
  203.                 txtRegistersAdress.Focus();
  204.                 MessageBox.Show("寄存器地址错误！");
  205.                 return;
  206.             }
  207.  
  208.             if (!int.TryParse(txtRegistersCount.Text.Trim(), out len))
  209.             {
  210.                 txtRegistersCount.Focus();
  211.                 MessageBox.Show("寄存器数量只能为正整数！");
  212.                 return;
  213.             }
  214.             float[] result = modbus.ReadFloatRegisters(slaveStation, address, len);
  215.             if (result == null) return;
  216.             StringBuilder sb = new StringBuilder();
  217.             foreach (var item in result)
  218.             {
  219.                 sb.Append(" " + item.ToString());
  220.             }
  221.             lblRegistersResult.Text = sb.ToString();
  222.         }
  223.  
  224.         private void btnWriteShort_Click(object sender, EventArgs e)
  225.         {
  226.             int address; short val;
  227.             if (!int.TryParse(txtWriteShortAdress.Text.Trim(), out address))
  228.             {
  229.                 txtWriteShortAdress.Focus();
  230.                 MessageBox.Show("寄存器地址错误！");
  231.                 return;
  232.             }
  233.  
  234.             if (!short.TryParse(txtWriteShortVal.Text.Trim(), out val))
  235.             {
  236.                 txtWriteShortVal.Focus();
  237.                 MessageBox.Show("写入的值只能为正整数！");
  238.                 return;
  239.             }
  240.             if (modbus.WriteSingleRegister(slaveStation, address, val))
  241.             {
  242.  
  243.                 MessageBox.Show("Short数已成功写入"); 
  244.             }
  245.             else
  246.             {
  247.                 MessageBox.Show("Short数写入失败");
  248.             }
  249.         }
  250.  
  251.         private void btnWriteFloat_Click(object sender, EventArgs e)
  252.         {
  253.             int address; float val;
  254.             if (!int.TryParse(txtFloatWriteAddress.Text.Trim(), out address))
  255.             {
  256.                 txtFloatWriteAddress.Focus();
  257.                 MessageBox.Show("寄存器地址错误！");
  258.                 return;
  259.             }
  260.  
  261.             if (!float.TryParse(txtWriteFloatVal.Text.Trim(), out val))
  262.             {
  263.                 txtWriteFloatVal.Focus();
  264.                 MessageBox.Show("写入的值只能为正整数！");
  265.                 return;
  266.             }
  267.             if (modbus.WriteFloatRegister(slaveStation, address, val))
  268.             {
  269.                 MessageBox.Show("Float数已成功写入");
  270.             }
  271.             else
  272.             {
  273.                 MessageBox.Show("Float数写入失败");
  274.             }
  275.         }
  276.         //给线圈批量赋值
  277.         private void btnBatch_Click(object sender, EventArgs e)
  278.         {
  279.             int address; short val;
  280.             if (!int.TryParse(txtCoils.Text.Trim(), out address))
  281.             {
  282.                 txtCoils.Focus();
  283.                 MessageBox.Show("线圈地址错误！");
  284.                 return;
  285.             }
  286.  
  287.             if (!short.TryParse(txtCoilsVal.Text.Trim(), out val))
  288.             {
  289.                 txtCoilsVal.Focus();
  290.                 MessageBox.Show("写入的值只能为正整数！");
  291.                 return;
  292.             }
  293.             bool result = modbus.WriteMultipleCoils(slaveStation, address, 16, new short[] { val });
  294.             if (result)
  295.             {
  296.                 MessageBox.Show("线圈已批量写入");
  297.             }
  298.             else
  299.             {
  300.                 MessageBox.Show("线圈批量失败");
  301.             }
  302.         }
  303.  
  304.         private void btnMulShortWrite_Click(object sender, EventArgs e)
  305.         {
  306.             int address; short val;int len;
  307.             if (!int.TryParse(txtMulAdress.Text.Trim(), out address))
  308.             {
  309.                 txtMulAdress.Focus();
  310.                 MessageBox.Show("寄存器地址错误！");
  311.                 return;
  312.             }
  313.  
  314.             if (!short.TryParse(txtMulShortVal.Text.Trim(), out val))
  315.             {
  316.                 txtMulShortVal.Focus();
  317.                 MessageBox.Show("写入的值只能为正整数！");
  318.                 return;
  319.             }
  320.             if (!int.TryParse(txtMulCount.Text.Trim(), out len))
  321.             {
  322.                 txtMulCount.Focus();
  323.                 MessageBox.Show("寄存器数量只能为正整数！");
  324.                 return;
  325.             }
  326.             if (modbus.WriteMultipleRegisters(slaveStation, address, len, Enumerable.Repeat(val, len).ToArray()))
  327.             {
  328.                 MessageBox.Show("寄存器已批量写入");
  329.             }
  330.             else
  331.             {
  332.                 MessageBox.Show("寄存器批量写入失败");
  333.             }
  334.         }
  335.     }

4.2.4，ModbusTCP部分

  1.  public class ModbusTCP : IDisposable
  2.     {
  3.         #region 说明
  4.         //---------------------------------------------------
  5.         //前8个字节的规律是一模一样了，都是标识号+modbus号+长度+站号，后面基本是跟地址和长度，或是直接是地址和数据。
  6.         //---------------------------------------------------
  7.         //功能码0x01:读线圈
  8.         //发送的数据--------------------------------------------
  9.         //根据协议指定，需要填写长度为12的byte数组
  10.         //byte[0]    byte[1]    byte[2]   byte[3]   byte[4]   byte[5]   byte[6]   byte[7]   byte[8]   byte[9]   byte[10]   byte[11]  
  11.         //byte[0] byte[1]: 消息号---------随便指定，服务器返回的数据的前两个字和这个一样
  12.         //byte[2] byte[3]：modbus标识，强制为0即可
  13.         //byte[4] byte[5]：指示排在byte[5] 后面所有字节的个数，也就是总长度-6
  14.         //byte[6]：站号，对于TCP协议来说，某些情况不重要，可以随便指定，对于rtu及ascii来说，就需要选择设备的站号信息。
  15.         //byte[7]：功能码，这里就需要填入我们的真正的想法了
  16.         //byte[8] byte[9]：起始地址，比如我们想读取地址0的数据，就填 00 00 ，如果我们想读取地址1000的数据，怎么办，填入 03 E8 ，也就是将1000转化十六进制填进去。
  17.         //byte[10] byte[11]：指定想读取的数据长度，比如我们就想读取地址0的一个数据，这里就写 00 01，如果我们想读取地址0-999共计一个数据的长度，就写 03 E8。和起始地址是一样的。
  18.         //有了上面的格式之后，如下
  19.         //00 00 00 00 00 06 FF 01 00 00 00 01
  20.         //表示：消息号设为0，站号FF，功能码01，地址01，长度01
  21.         //响应的数据--------------------------------------------
  22.         //00 00 00 00 00 04 FF 01 01 00 共计10个字节的数据。
  23.         //byte[0] byte[1] :消息号，发送指令是多少，这里就是多少。
  24.         //byte[2] byte[3]：必须都为0，代表这是modbus 通信
  25.         //byte[4] byte[5]：指示byte[5] 后面的所有字节数，这里是00 04，如果后面共有100个，那么这里就是 00 64
  26.         //byte[6]：站号，发送为FF，那么这里也就是FF
  27.         //byte[7]：功能码，发送指令为01的功能码，这里也是01，和发送的指令是一致的
  28.         //byte[8]：指示byte[8] 后面跟随的字节数量，因为跟在byte[8] 后面的就是真实的数据，结果就在byte[8] 后面
  29.         //byte[9]：真实的数据，一个byte有8位，这里只读取了一个位数据，所有这里的有效值只是byte[9] 的最低位，二进制为 0000 0000 我们看到最低位为0，所以最终我们读取的地址0的线圈为断。
  30.         // 功能码0x05:写单个线圈
  31.         //如果指定地址0的线圈为通：00 00 00 00 00 06 FF 05 00 00 FF 00 
  32.         // 前面的含义都是一致的，不同的是： 05 00 00 FF 00
  33.         //05 是功能码， 00 00 是指定的地址，如果想地址1000为通，那么就为 03 E8，规定数据 FF 00 线圈通，00 00线圈断，其他任何的值都对结果无效。
  34.         //响应数据：  00 00 00 00 00 06 FF 05 00 00 FF 00   因执行写入的操作，是不带读取数据，所以服务器会直接复制一遍你的指令并返回。
  35.         //下面再举例一些方便理解（我们只需要指定地址及是否通断的情况即可）：
  36.         //写入地址100为通： 00 00 00 00 00 06 FF 05 00 64 FF 00   
  37.         //写入地址1000为断：00 00 00 00 00 06 FF 05 03 E8 00 00
  38.         // 功能码0x0F:写入多个线圈
  39.         //  00 00 00 00 00 84 FF 0F 00 00 03 E8 7D ...（后面跟125个byte，都是00） 
  40.         //00 00 :消息标识号，任意数字，服务器回复相同数字。
  41.         //00 00 :modbus标志号，规定为00 。
  42.         //00 84 :0x0084转化十进制就是132，也就是说，00 84(不包含00 84)后面跟了132个字节
  43.         //FF :站号
  44.         //0F :功能码
  45.         //00 00:起始地址，此处就是0，如果起始地址为100，那么就写00 64，如果起始地址为1000，那么就写03 E8
  46.         //03 E8: 我们需要写的数据长度，如果需要写1000个线圈，就是03 E8，如果写999个线圈，那么就是03 E7。
  47.         //7D : 这个字节代表后面跟随的真实写入的数据的长度，为125个字节。    
  48.         //响应的数据：
  49.         //00 00 00 00 00 06 FF 0F 00 00 03 E8 
  50.         // 功能码0x03:读取寄存器的值
  51.         //该功能码实现寄存器的数据读取，我们需要知道的是，一个寄存器占2个byte，而且是高位在前，地位在后，那么如果寄存器0的数据为1000，那么我们读取到的数据就是03 E8，这是我们最终想要的东西，03功能码和01功能码很接近，就是功能码替换一下，返回的数据解析不一样而已，比如我们需要读取地址0的寄存器数据：
  52.         //00 00 00 00 00 06 FF 03 00 00 00 01             
  53.         //功能码03，读取寄存器，地址0，长度1 返回如下：
  54.         //00 00 00 00 00 05 FF 03 02 03 E8 
  55.         //02 03 E8:02代表后面的字节长度是2个字节，03 E8是真实的数据了，代表了寄存器0存储了1000这个数据。
  56.         #endregion
  57.         Socket socketObject = null;
  58.         /// <summary>
  59.         /// 目标站点号
  60.         /// </summary>
  61.         int targetStation = 0;
  62.         /// <summary>
  63.         /// 消息接收到标志位
  64.         /// </summary>
  65.         bool msgRecFlag = false;
  66.         /// <summary>
  67.         /// 接收到有效的数据
  68.         /// </summary>
  69.         byte[] RecBytes = null;
  70.         AutoResetEvent slim = new AutoResetEvent(true);
  71.         /// <summary>
  72.         /// 返回的异常信息
  73.         /// </summary>
  74.         public event Action<int, string> ErrorMessage;
  75.         /// <summary>
  76.         /// 消息号
  77.         /// </summary>
  78.         int MsgId = 0;
  79.         CancellationTokenSource source;
  80.         public ModbusTCP()
  81.         {
  82.  
  83.         }
  84.  
  85.  
  86.  
  87.         EndPoint remoteEndPoint;
  88.         /// <summary>
  89.         /// 远程终结点
  90.         /// </summary>
  91.         public EndPoint RemoteEndPoint
  92.         {
  93.             get
  94.             {
  95.                 remoteEndPoint = socketObject.RemoteEndPoint;
  96.                 return remoteEndPoint;
  97.             }
  98.             set
  99.             {
  100.                 remoteEndPoint = value;
  101.             }
  102.         }
  103.         /// <summary>
  104.         /// 本地终结点
  105.         /// </summary>
  106.         public EndPoint LocalEndPoint
  107.         {
  108.             get
  109.             {
  110.                 return socketObject.LocalEndPoint;
  111.             }
  112.         }
  113.         /// <summary>
  114.         /// 当前的Socket对象
  115.         /// </summary>
  116.         public Socket SocketObject
  117.         {
  118.             get
  119.             {
  120.                 return socketObject;
  121.             }
  122.         }
  123.         bool isConnected = false;
  124.         public bool IsConnected
  125.         {
  126.             get
  127.             {
  128.                 if (socketObject==null || !socketObject.Connected)
  129.                 {
  130.                     isConnected = false;
  131.                 }
  132.                 return isConnected;
  133.             }
  134.         }
  135.         /// <summary>
  136.         /// 使用RemoteEndPoint属性值建立与远程主机的连接
  137.         /// </summary>
  138.         /// <param name="serialPortName"></param>
  139.         public void Connect()
  140.         {
  141.             if (socketObject != null)
  142.             {
  143.                 Disconnect();
  144.             }
  145.             socketObject = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
  146.             socketObject.Connect(remoteEndPoint);
  147.             isConnected = socketObject.Connected;
  148.             source = new CancellationTokenSource();
  149.             if (IsConnected)
  150.             {
  151.                 DataReceivedTask();
  152.                 
  153.             }
  154.         }
  155.  
  156.         /// <summary>
  157.         /// 建立与远程主机的连接
  158.         /// </summary>
  159.         /// <param name="address">远程主机IP</param>
  160.         /// <param name="port">远程主机端口号</param>
  161.         public void Connect(string address, int port)
  162.         {
  163.             if (socketObject != null)
  164.             {
  165.                 Disconnect();
  166.             }
  167.             socketObject = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
  168.             socketObject.Connect(IPAddress.Parse(address), port);
  169.             isConnected = socketObject.Connected;
  170.             source = new CancellationTokenSource();
  171.             if (IsConnected)
  172.             {
  173.                 DataReceivedTask();
  174.             }
  175.         }
  176.         /// <summary>
  177.         /// 关闭连接
  178.         /// </summary>
  179.         /// <param name="reuseSocket">如果关闭当前连接后可以重用此套接字，则为 true；否则为 false。</param>
  180.         public void Disconnect()
  181.         {
  182.             if (socketObject != null && IsConnected)
  183.             {
  184.                 socketObject.Shutdown(SocketShutdown.Both);
  185.                 socketObject.Disconnect(false);
  186.                 socketObject.Close();
  187.                 socketObject.Dispose();
  188.                 socketObject = null;
  189.  
  190.             }
  191.             isConnected = false;
  192.             source.Cancel();
  193.         }
  194.         /// <summary>
  195.         /// 接收数据任务
  196.         /// </summary>
  197.         async void DataReceivedTask()
  198.         {
  199.             try
  200.             {
  201.                 await Task.Run(() =>
  202.                 {
  203.                     while (true)
  204.                     {
  205.                         if (source.Token.IsCancellationRequested)
  206.                         {
  207.                             source.Token.ThrowIfCancellationRequested();
  208.                         }
  209.                         // int num = socketObject.Available;
  210.                         // if (num == 0) return;
  211.                         byte[] data = new byte[10 * 1024 * 1024];
  212.  
  213.                         byte[] bytes;
  214.                         try
  215.                         {
  216.                             int len = socketObject.Receive(data);
  217.                             if (len == 0)
  218.                             {
  219.                                 isConnected = false;
  220.                                 return;
  221.                             }
  222.                             bytes = new byte[len];
  223.                             Array.Copy(data, bytes, len);
  224.                         }
  225.                         catch (Exception)
  226.                         {
  227.                             isConnected = false;
  228.                             return;
  229.                         }
  230.                         //对消息进行解析
  231.                         //检查报文是否正确
  232.                         msgRecFlag = true;
  233.                         //ModbusTCP无校验位
  234.                         //获取salve Station No
  235.                         byte stationNo = bytes[6];
  236.                         targetStation = stationNo;
  237.                         //功能码
  238.                         byte commandCode = bytes[7];
  239.                         if (commandCode > 80)
  240.                         {
  241.                             //异常信息
  242.                             ErrorCode errorCode = (ErrorCode)bytes[8];
  243.                             ErrorMessage?.BeginInvoke(stationNo, errorCode.ToString(),null,null);
  244.                            
  245.                         }
  246.                         else
  247.                         {
  248.                             FunctionCode function = (FunctionCode)commandCode;
  249.                             //有效数据占用的字节数                      
  250.                             byte length = bytes[8];
  251.                             switch (function)
  252.                             {
  253.                                 case FunctionCode.ReadCoils:
  254.                                 case FunctionCode.ReadDiscreteInputs:
  255.                                     //返回字节长度
  256.                                     RecBytes = new byte[length];
  257.                                     Array.Copy(bytes, 9, RecBytes, 0, length);
  258.                                     break;
  259.                                 case FunctionCode.ReadHoldingRegisters:
  260.                                 case FunctionCode.ReadInputRegisters:
  261.                                     //读取寄存器数据
  262.                                     RecBytes = new byte[length];
  263.                                     Array.Copy(bytes, 9, RecBytes, 0, length);
  264.                                     break;
  265.                                 case FunctionCode.WriteSingleCoil:
  266.                                 case FunctionCode.WriteSingleRegister:
  267.                                 case FunctionCode.WriteMultipleCoils:
  268.                                 case FunctionCode.WriteMultipleRegisters:
  269.                                     RecBytes = new byte[4];
  270.                                     Array.Copy(bytes, 8, RecBytes, 0, RecBytes.Length);
  271.                                     break;
  272.                                 case FunctionCode.ReportSlaveID:
  273.                                     break;
  274.                                 case FunctionCode.MaskWriteRegister:
  275.                                     break;
  276.                                 case FunctionCode.ReadWriteRegister:
  277.                                     break;
  278.                                 default:
  279.                                     break;
  280.                             }
  281.                         }
  282.                             
  283.                         
  284.                         //接收完成，取消主线程阻塞
  285.                         slim.Set();
  286.                     }
  287.                 });
  288.             }
  289.             catch (OperationCanceledException ex)
  290.             {
  291.                 socketObject.Disconnect(true);
  292.             }
  293.             catch (Exception ex)
  294.             {
  295.                 ErrorMessage?.Invoke(targetStation, "出现异常，原因：" + ex.Message);
  296.             }
  297.         }
  298.         /// <summary>
  299.         ///发送报文
  300.         /// </summary>
  301.         /// <param name="bytes"></param>
  302.         /// <param name="protocol">报文协议</param>
  303.         void Send(string sendMsg)
  304.         {
  305.             //对消息进行判断是否合规
  306.             if (!Regex.IsMatch(sendMsg, @"^[0-9a-fA-F]+$"))
  307.             {
  308.                 throw new Exception("报文错误，存在非16进制字符");
  309.             }
  310.             byte[] bytes = new byte[sendMsg.Length / 2];
  311.             for (int i = 0; i < sendMsg.Length / 2; i++)
  312.             {
  313.                 bytes[i] = Convert.ToByte(sendMsg.Substring(i * 2, 2), 16);
  314.             }
  315.             //ModbusTCP不需要添加校验码
  316.             //  byte[] checkSum = Checkhelper.CrcModbus(bytes, 0, bytes.Length);
  317.             //  var checkarr = checkSum.Reverse().ToArray();
  318.             // byte[] msgBytes = new byte[bytes.Length + checkSum.Length];
  319.             byte[] msgBytes = new byte[bytes.Length];
  320.             Array.Copy(bytes, msgBytes, bytes.Length);
  321.             // Array.Copy(checkarr, 0, msgBytes, bytes.Length, checkarr.Length);
  322.             socketObject.Send(msgBytes, 0, msgBytes.Length, SocketFlags.None);
  323.         }
  324.         /// <summary>
  325.         /// 编制报文
  326.         /// </summary>
  327.         /// <param name="slaveStation">从站站号</param>
  328.         /// <param name="function">功能代码</param>
  329.         /// <param name="devAdress">起始地址</param>
  330.         /// <param name="devLenght">数量</param>
  331.         /// <param name="values">写入的值</param>
  332.         ///  /// <param name="fromBase">如果写入的数值类型所占用的byte，例如short类型为2，int类型为4，flost类型为4，double类型为8</param>
  333.         /// <param name="set">强制线圈通断，true：ON ;false:OFF</param>
  334.         void ComposeMessage(int slaveStation, FunctionCode function, int devAdress, int devLenght = 1, byte[] values = null, int fromBase = 2, bool set = false)
  335.         {
  336.             lock (this)
  337.             {
  338.                 slim.Reset();
  339.                 StringBuilder sb = new StringBuilder();
  340.                 int afterBytesCount = 0;
  341.                 sb.Append(devAdress.ToString("X4"));
  342.                 switch (function)
  343.                 {
  344.                     case FunctionCode.ReadCoils:
  345.                     case FunctionCode.ReadDiscreteInputs:
  346.                     case FunctionCode.ReadHoldingRegisters:
  347.                     case FunctionCode.ReadInputRegisters:
  348.                         //功能码0x01:读线圈
  349.                         //发送的数据--------------------------------------------
  350.                         //根据协议指定，需要填写长度为12的byte数组
  351.                         //byte[0]    byte[1]    byte[2]   byte[3]   byte[4]   byte[5]   byte[6]   byte[7]   byte[8]   byte[9]   byte[10]   byte[11]  
  352.                         //byte[0] byte[1]: 消息号---------随便指定，服务器返回的数据的前两个字和这个一样
  353.                         //byte[2] byte[3]：modbus标识，强制为0即可
  354.                         //byte[4] byte[5]：指示排在byte[5] 后面所有字节的个数，也就是总长度-6
  355.                         //byte[6]：站号，对于TCP协议来说，某些情况不重要，可以随便指定，对于rtu及ascii来说，就需要选择设备的站号信息。
  356.                         //byte[7]：功能码，这里就需要填入我们的真正的想法了
  357.                         //byte[8] byte[9]：起始地址，比如我们想读取地址0的数据，就填 00 00 ，如果我们想读取地址1000的数据，怎么办，填入 03 E8 ，也就是将1000转化十六进制填进去。
  358.                         //byte[10] byte[11]：指定想读取的数据长度，比如我们就想读取地址0的一个数据，这里就写 00 01，如果我们想读取地址0-999共计一个数据的长度，就写 03 E8。和起始地址是一样的。
  359.                         //有了上面的格式之后，如下
  360.                         //00 00 00 00 00 06 FF 01 00 00 00 01
  361.                         //表示：消息号设为0，站号FF，功能码01，地址01，长度01
  362.                         afterBytesCount = 6;
  363.                         sb.Append(devLenght.ToString("X4"));
  364.                         break;
  365.                     case FunctionCode.WriteSingleCoil:
  366.                         // 功能码0x05:写单个线圈
  367.                         //如果指定地址0的线圈为通：00 00 00 00 00 06 FF 05 00 00 FF 00 
  368.                         // 前面的含义都是一致的，不同的是： 05 00 00 FF 00
  369.                         //05 是功能码， 00 00 是指定的地址，如果想地址1000为通，那么就为 03 E8，规定数据 FF 00 线圈通，00 00线圈断，其他任何的值都对结果无效。
  370.                         //响应数据：  00 00 00 00 00 06 FF 05 00 00 FF 00   因执行写入的操作，是不带读取数据，所以服务器会直接复制一遍你的指令并返回。
  371.                         //下面再举例一些方便理解（我们只需要指定地址及是否通断的情况即可）：
  372.                         //写入地址100为通： 00 00 00 00 00 06 FF 05 00 64 FF 00   
  373.                         //写入地址1000为断：00 00 00 00 00 06 FF 05 03 E8 00 00
  374.                         afterBytesCount = 6;
  375.  
  376.                         if (set)
  377.                         {
  378.                             //线圈置ON
  379.                             sb.Append("FF00");
  380.                         }
  381.                         else
  382.                         {
  383.                             //线圈置OFF
  384.                             sb.Append("0000");
  385.                         }
  386.                         break;
  387.                     case FunctionCode.WriteSingleRegister:
  388.                         //向单个寄存器写入值,占用两个byte
  389.                         afterBytesCount = 6;
  390.                         int curVal = BitConverter.ToInt16(values, 0);
  391.                         sb.Append(curVal.ToString("X4"));
  392.                         break;
  393.                     case FunctionCode.WriteMultipleCoils:
  394.                         // 功能码0x0F:写入多个线圈
  395.                         //  00 00 00 00 00 84 FF 0F 00 00 03 E8 7D ...（后面跟125个byte，都是00） 
  396.                         //00 00 :消息标识号，任意数字，服务器回复相同数字。
  397.                         //00 00 :modbus标志号，规定为00 。
  398.                         //00 84 :0x0084转化十进制就是132，也就是说，00 84(不包含00 84)后面跟了132个字节
  399.                         //FF :站号
  400.                         //0F :功能码
  401.                         //00 00:起始地址，此处就是0，如果起始地址为100，那么就写00 64，如果起始地址为1000，那么就写03 E8
  402.                         //03 E8: 我们需要写的数据长度，如果需要写1000个线圈，就是03 E8，如果写999个线圈，那么就是03 E7。
  403.                         //7D : 这个字节代表后面跟随的真实写入的数据的长度，为125个字节。   
  404.                         int len = (int)Math.Ceiling(devLenght * 1.0 / 8);
  405.                         afterBytesCount = 7 + len;
  406.                         sb.Append(devLenght.ToString("X4"));
  407.                         sb.Append(len.ToString("X2"));
  408.                         foreach (var item in values)
  409.                         {
  410.                             sb.Append(item.ToString("X2"));
  411.                         }
  412.                         break;
  413.                     case FunctionCode.WriteMultipleRegisters:
  414.                         //向多个寄存器写入值
  415.                         //1,需操作的寄存器数量,数值占用两个byte
  416.                         afterBytesCount = 7 + values.Length;
  417.                         //2,寄存器数量
  418.                         sb.Append((values.Length*2 / fromBase ).ToString("X4"));
  419.                         //2,需要操作的寄存器占用的字节数，数值占用1个byte
  420.                         sb.Append((values.Length).ToString("X2"));
  421.                         //3,写入寄存器的值,根据frombase判定值
  422.                         //此时姑且以占2个Byte计算
  423.                         for (int i = 0; i < values.Length; i++)
  424.                         {
  425.                             sb.Append(values[i].ToString("X2"));
  426.                         }
  427.                         break;
  428.                     case FunctionCode.ReportSlaveID:
  429.                         break;
  430.                     case FunctionCode.MaskWriteRegister:
  431.                         break;
  432.                     case FunctionCode.ReadWriteRegister:
  433.                         break;
  434.                     default:
  435.                         break;
  436.                 }
  437.                 //---------------------------------------------------
  438.                 //前8个字节的规律是一模一样了，都是：消息ID+modbus号+长度+站号，后面基本是跟地址和长度，或是直接是地址和数据。
  439.                 //byte[0] byte[1]: 消息号---------随便指定，服务器返回的数据的前两个字和这个一样
  440.                 //byte[2] byte[3]：modbus标识，强制为0即可
  441.                 //byte[4] byte[5]：指示排在byte[5] 后面所有字节的个数，也就是总长度
  442.                 //byte[6]：站号，对于TCP协议来说，某些情况不重要，可以随便指定，对于rtu及ascii来说，就需要选择设备的站号信息。
  443.                 //byte[7]：功能码，这里就需要填入我们的真正的想法了
  444.                 //---------------------------------------------------
  445.                 //添加从站点,功能代码，起始位置
  446.                 if (MsgId > 1000) MsgId = 0;
  447.                 MsgId++;
  448.                 string msg = $"{MsgId.ToString("X4")}0000{afterBytesCount.ToString("X4")}{ slaveStation.ToString("X2")}{((int)function).ToString("X2")}";
  449.                 msg += sb;
  450.                 RecBytes = null;
  451.                 Send(msg.Trim());
  452.                 //100ms等待消息回复
  453.                 msgRecFlag = slim.WaitOne(3000);
  454.                 System.Threading.Thread.Sleep(20);
  455.                 if (!msgRecFlag)
  456.                 {
  457.                     ErrorMessage?.Invoke(slaveStation, $"从站：{slaveStation}，回复超时");
  458.                 }
  459.             }
  460.         }
  461.         /// <summary>
  462.         /// 强制指定单个线圈动作
  463.         /// </summary>
  464.         /// <param name="slaveStationNo">从站站号</param>
  465.         /// <param name="devAdress">线圈地址</param>
  466.         /// <param name="onOrOff">True为ON，false为Off</param>
  467.         /// <returns></returns>
  468.         public bool ForcedCoil(int slaveStationNo, int devAdress, bool set)
  469.         {
  470.             ComposeMessage(slaveStationNo, FunctionCode.WriteSingleCoil, devAdress, set: set);
  471.             if (slaveStationNo == targetStation && msgRecFlag && RecBytes != null)
  472.             {
  473.                 if (RecBytes[2] == 0xff && RecBytes[3] == 0 && set)
  474.                 {
  475.                     return true;
  476.                 }
  477.                 if (RecBytes[3] == 0 && RecBytes[2] == 0 && !set)
  478.                 {
  479.                     return true;
  480.  
  481.  
  482.                 }
  483.             }
  484.  
  485.             return false;
  486.  
  487.         }
  488.         /// <summary>
  489.         /// 读取多个线圈状态
  490.         /// </summary>
  491.         /// <param name="slaveStationNo"></param>
  492.         /// <param name="devAdress"></param>
  493.         /// <param name="iLenght"></param>
  494.         public bool[] ReadCoils(int slaveStationNo, int devAdress, int iLenght)
  495.         {
  496.             ComposeMessage(slaveStationNo, FunctionCode.ReadCoils, devAdress, iLenght);
  497.             if (slaveStationNo == targetStation && msgRecFlag && RecBytes != null)
  498.             {
  499.                 BitArray array = new BitArray(RecBytes);
  500.  
  501.                 if (iLenght > array.Count)
  502.                 {
  503.                     throw new Exception("线圈查询结果异常！");
  504.                 }
  505.                 bool[] coils = new bool[iLenght];
  506.                 for (int i = 0; i < iLenght; i++)
  507.                 {
  508.                     coils[i] = array[i];
  509.                 }
  510.                 return coils;
  511.             }
  512.             else
  513.             {
  514.                 return null;
  515.             }
  516.         }
  517.         /// <summary>
  518.         /// 将short值写入到多个线圈
  519.         /// </summary>
  520.         /// <param name="slaveStationNo">从站站号</param>
  521.         /// <param name="devAdress"></param>
  522.         /// <param name="iLenght">地址长度</param>
  523.         /// <param name="arr">写入的值</param>
  524.         public bool WriteMultipleCoils(int slaveStationNo, int devAdress, int iLenght, short[] arr)
  525.         {
  526.             if ((int)Math.Ceiling(iLenght * 1.0 / 16) != arr.Length)
  527.             {
  528.                 throw new Exception("线圈数量与所赋值数量不匹配");
  529.             }
  530.             byte[] bytes = new byte[arr.Length * 2];
  531.             int index = 0;
  532.             foreach (var item in arr)
  533.             {
  534.                 byte[] temBytes = BitConverter.GetBytes(item);
  535.                 Array.Copy(temBytes, 0, bytes, index, temBytes.Length);
  536.                 index += temBytes.Length;
  537.             }
  538.             ComposeMessage(slaveStationNo, FunctionCode.WriteMultipleCoils, devAdress, iLenght, bytes);
  539.             if (slaveStationNo == targetStation && msgRecFlag && RecBytes != null && RecBytes.Length == 4)
  540.             {
  541.                 int startAddress = BitConverter.ToInt16(new byte[] { RecBytes[1], RecBytes[0] }, 0);
  542.                 int addressLen = BitConverter.ToInt16(new byte[] { RecBytes[3], RecBytes[2] }, 0);
  543.                 
  544.                 if (startAddress == devAdress && addressLen == iLenght)
  545.                 {
  546.                     return true;
  547.                 }
  548.                 else
  549.                 {
  550.                     return false;
  551.                 }
  552.             }
  553.             else
  554.             {
  555.                 return false;
  556.             }
  557.         }
  558.         /// <summary>
  559.         /// 读取从站多个寄存器的值
  560.         /// </summary>
  561.         /// <param name="slaveStationNo"></param>
  562.         /// <param name="devAdress">起始寄存器</param>
  563.         /// <param name="iLenght">寄存器数量</param>
  564.         public short[] ReadHoldingRegisters(int slaveStationNo, int devAdress, int iLenght)
  565.         {
  566.             ComposeMessage(slaveStationNo, FunctionCode.ReadHoldingRegisters, devAdress, iLenght);
  567.             if (slaveStationNo == targetStation && msgRecFlag && RecBytes != null)
  568.             {
  569.                 List<short> shortList = new List<short>();
  570.                 for (int i = 0; i < RecBytes.Length; i += 2)
  571.                 {
  572.                     shortList.Add(BitConverter.ToInt16(new byte[] { RecBytes[i + 1], RecBytes[i] }, 0));
  573.                 }
  574.                 return shortList.ToArray();
  575.             }
  576.             else
  577.             {
  578.                 return null;
  579.             }
  580.         }
  581.         /// <summary>
  582.         /// 读取单精度浮点数
  583.         /// </summary>
  584.         /// <param name="slaveStationNo">从站站点</param>
  585.         /// <param name="devAdress">起始地址</param>
  586.         /// <param name="iLenght">连续读取浮点数的个数</param>
  587.         /// <returns></returns>
  588.         public float[] ReadFloatRegisters(int slaveStationNo, int devAdress, int iLenght)
  589.         {
  590.             ComposeMessage(slaveStationNo, FunctionCode.ReadHoldingRegisters, devAdress, iLenght * 2);
  591.             if (slaveStationNo == targetStation && msgRecFlag && RecBytes != null)
  592.             {
  593.                 List<float> floatList = new List<float>();
  594.                 for (int i = 0; i < RecBytes.Length; i += 4)
  595.                 {
  596.                     floatList.Add(BitConverter.ToSingle(new byte[] { RecBytes[i + 1], RecBytes[i], RecBytes[i + 3], RecBytes[i + 2] }, 0));
  597.                 }
  598.                 return floatList.ToArray();
  599.             }
  600.             else
  601.             {
  602.                 return null;
  603.             }
  604.         }
  605.         /// <summary>
  606.         /// 向从站单个寄存器写入值
  607.         /// </summary>
  608.         /// <param name="slaveStationNo"></param>
  609.         /// <param name="devAdress"></param>
  610.         /// <param name="value"></param>
  611.         public bool WriteSingleRegister(int slaveStationNo, int devAdress, short value)
  612.         {
  613.             ComposeMessage(slaveStationNo, FunctionCode.WriteSingleRegister, devAdress, values: BitConverter.GetBytes(value));
  614.             if (slaveStationNo == targetStation && msgRecFlag && RecBytes != null && RecBytes.Length == 4)
  615.             {
  616.                 int startAddress = BitConverter.ToInt16(new byte[] { RecBytes[1], RecBytes[0] }, 0);
  617.                 int val = BitConverter.ToInt16(new byte[] { RecBytes[3], RecBytes[2] }, 0);
  618.                 if (startAddress == devAdress && val == value)
  619.                 {
  620.                     return true;
  621.                 }
  622.                 else
  623.                 {
  624.                     return false;
  625.                 }
  626.             }
  627.             else
  628.             {
  629.                 return false;
  630.             }
  631.         }
  632.         /// <summary>
  633.         /// 写入单精度浮点数
  634.         /// </summary>
  635.         /// <param name="slaveStationNo">从站站点</param>
  636.         /// <param name="devAdress">寄存器地址</param>
  637.         /// <param name="value">值</param>
  638.         /// <returns>true写入成功，false写入失败</returns>
  639.         public bool WriteFloatRegister(int slaveStationNo, int devAdress, float value)
  640.         {
  641.             //进行拆解组合
  642.             byte[] bytes = BitConverter.GetBytes(value);
  643.             byte[] valBytes= new byte[] { bytes[1], bytes[0], bytes[ 3], bytes[2] };
  644.             ComposeMessage(slaveStationNo, FunctionCode.WriteMultipleRegisters, devAdress, values: valBytes, fromBase: 4);
  645.             if (slaveStationNo == targetStation && msgRecFlag && RecBytes != null)
  646.             {
  647.                 short adress = BitConverter.ToInt16(new byte[] { RecBytes[1], RecBytes[0] }, 0);
  648.                 short registerCount = BitConverter.ToInt16(new byte[] { RecBytes[3], RecBytes[2] }, 0);
  649.                 if (adress == devAdress && registerCount == 2)
  650.                 {
  651.                     return true;
  652.                 }
  653.                 else
  654.                 {
  655.                     return false;
  656.                 }
  657.             }
  658.             else
  659.             {
  660.                 return false;
  661.             }
  662.         }
  663.         /// <summary>
  664.         /// 向从站多个寄存器写入值
  665.         /// </summary>
  666.         /// <param name="slaveStationNo"></param>
  667.         /// <param name="devAdress"></param>
  668.         /// <param name="iLenght"></param>
  669.         /// <param name="arr"></param>
  670.         public bool WriteMultipleRegisters(int slaveStationNo, int devAdress, int iLenght, short[] arr)
  671.         {
  672.             if (iLenght != arr.Length)
  673.             {
  674.                 throw new Exception("寄存器数量与所赋值数量不匹配");
  675.             }
  676.             byte[] bytes = new byte[arr.Length * 2];
  677.             int index = 0;
  678.             foreach (var item in arr)
  679.             {
  680.                 byte[] temBytes = BitConverter.GetBytes(item);
  681.                 byte[] temBytes2 = new byte[] { temBytes[1], temBytes[0] };
  682.                 Array.Copy(temBytes2, 0, bytes, index, temBytes2.Length);
  683.                 index += temBytes.Length;
  684.             }
  685.             ComposeMessage(slaveStationNo, FunctionCode.WriteMultipleRegisters, devAdress, iLenght, bytes,fromBase:4);
  686.             if (slaveStationNo == targetStation && msgRecFlag && RecBytes != null && RecBytes.Length == 4)
  687.             {
  688.                 int startAddress = BitConverter.ToInt16(new byte[] { RecBytes[1], RecBytes[0] }, 0);
  689.                 int addressLen = BitConverter.ToInt16(new byte[] { RecBytes[3], RecBytes[2] }, 0);
  690.                 if (startAddress == devAdress && addressLen == iLenght)
  691.                 {
  692.                     return true;
  693.                 }
  694.                 else
  695.                 {
  696.                     return false;
  697.                 }
  698.             }
  699.             else
  700.             {
  701.                 return false;
  702.             }
  703.         }
  704.         public void Dispose()
  705.         {
  706.             socketObject.Close();
  707.             socketObject.Dispose();
  708.         }
  709.     }

5，基于OPC服务的Modbus通信

5.1，OPC介绍

  1. 1，OPC协议
  2.  OPC是Object Linking and Embedding（OLE）for Process Controls的缩写，是微软公司得对象连接和嵌入技术在过程控制方面的应用。OPC主要基于微软的OLE（现在的Active X），COM（部件对象模型）和DCOM（分布式部件对象模型）技术。
  3.  
  4. 2，常见的OPCServer
  5.   1,KEPWSRE	2,SIMATIC NET 	3,PC ACCESS(PC ACCESS SMART) 4,Matrikon,Knight公司得OPC软件。
  7. 3，OPC读写方式。
  9. 3.1，同步方式
  10. 客户端发送请求，必须等待服务器响应全部完成后才能返回，期间处于等待状态。
  11. 多客户端向服务器操作时，客户端程序产生阻塞。
  12. 同步通讯适用于客户端较少，数据量较少的场合。
  14. 3.2，异步方式。
  15. 客户端发送请求后立即返回，不需要等待服务器的响应，可以进行其他操作。
  16. 服务器完成响应后再通知客户端。
  17. 相对于同步通讯，异步通讯的效率更高。
  19. 3.3，订阅模式。
  20. 客户端发送请求后立即返回，不需要等待服务器的响应，可以进行其他操作。
  21. 服务器有数据发生变化时，自动刷新客户端数据。
  22. 客户端只向服务端发送一次请求。
  24. 3.4，OPC存在同步写和异步写两种模式。
  26. 4，OPC访问接口方式。
  27. OPC主要包含两种接口：Custom标准接口和OLE自动化标准接口。
  28. 自定义接口是一组COM接口，主要用于C++语言的应用程序开发。
  29. 自动化接口是一组OLE接口，主要用于VB，DELPHI，Excel等基本脚本语言的应用程序开发。
  31. OPC基金会提供了OPCRcw动态链接库，OPC NET COM 和 OPC NET API，将复杂的OPC规范封装为简单的C#类，从而可以较为简单的实现数据访问。
  33. 5，OPCClient开发
  34. 使用OPCNetApi2.0，需要使用OPCNetAPI.dll。该dll由OPC Foundation提供，需付费注册会员。
  35. 使用自动化接口，需要使用OPCDAAuto.dll.不需付费注册，比较简单，但是不够灵活。
  36. 使用自定义接口，需要用到多个.Net Wrapper:OpcRcw.Ae.dll,OpcRcw.Bath.dll,OpcRcw.sec.dll，OpcRcw.Da.dll等

5.2,OPCDAAuto.dll链接

https://download.csdn.net/download/lingxiao16888/89517377

5.3，配置OPC服务软件KEPServerEx V4.0

创建Modbus通信频道

选择设备驱动为modbus serial

通信参数设置

 创建Tag

 点击OPCQuickClient 测试通信，通信OK。

5.4，代码

  1.  public partial class Form1 : Form
  2.     {
  3.         OPCHelper opc = new OPCHelper();
  4.         List<OPCItem> opcList = new List<OPCItem>();
  5.         public Form1()
  6.         {
  7.             InitializeComponent();
  8.             dataGridView1.AutoGenerateColumns = false;
  9.             btnRefresh_Click(null, null);
  10.             opc.AsyncWriteComplete += Opc_AsyncWriteComplete;
  11.         }
  12.  
  13.         private void Opc_AsyncWriteComplete(List<OPCItem> result)
  14.         {
  15.             dataGridView1.DataSource = null;
  16.             dataGridView1.DataSource = result;
  17.         }
  18.  
  19.         private void btnRefresh_Click(object sender, EventArgs e)
  20.         {
  21.             comboNode.Items.Clear();
  22.             //获取HostName
  23.             foreach (var item in Dns.GetHostAddresses(Environment.MachineName))
  24.             {
  25.                 if (comboNode.Items.Contains(Dns.GetHostEntry(item).HostName))
  26.                     continue;
  27.                 comboNode.Items.Add(Dns.GetHostEntry(item).HostName);
  28.  
  29.             }
  30.             //如果存在则将第一项设置为当前项
  31.             comboNode.SelectedIndex = comboNode.Items.Count > 0 ? 0 : -1;
  32.         }
  33.         private void comboNode_SelectedIndexChanged(object sender, EventArgs e)
  34.         {
  35.             if (comboNode.SelectedItem != null)
  36.             {
  37.                 //获取所有可用的OPC服务
  38.                 var servers = OPCHelper.GetOPCServers(comboNode.Text);
  39.                 comboServer.DataSource = servers;
  40.                 
  41.             }
  42.         }
  43.         private void comboServer_SelectedIndexChanged(object sender, EventArgs e)
  44.         {
  45.            
  46.         }
  47.         private void btnConnect_Click(object sender, EventArgs e)
  48.         {
  49.             if (btnConnect.Text.Equals("Connect", StringComparison.CurrentCultureIgnoreCase))
  50.             {
  51.                 if (comboServer.SelectedItem != null)
  52.                 {
  53.                     opcList.Clear();
  54.                     opc.Connected(comboServer.Text.Trim());
  55.                     //获取OPC上所有注册的tag
  56.                     if (opc.IsConnected)
  57.                     {
  58.                         var tags = opc.GetOPCServerTags();
  59.                         lsbBrowser.DataSource = tags;
  60.                         btnConnect.Text = "Disconnect";
  61.                         btnConnect.BackColor = Color.LightGreen;
  62.  
  63.                     }
  64.  
  65.  
  66.                 }
  67.                 else
  68.                 {
  69.                     MessageBox.Show("请先选择需要连接OPC服务！");
  70.                 }
  71.             }
  72.             else
  73.             {
  74.                 opc.Disconnect();
  75.                 if (!opc.IsConnected)
  76.                 {
  77.                     opcList.Clear();
  78.                     lsbBrowser.DataSource = null;
  79.                     dataGridView1.DataSource = null;
  80.                     btnConnect.Text = "Connect";
  81.                     btnConnect.BackColor = Color.Red;
  82.                 }
  83.             }
  84.            
  85.         }
  86.  
  87.         private void btnRead_Click(object sender, EventArgs e)
  88.         {
  89.             if(dataGridView1.Rows.Count==0)
  90.             {
  91.                 MessageBox.Show("请先添加需要读取的寄存器！");
  92.                 return;
  93.             }
  94.             if (opc.IsConnected)
  95.             {
  96.                 List<string> tags = opcList.Select(item => item.Tag).ToList();
  97.              var list=   opc.ReadMultipleRegisters<float>(tags,ckAsync.Checked);
  98.                 if (list != null)
  99.                 {
  100.                     StringBuilder sb = new StringBuilder();
  101.                     foreach (var item in list)
  102.                     {
  103.                         sb.AppendFormat("{0} ", item);
  104.                     }
  105.                     MessageBox.Show(sb.ToString());
  106.                 }
  107.             }
  108.             else
  109.             {
  110.                 MessageBox.Show("未连接服务！");
  111.                 return;
  112.             }
  113.         }
  114.        
  115.         private void lsbBrowser_DoubleClick(object sender, EventArgs e)
  116.         {
  117.             if (lsbBrowser.SelectedItem != null)
  118.             {
  119.                 string tag = lsbBrowser.SelectedItem.ToString();
  120.                 if (!opcList.Any(item => item.Tag.Equals(tag)))
  121.                 {
  122.                     opcList.Add(new OPCItem { Tag = tag });
  123.                 }
  124.                 dataGridView1.DataSource = null;
  125.                 dataGridView1.DataSource = opcList;
  126.             }
  127.         }
  128.  
  129.         private void dataGridView1_CellDoubleClick(object sender, DataGridViewCellEventArgs e)
  130.         {
  131.             if (dataGridView1.CurrentRow != null)
  132.             {
  133.                 //获取当前值
  134.                 if (opc.IsConnected)
  135.                 {
  136.                     DataGridViewRow row = dataGridView1.CurrentRow;
  137.                     string tag = row.Cells["Tag"].Value.ToString();
  138.                    
  139.                     if (row.Cells["Value"].Value == null)
  140.                     {
  141.                         btnRead_Click(null, null);
  142.                     }
  143.                     string val = row.Cells["Value"].Value?.ToString();
  144.  
  145.                     WriteFrm frm = new WriteFrm(tag, val);
  146.                     frm.StartPosition = FormStartPosition.CenterScreen;
  147.                     frm.ModifyCompleted += Frm_ModifyCompleted;
  148.                     frm.ShowDialog();
  149.                 }
  150.             }
  151.         }
  152.  
  153.         private void Frm_ModifyCompleted(string tag, float val, bool async)
  154.         {
  155.             if (opc.IsConnected)
  156.             {
  157.                 opc.WriteSingleValue<float>(tag, val, async);
  158.                 btnRead_Click(null, null);
  159.             }
  160.         }
  161.     }

  1.   //定义一个委托
  2.     public delegate void AsyncReadCompleteEventHandler(List<OPCItem> result);
  3.     /// <summary>
  4.     /// 基于OPC协议（对象连接与嵌入流程控制）的读写类
  5.     /// </summary>
  6.     public class OPCHelper
  7.     {
  8.         //--------------使用指南-----------------------
  9.         //第1步,使用静态方法获取本机或者局域网的hostName或者IpAdress所拥有的OPS服务
  10.         //  public static string[] GetOPCServers(string hostNameorAdress)
  11.         //第2步，使用实例化方法连接OPS服务
  12.         //   public bool Connected(string serverName)
  13.         //第3步，在连接的基础上使用实例化方法获取对应OPC服务器上所声明定义的所有可用寄存器
  14.         //   public string[] GetOPCServerTags()
  15.         //第4步，在连接的基础上使用实例化方法对寄存器进行读写
  16.         //   public void WriteMultipleRegisters(List<string> tags, List<object> values, bool async = true)
  17.         //   public List<T> ReadMultipleRegisters<T>(List<string> tags, bool async = true)
  18.         //第5步，如果使用的是异步读取，请在异步读取完成事件中接收值。
  19.         //   public event AsyncReadCompleteEventHandler AsyncWriteComplete;
  20.         //***********************************************************************************************
  21.         //***********************************************************************************************
  22.         //--------------特别注意事项----------------------
  23.         //第1点：
  24.         //OPC中数组Array有效的下标是从1开始，至于下标为0的值需要填充同类型的任意值，int类型一般采用0，string类型一般为"0"
  25.         //同样，下标1开始的才是有效的值才可以进行取值操作。
  26.         //如果按照C#中数组从下表0开始赋值取值操作，将抛出异常。
  27.         //
  28.         //第2点
  29.         //进行异步或者同步写入时
  30.         //OPC.SyncWrite(int NumItems, ref Array ServerHandles, ref Array Values, out Array Errors);
  31.         //参数Values必须是Object类型
  32.         //----------------------------------------------
  33.         //定义OPC相关对象
  34.         OPCServer kepServer = new OPCServer();
  35.         OPCGroups kepGroups;
  36.         OPCGroup kepGroup;
  37.         OPCBrowser kepBrowser;
  38.         Dictionary<int, string> currentItemId = new Dictionary<int, string>();
  39.         //定义OPC标签错误
  40.         Array iErrors;
  41.         bool isConnected;
  42.         /// <summary>
  43.         /// 服务句柄
  44.         /// </summary>
  45.         Array ServerHandles;
  46.         int cancelId;
  47.         /// <summary>
  48.         /// 异步读取完成事件
  49.         /// </summary>
  50.         public event AsyncReadCompleteEventHandler AsyncWriteComplete;
  51.         /// <summary>
  52.         /// OPC是否连接
  53.         /// </summary>
  54.         public bool IsConnected
  55.         {
  56.             get
  57.             {
  58.                 if (kepGroup == null)
  59.                 {
  60.                     isConnected = false;
  61.                 }
  62.                 return isConnected;
  63.             }
  64.         }
  65.         /// <summary>
  66.         /// 当前OPCOPCGroup服务,可用于寄存器的读取与写入
  67.         /// </summary>
  68.         public OPCGroup CurrentOPCGroup
  69.         {
  70.             get
  71.             {
  72.                 return kepGroup;
  73.             }
  74.         }
  75.         /// <summary>
  76.         /// 根据hostName或者Adress获取可用的OPC服务
  77.         /// </summary>
  78.         /// <param name="hostNameorAdress"></param>
  79.         /// <returns>返回可用的服务列表</returns>
  80.         public static List<string> GetOPCServers(string hostNameorAdress)
  81.         {
  82.             //获取hostName
  83.             string hostName = Dns.GetHostEntry(hostNameorAdress).HostName;
  84.             //注意：这里须使用Object接收值，若使用Var，后续进行遍历时将报异常
  85.             OPCServer opcServer = new OPCServer();
  86.             object result = opcServer.GetOPCServers(hostName);
  87.             List<string> list = new List<string>();
  88.             foreach (var item in (Array)result)
  89.             {
  90.                 list.Add(item.ToString());
  91.             }
  92.             return list;
  93.         }
  94.         /// <summary>
  95.         /// 连接OPC服务
  96.         /// </summary>
  97.         /// <param name="serverName">OPC服务名</param>
  98.         /// <returns></returns>
  99.         public bool Connected(string serverName)
  100.         {
  101.             try
  102.             {
  103.                 kepServer.Connect(serverName);
  104.                 isConnected = true;
  105.                 kepServer.OPCGroups.RemoveAll();
  106.                 kepGroups = kepServer.OPCGroups;
  107.                 kepGroups.DefaultGroupDeadband = 0;
  108.                 kepGroup = kepGroups.Add("Test");
  109.                 kepGroup.IsActive = true;
  110.                 kepGroup.IsSubscribed = true;
  111.                 kepGroup.UpdateRate = 250;
  112.                 //监视数据变化事件获取值
  113.                 // kepGroup.DataChange += KepGroup_DataChange;
  114.                 kepGroup.AsyncReadComplete += KepGroup_AsyncReadComplete;
  115.                 kepGroup.AsyncWriteComplete += KepGroup_AsyncWriteComplete;
  116.                 return true;
  117.             }
  118.             catch (Exception)
  119.             {
  120.                 return false;
  121.             }
  122.         }
  123.         private void KepGroup_AsyncWriteComplete(int TransactionID, int NumItems, ref Array ClientHandles, ref Array Errors)
  124.         {
  125.             // throw new NotImplementedException();
  126.         }
  127.         private void KepGroup_AsyncReadComplete(int TransactionID, int NumItems, ref Array ClientHandles, ref Array ItemValues, ref Array Qualities, ref Array TimeStamps, ref Array Errors)
  128.         {
  129.             List<OPCItem> opcItemList = new List<OPCItem>();
  130.             //获取值
  131.             for (int i = 0; i < NumItems; i++)
  132.             {
  133.                 //kepOPC有效所有从1开始
  134.                 int clientId = Convert.ToInt32(ClientHandles.GetValue(i + 1));
  135.                 string tag = null;
  136.                 if (currentItemId.Keys.Contains(clientId))
  137.                 {
  138.                     tag = currentItemId[clientId];
  139.                 }
  140.                 object val = ItemValues.GetValue(i + 1);
  141.                 //TimeStamps:是标准时间即格林时间是0时区计时，所以这里需要+8
  142.                 DateTime dt = Convert.ToDateTime(TimeStamps.GetValue(i + 1)).AddHours(8);
  143.                 opcItemList.Add(new OPCItem { Tag = tag, Value = val.ToString(), Time = dt });
  144.             }
  145.             AsyncWriteComplete?.Invoke(opcItemList);
  146.         }
  147.         /// <summary>
  148.         /// 获取OPC服务中所有已定义可用的Tag即定义的寄存器名
  149.         /// </summary>
  150.         /// <returns></returns>
  151.         public string[] GetOPCServerTags()
  152.         {
  153.             if (!IsConnected)
  154.             {
  155.                 throw new Exception("OPC服务未连接！");
  156.             }
  157.             kepBrowser = kepServer.CreateBrowser();
  158.             kepBrowser.ShowBranches();
  159.             kepBrowser.ShowLeafs(true);
  160.             List<string> list = new List<string>();
  161.             foreach (var item in kepBrowser)
  162.             {
  163.                 list.Add(item.ToString());
  164.             }
  165.             return list.ToArray();
  166.         }
  167.         /// <summary>
  168.         /// 向OPC的多个寄存器写入多个值
  169.         /// </summary>
  170.         /// <param name="tags">OPC服务上定义的寄存器名</param>
  171.         /// <param name="values">写入的值的集合</param>
  172.         /// <param name="async">是否异步写入</param>
  173.         public void WriteMultipleRegisters(List<string> tags, List<object> values, bool async = true)
  174.         {
  175.             if (!IsConnected)
  176.             {
  177.                 throw new Exception("OPC未连接，写入失败！");
  178.             }
  179.             if (kepGroup.OPCItems.Count > 0)
  180.             {
  181.                 //移除项目
  182.                 kepGroup.OPCItems.Remove(kepGroup.OPCItems.Count, ref ServerHandles, out iErrors);
  183.             }
  184.             var itemIds = new List<string>(tags);
  185.             //OPC Array中有效值是从下标1开始，所以需对下标0填充任意值,这里填充"0"
  186.             itemIds.Insert(0, "0");
  187.             Array ItemIds = itemIds.ToArray();
  188.             List<int> clientList = new List<int>();
  189.             //OPC Array中有效值是从下标1开始，所以需对下标0填充任意值,这里填充 0
  190.             clientList.Add(0);
  191.             for (int i = 0; i < tags.Count; i++)
  192.             {
  193.                 clientList.Add(i + 20);
  194.             }
  195.             Array ClientHandles = clientList.ToArray();
  196.             kepGroup.OPCItems.AddItems(tags.Count, ref ItemIds, ref ClientHandles, out ServerHandles, out iErrors);
  197.             //------------------特别注意----------------
  198.             //写入的值的类型只能是Object类型，如果是其他类型将抛出异常
  199.             List<object> writeValues = new List<object>(values);
  200.             writeValues.Insert(0,default(object));
  201.             Array valueArray = writeValues.ToArray();
  202.             if (async)
  203.             {
  204.                 kepGroup.AsyncWrite(1, ref ServerHandles, valueArray, out iErrors, 0, out cancelId);
  205.             }
  206.             else
  207.             {
  208.                 kepGroup.SyncWrite(1, ref ServerHandles, ref valueArray, out iErrors);
  209.             }
  210.         }
  211.         /// <summary>
  212.         /// 从OPC中读取多个寄存器的值,当选择异步模式时返回null，真实的值通过AsyncReadComplete事件获取
  213.         /// </summary>
  214.         /// <param name="tags">OPC服务上定义的寄存器名</param>
  215.         /// <param name="async">是否异步读取</param>
  216.         /// <returns>异步读取时返回null</returns>
  217.         public List<T> ReadMultipleRegisters<T>(List<string> tags, bool async = true)
  218.         {
  219.             if (!IsConnected)
  220.             {
  221.                 throw new Exception("OPC未连接，读取失败！");
  222.             }
  223.             if (kepGroup.OPCItems.Count > 0)
  224.             {
  225.                 //移除项目
  226.                 kepGroup.OPCItems.Remove(kepGroup.OPCItems.Count, ref ServerHandles, out iErrors);
  227.             }
  228.             var itemIds = new List<string>(tags);
  229.             //OPC Array中有效值是从下标1开始，所以需对下标0填充任意值,这里填充"0"
  230.             itemIds.Insert(0, "0");
  231.             Array ItemIds = itemIds.ToArray();
  232.             List<int> clientList = new List<int>();
  233.             //OPC Array中有效值是从下标1开始，所以需对下标0填充任意值,这里填充 0
  234.             clientList.Add(0);
  235.             for (int i = 0; i < tags.Count; i++)
  236.             {
  237.                 clientList.Add(i + 20);
  238.             }
  239.             Array ClientHandles = clientList.ToArray();
  240.             kepGroup.OPCItems.AddItems(tags.Count, ref ItemIds, ref ClientHandles, out ServerHandles, out iErrors);
  241.             //获取服务句柄，并写入到字典中
  242.             currentItemId.Clear();
  243.             for (int i = 0; i < ItemIds.Length - 1; i++)
  244.             {
  245.                 string tag = ItemIds.GetValue(i + 1).ToString();
  246.                 int id = Convert.ToInt32(ClientHandles.GetValue(i + 1));
  247.                 currentItemId.Add(id, tag);
  248.             }
  249.             if (async)
  250.             {
  251.                 kepGroup.AsyncRead(ItemIds.Length - 1, ref ServerHandles, out iErrors, 1, out cancelId);
  252.                 return null;
  253.             }
  254.             else
  255.             {
  256.                 Array result;
  257.                 object qualities;
  258.                 object tiemstamps;
  259.                 kepGroup.SyncRead(2, ItemIds.Length - 1, ref ServerHandles, out result, out iErrors, out qualities, out tiemstamps);
  260.                 List<T> list = new List<T>();
  261.                 for (int i = 0; i < result.Length; i++)
  262.                 {
  263.                     list.Add((T)result.GetValue(i + 1));
  264.                 }
  265.                 return list;
  266.             }
  267.         }
  268.         /// <summary>
  269.         /// 写入单个值
  270.         /// </summary>
  271.         /// <typeparam name="T"></typeparam>
  272.         /// <param name="tag">寄存器在OPC上的tag名</param>
  273.         /// <param name="value">写入的值</param>
  274.         /// <param name="async">是否异步</param>
  275.         public void WriteSingleValue<T>(string tag, T value, bool async = true)
  276.         {
  277.             WriteMultipleRegisters(new List<string> { tag }, new List<object> { value }, async);
  278.         }
  279.         /// <summary>
  280.         /// 读取单个值，当选择异步模式时返回null，真实的值通过AsyncReadComplete事件获取
  281.         /// </summary>
  282.         /// <typeparam name="T"></typeparam>
  283.         /// <param name="tag">寄存器在OPC上的tag名</param>
  284.         /// <param name="async">是否异步，异步时返回null，具体的值通过AsyncReadComplete事件获取</param>
  285.         public List<T> ReadSingleValue<T>(string tag, bool async = true)
  286.         {
  287.             return ReadMultipleRegisters<T>(new List<string> { tag }, async);
  288.         }
  289.         /// <summary>
  290.         /// 断开OPC连接
  291.         /// </summary>
  292.         /// <returns></returns>
  293.         public bool Disconnect()
  294.         {
  295.             try
  296.             {
  297.                 if (kepGroup == null)
  298.                 {
  299.                     isConnected = false;
  300.                     return false;
  301.                 }
  302.                 kepServer.Disconnect();
  303.                 isConnected = false;
  304.                 return true;
  305.             }
  306.             catch (Exception)
  307.             {
  308.                 return false;
  309.             }
  310.         }
  311.     }
  312.     public class OPCItem
  313.     {
  314.         public string Tag { get; set; }
  315.         public string Value { get; set; }
  316.         public DateTime Time { get; set; }
  317.        
  318.     }

6，Demo链接。

https://download.csdn.net/download/lingxiao16888/89517465

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/笔触狂放9/article/detail/806153
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号