溫馨提示×

溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊×
其他方式登錄
點擊 登錄注冊 即表示同意《億速云用戶服務條款》

Modbus RTU 通信工具設計

發(fā)布時間:2020-06-18 05:02:04 來源:網(wǎng)絡 閱讀:3973 作者:guangrou 欄目:編程語言
 

Modbus 是一個工業(yè)上常用的通訊協(xié)議、一種通訊約定。

ModBus 協(xié)議是應用層報文傳輸協(xié)議(OSI 模型第7層),它定義了一個與通信層無關的協(xié)議數(shù)據(jù)單元(PDU),即PDU=功能碼+數(shù)據(jù)域。
ModBus 協(xié)議能夠應用在不同類型的總線或網(wǎng)絡。對應不同的總線或網(wǎng)絡,Modbus 協(xié)議引入一些附加域映射成應用數(shù)據(jù)單元(ADU),即ADU=附加域+PDU。目前,Modbus 有下列三種通信方式:
1. 以太網(wǎng),對應的通信模式是Modbus TCP。
2. 異步串行傳輸(各種介質如有線RS-232-/422/485/;光纖、無線等),對應的通信模式是 Modbus RTU 或 Modbus ASCII。Modbus 的ASCII、RTU 協(xié)議規(guī)定了消息、數(shù)據(jù)的結構、命令和應答的方式,數(shù)據(jù)通訊采用Maser/Slave方式。
3. 高速令牌傳遞網(wǎng)絡,對應的通信模式是Modbus PLUS。

 

Modbus 需要對數(shù)據(jù)進行校驗,串行協(xié)議中除有奇偶校驗外,ASCII 模式采用LRC 校驗;RTU 模式采用16位CRC 校驗;TCP 模式?jīng)]有額外規(guī)定校驗,因為TCP 是一個面向連接的可靠協(xié)議。

 

Modbus 協(xié)議的應用中,最常用的是Modbus RTU 傳輸模式。

 

RTU 傳輸模式 

當設備使用RTU (Remote Terminal Unit) 模式在 Modbus  串行鏈路通信, 報文中每個8位字節(jié)含有兩個4位十六進制字符。這種模式的主要優(yōu)點是較高的數(shù)據(jù)密度,在相同的波特率下比ASCII 模式有更高的吞吐率。每個報文必須以連續(xù)的字符流傳送。 

 

RTU 模式每個字節(jié) ( 11 位 ) 的格式為:

       編碼系統(tǒng):  8位二進制。 報文中每個8位的字節(jié)含有兩個4位十六進制字符(0–9, A–F)

  Bits per Byte:  1 起始位

                   8 數(shù)據(jù)位, 首先發(fā)送最低有效位

                   1 位作為奇偶校驗

                   1 停止位

偶校驗是要求的,其它模式 ( 奇校驗, 無校驗 ) 也可以使用。為了保證與其它產(chǎn)品的最大兼容性,同時支持無校驗模式是建議的。默認校驗模式模式 必須為偶校驗。注:使用無校驗要求2 個停止位。 

 

字符的串行傳送方式:

每個字符或字節(jié)均由此順序發(fā)送(從左到右):最低有效位 (LSB) . . . 最高有效位 (MSB)

Modbus RTU 通信工具設計

圖1:RTU 模式位序列 

 

設備配置為奇校驗、偶校驗或無校驗都可以接受。如果無奇偶校驗,將傳送一個附加的停止位以填充字符幀:

Modbus RTU 通信工具設計

圖2:RTU 模式位序列 (無校驗的特殊情況)

 

幀檢驗域:循環(huán)冗余校驗 (CRC)

在RTU 模式包含一個對全部報文內容執(zhí)行的,基于循環(huán)冗余校驗 (CRC - Cyclical Redundancy Checking) 算法的錯誤檢驗域。

CRC 域檢驗整個報文的內容。不管報文有無奇偶校驗,均執(zhí)行此檢驗。

CRC 包含由兩個8位字節(jié)組成的一個16位值。  

CRC 域作為報文的最后的域附加在報文之后。計算后,首先附加低字節(jié),然后是高字節(jié)。CRC 高字節(jié)為報文發(fā)送的最后一個子節(jié)。

附加在報文后面的CRC 的值由發(fā)送設備計算。接收設備在接收報文時重新計算 CRC 的值,并將計算結果于實際接收到的CRC 值相比較。如果兩個值不相等,則為錯誤。

CRC 的計算,開始對一個16位寄存器預裝全1。 然后將報文中的連續(xù)的8位子節(jié)對其進行后續(xù)的計算。只有字符中的8個數(shù)據(jù)位參與生成CRC 的運算,起始位,停止位和校驗位不參與 CRC 計算。

CRC 的生成過程中, 每個 8–位字符與寄存器中的值異或。然后結果向最低有效位(LSB)方向移動(Shift) 1位,而最高有效位(MSB)位置充零。 然后提取并檢查 LSB:如果LSB 為1, 則寄存器中的值與一個固定的預置值異或;如果LSB 為 0, 則不進行異或操作。

這個過程將重復直到執(zhí)行完8次移位。完成最后一次(第8次)移位及相關操作后,下一個8位字節(jié)與寄存器的當前值異或,然后又同上面描述過的一樣重復8次。當所有報文中子節(jié)都運算之后得到的寄存器中的最終值,就是CRC。

當CRC 附加在報文之后時,首先附加低字節(jié),然后是高字節(jié)。

CRC 算法如下:

  1. private bool CheckResponse(byte[] response) 
  2.     //Perform a basic CRC check: 
  3.     byte[] CRC = new byte[2]; 
  4.     GetCRC(response, ref CRC); 
  5.     if (CRC[0] == response[response.Length - 2] && CRC[1] == response[response.Length - 1]) 
  6.     return true
  7.     else 
  8.     return false
  9.  
  10. private void GetCRC(byte[] message, ref byte[] CRC) 
  11.     //Function expects a modbus message of any length as well as a 2 byte CRC array in which to  
  12.     //return the CRC values: 
  13.  
  14.     ushort CRCFull = 0xFFFF; 
  15.     byte CRCHigh = 0xFF, CRCLow = 0xFF; 
  16.     char CRCLSB; 
  17.  
  18.     for (int i = 0; i < (message.Length) - 2; i++) 
  19.     { 
  20.     CRCFull = (ushort)(CRCFull ^ message[i]); 
  21.  
  22.     for (int j = 0; j < 8; j++) 
  23.     { 
  24.         CRCLSB = (char)(CRCFull & 0x0001); 
  25.         CRCFull = (ushort)((CRCFull >> 1) & 0x7FFF); 
  26.  
  27.         if (CRCLSB == 1) 
  28.         CRCFull = (ushort)(CRCFull ^ 0xA001); 
  29.     } 
  30.     } 
  31.     CRC[1] = CRCHigh = (byte)((CRCFull >> 8) & 0xFF); 
  32.     CRC[0] = CRCLow = (byte)(CRCFull & 0xFF); 

 

幀描述 (如下圖所示) :

Modbus RTU 通信工具設計

圖3:RTU 報文幀

注意:Modbus  RTU 幀最大為256字節(jié)。

 

下面是我為公司設計的一個 Modbus RTU 通信測試小工具,界面截圖如下:

Modbus RTU 通信工具設計

圖4:Modbus RTU 通信工具

 

我的通用Modbus RTU 動態(tài)庫,modbus.cs 如下:

  1. modbus.cs 
  2.  
  3. using System; 
  4. using System.Collections.Generic; 
  5. using System.Text; 
  6. using System.IO.Ports; 
  7. using System.Threading; 
  8.  
  9. namespace SerialPort_Lib 
  10.     public class modbus 
  11.     { 
  12.         private SerialPort sp = new SerialPort(); 
  13.         public string modbusStatus; 
  14.  
  15.         #region Constructor / Deconstructor 
  16.         public modbus() 
  17.         { 
  18.         } 
  19.         ~modbus() 
  20.         { 
  21.         } 
  22.         #endregion 
  23.  
  24.         #region Open / Close Procedures 
  25.         public bool Open(string portName, int baudRate, int databits, Parity parity, StopBits stopBits) 
  26.         { 
  27.             //Ensure port isn't already opened: 
  28.             if (!sp.IsOpen) 
  29.             { 
  30.                 //Assign desired settings to the serial port: 
  31.                 sp.PortName = portName; 
  32.                 sp.BaudRate = baudRate; 
  33.                 sp.DataBits = databits; 
  34.                 sp.Parity = parity; 
  35.                 sp.StopBits = stopBits; 
  36.                 //These timeouts are default and cannot be editted through the class at this point: 
  37.                 sp.ReadTimeout = -1; 
  38.                 sp.WriteTimeout = 10000; 
  39.  
  40.                 try 
  41.                 { 
  42.                     sp.Open(); 
  43.                 } 
  44.                 catch (Exception err) 
  45.                 { 
  46.                     modbusStatus = "Error opening " + portName + ": " + err.Message; 
  47.                     return false
  48.                 } 
  49.                 modbusStatus = portName + " opened successfully"
  50.                 return true
  51.             } 
  52.             else 
  53.             { 
  54.                 modbusStatus = portName + " already opened"
  55.                 return false
  56.             } 
  57.         } 
  58.         public bool Close() 
  59.         { 
  60.             //Ensure port is opened before attempting to close: 
  61.             if (sp.IsOpen) 
  62.             { 
  63.                 try 
  64.                 { 
  65.                     sp.Close(); 
  66.                 } 
  67.                 catch (Exception err) 
  68.                 { 
  69.                     modbusStatus = "Error closing " + sp.PortName + ": " + err.Message; 
  70.                     return false
  71.                 } 
  72.                 modbusStatus = sp.PortName + " closed successfully"
  73.                 return true
  74.             } 
  75.             else 
  76.             { 
  77.                 modbusStatus = sp.PortName + " is not open"
  78.                 return false
  79.             } 
  80.         } 
  81.         #endregion 
  82.  
  83.         #region CRC Computation 
  84.         private void GetCRC(byte[] message, ref byte[] CRC) 
  85.         { 
  86.             //Function expects a modbus message of any length as well as a 2 byte CRC array in which to  
  87.             //return the CRC values: 
  88.  
  89.             ushort CRCFull = 0xFFFF; 
  90.             byte CRCHigh = 0xFF, CRCLow = 0xFF; 
  91.             char CRCLSB; 
  92.  
  93.             for (int i = 0; i < (message.Length) - 2; i++) 
  94.             { 
  95.                 CRCFull = (ushort)(CRCFull ^ message[i]); 
  96.  
  97.                 for (int j = 0; j < 8; j++) 
  98.                 { 
  99.                     CRCLSB = (char)(CRCFull & 0x0001); 
  100.                     CRCFull = (ushort)((CRCFull >> 1) & 0x7FFF); 
  101.  
  102.                     if (CRCLSB == 1) 
  103.                         CRCFull = (ushort)(CRCFull ^ 0xA001); 
  104.                 } 
  105.             } 
  106.             CRC[1] = CRCHigh = (byte)((CRCFull >> 8) & 0xFF); 
  107.             CRC[0] = CRCLow = (byte)(CRCFull & 0xFF); 
  108.         } 
  109.         #endregion 
  110.  
  111.         #region Build Message 
  112.         private void BuildMessage(byte address, byte type, ushort start, ushort registers, ref byte[] message) 
  113.         { 
  114.             //Array to receive CRC bytes: 
  115.             byte[] CRC = new byte[2]; 
  116.  
  117.             message[0] = address; 
  118.             message[1] = type; 
  119.             message[2] = (byte)(start >> 8); 
  120.             message[3] = (byte)start; 
  121.             message[4] = (byte)(registers >> 8); 
  122.             message[5] = (byte)registers; 
  123.  
  124.             GetCRC(message, ref CRC); 
  125.             message[message.Length - 2] = CRC[0]; 
  126.             message[message.Length - 1] = CRC[1]; 
  127.         } 
  128.         #endregion 
  129.  
  130.         #region Check Response 
  131.         private bool CheckResponse(byte[] response) 
  132.         { 
  133.             //Perform a basic CRC check: 
  134.             byte[] CRC = new byte[2]; 
  135.             GetCRC(response, ref CRC); 
  136.             if (CRC[0] == response[response.Length - 2] && CRC[1] == response[response.Length - 1]) 
  137.                 return true
  138.             else 
  139.                 return false
  140.         } 
  141.         #endregion 
  142.  
  143.         #region Get Response 
  144.         private void GetResponse(ref byte[] response) 
  145.         { 
  146.             //There is a bug in .Net 2.0 DataReceived Event that prevents people from using this 
  147.             //event as an interrupt to handle data (it doesn't fire all of the time).  Therefore 
  148.             //we have to use the ReadByte command for a fixed length as it's been shown to be reliable. 
  149.             for (int i = 0; i < response.Length; i++) 
  150.             { 
  151.                 response[i] = (byte)(sp.ReadByte()); 
  152.             } 
  153.         } 
  154.         #endregion 
  155.  
  156.         #region GetModbusData 獲得接收數(shù)據(jù) 
  157.         public bool GetModbusData(ref byte[] values) 
  158.         { 
  159.             //Ensure port is open: 
  160.             if (sp.IsOpen) 
  161.             { 
  162.                 // 等待線程進入  
  163.                 //Monitor.Enter(sp); 
  164.  
  165.                 //Clear in/out buffers: 
  166.                 //sp.DiscardOutBuffer(); 
  167.                 //sp.DiscardInBuffer(); 
  168.  
  169.                 //Message is 1 addr + 1 type + N Data + 2 CRC 
  170.                      
  171.                 try 
  172.                 { 
  173.                     //GetResponse(ref readBuffer); 
  174.                     //string str = readBuffer.ToString(); 
  175.  
  176.                     int count = sp.BytesToRead; 
  177.                     if (count > 0) 
  178.                     { 
  179.                         byte[] readBuffer = new byte[count]; 
  180.  
  181.                         GetResponse(ref readBuffer); 
  182.  
  183.                         //   readData = new byte[29]; 
  184.                         //   Array.Copy(readBuffer, readData, readData.Length); 
  185.  
  186.                         // CRC 驗證 
  187.                         if (CheckResponse(readBuffer)) 
  188.                         { 
  189.                             //顯示輸入數(shù)據(jù) 
  190.                             values = readBuffer; 
  191.  
  192.                             modbusStatus = "Write successful"
  193.  
  194.                             sp.DiscardInBuffer(); 
  195.  
  196.                             //values = System.Text.Encoding.ASCII.GetString(readData); 
  197.                             return true
  198.                         } 
  199.                         else 
  200.                         { 
  201.                             modbusStatus = "CRC error"
  202.  
  203.                             sp.DiscardInBuffer(); 
  204.  
  205.                             return false
  206.                         } 
  207.                     } 
  208.                     else return false
  209.                 } 
  210.                 catch (Exception err) 
  211.                 { 
  212.                     modbusStatus = "Error in write event: " + err.Message; 
  213.  
  214.                     sp.DiscardInBuffer(); 
  215.  
  216.                     return false
  217.                 } 
  218.  
  219.                 //finally 
  220.                 //{ 
  221.                     // 通知其它對象 
  222.                     //Monitor.Pulse(sp); 
  223.                     // 釋放對象鎖  
  224.                     //Monitor.Exit(sp); 
  225.                 //} 
  226.             } 
  227.             else 
  228.             { 
  229.                 modbusStatus = "Serial port not open"
  230.                 return false
  231.             } 
  232.         } 
  233.         #endregion 
  234.  
  235.         #region SendModbusData 打包發(fā)送數(shù)據(jù) 
  236.         public bool SendModbusData(ref byte[] values) 
  237.         { 
  238.             //Ensure port is open: 
  239.             if (sp.IsOpen) 
  240.             { 
  241.                 //Clear in/out buffers: 
  242.                 sp.DiscardOutBuffer(); 
  243.                 sp.DiscardInBuffer(); 
  244.  
  245.                 //Function 3 response buffer: 
  246.                 byte[] response = new byte[values.Length + 2]; 
  247.                 Array.Copy(values, response, values.Length); 
  248.  
  249.                 //BuildMessage(address, (byte)3, start, registers, ref message); 
  250.  
  251.                 //打包帶有 CRC 驗證的modbus 數(shù)據(jù)包: 
  252.                 byte[] CRC = new byte[2]; 
  253.                 GetCRC(response, ref CRC); 
  254.                 response[response.Length - 2] = CRC[0]; 
  255.                 response[response.Length - 1] = CRC[1]; 
  256.  
  257.                 values = response; //返回帶有 CRC 驗證的modbus 數(shù)據(jù)包 
  258.  
  259.                 //Send modbus message to Serial Port: 
  260.                 try 
  261.                 { 
  262.                     sp.Write(response, 0, response.Length); 
  263.                     //GetResponse(ref response); 
  264.                     return true
  265.                 } 
  266.                 catch (Exception err) 
  267.                 { 
  268.                     modbusStatus = "Error in read event: " + err.Message; 
  269.                     return false
  270.                 } 
  271.                 //Evaluate message: 
  272.                 //if (CheckResponse(response)) 
  273.                 //{ 
  274.                 //    //Return requested register values: 
  275.                 //    for (int i = 0; i < (response.Length - 5) / 2; i++) 
  276.                 //    { 
  277.                 //        values[i] = response[2 * i + 3]; 
  278.                 //        values[i] <<= 8; 
  279.                 //        values[i] += response[2 * i + 4]; 
  280.                 //    } 
  281.                 //    modbusStatus = "Read successful"; 
  282.                 //    return true; 
  283.                 //} 
  284.                 //else 
  285.                 //{ 
  286.                 //    modbusStatus = "CRC error"; 
  287.                 //    return false; 
  288.                 //} 
  289.             } 
  290.             else 
  291.             { 
  292.                 modbusStatus = "Serial port not open"
  293.                 return false
  294.             } 
  295.  
  296.         } 
  297.         #endregion 
  298.  
  299.     } 

 

調用的主要代碼如下:

  1. modbus類的winform調用代碼 
  2.  
  3. public partial class FormConfig : Form,IModbusData 
  4.     //業(yè)務處理類 
  5.     B_ModbusData ModbusDataBLL = new B_ModbusData(); 
  6.  
  7.     modbus mb = new modbus(); 
  8.     //SerialPort sp = new SerialPort(); 
  9.     System.Timers.Timer timer = new System.Timers.Timer(); 
  10.  
  11.     public FormConfig() 
  12.     { 
  13.         InitializeComponent(); 
  14.         
  15.         timer.Elapsed += new ElapsedEventHandler(timer_Elapsed); 
  16.     } 
  17.  
  18.     #region Timer Elapsed 事件處理程序 
  19.     bool runEnd = true
  20.     void timer_Elapsed(object sender, ElapsedEventArgs e) 
  21.     { 
  22.         if (runEnd == true
  23.         { 
  24.             runEnd = false
  25.             PollFunction(); 
  26.             runEnd = true
  27.         } 
  28.     } 
  29.  
  30.     //定時器調用方法 
  31.     private void PollFunction() 
  32.     { 
  33.         byte[] values = null
  34.         try 
  35.         { 
  36.             mb.GetModbusData(ref values); 
  37.             //while (!mb.SendFc3(Convert.ToByte(txtSlaveID.Text), pollStart, pollLength, ref values)) ; 
  38.         } 
  39.         catch (Exception err) 
  40.         { 
  41.             DoGUIStatus("Error in modbus read: " + err.Message); 
  42.         } 
  43.  
  44.         if (values != null
  45.         { 
  46.             //業(yè)務處理 
  47.             byte[] sendData = ModbusDataProcess(values); 
  48.         } 
  49.     } 
  50.     #endregion 
  51.  
  52.     #region IModbusData 接口成員處理 
  53.     public byte[] ModbusDataProcess(byte[] _data) 
  54.     { 
  55.        byte[] sendData = ModbusDataBLL.ModbusDataProcess(_data); 
  56.  
  57.        // CRC驗證,并打包發(fā)送數(shù)據(jù)。 
  58.        mb.SendModbusData(ref sendData); 
  59.  
  60.        return sendData; 
  61.     } 
  62.     #endregion 

 

其實,三步就能成功調用:

  1. modbus mb = new modbus(); 
  2. mb.GetModbusData(ref values); // 從串口設備獲得數(shù)據(jù)。 
  3. byte[] sendData = ModbusDataBLL.ModbusDataProcess(values); // 你的業(yè)務處理,并產(chǎn)生最終返回數(shù)據(jù)。 
  4. mb.SendModbusData(ref sendData); // CRC驗證,并打包發(fā)送數(shù)據(jù)。 


主要代碼已全部提供,由于工作原因暫不提供完整工具源代碼,見諒!

(完)

 
向AI問一下細節(jié)

免責聲明:本站發(fā)布的內容(圖片、視頻和文字)以原創(chuàng)、轉載和分享為主,文章觀點不代表本網(wǎng)站立場,如果涉及侵權請聯(lián)系站長郵箱:is@yisu.com進行舉報,并提供相關證據(jù),一經(jīng)查實,將立刻刪除涉嫌侵權內容。

AI