VB.NET的modbus代码，可以编译DLL供其他文件调用

看到有网友要，就找来了

1. &#65279;''' <summary>
   
2. ''' Modbus通讯的基础模块，以Modbus通讯协议运行
   
3. ''' </summary>
   
4. ''' <remarks></remarks>
   
5. Public Class Modbus
   
6. #Region "枚举"
   
7. 
   
8.     ''' <summary>
   
9.     ''' 串口的状态：正常、超时、出错
   
10.     ''' </summary>
    
11.     ''' <remarks></remarks>
    
12.     Public Enum enCommStateType As Byte
    
13.         ''' <summary>
    
14.         ''' 正常
    
15.         ''' </summary>
    
16.         ''' <remarks></remarks>
    
17.         Normal = 0
    
18. 
    
19.         ''' <summary>
    
20.         ''' 超时
    
21.         ''' </summary>
    
22.         ''' <remarks></remarks>
    
23.         OutTime = 1
    
24. 
    
25.         ''' <summary>
    
26.         ''' 出错
    
27.         ''' </summary>
    
28.         ''' <remarks></remarks>
    
29.         Failure = 2
    
30.     End Enum
    
31. 
    
32.     ''' <summary>
    
33.     ''' 串口工作步骤
    
34.     ''' </summary>
    
35.     ''' <remarks></remarks>
    
36.     Public Enum enWorkStateType
    
37.         ''' <summary>
    
38.         ''' 空闲
    
39.         ''' </summary>
    
40.         ''' <remarks></remarks>
    
41.         Idle = 1
    
42. 
    
43.         ''' <summary>
    
44.         ''' 接收功能码
    
45.         ''' </summary>
    
46.         ''' <remarks></remarks>
    
47.         ReceiveCommand = 2
    
48. 
    
49.         ''' <summary>
    
50.         ''' 接收命令信息
    
51.         ''' </summary>
    
52.         ''' <remarks></remarks>
    
53.         ReceiceCommandInfo = 3
    
54. 
    
55.         ''' <summary>
    
56.         ''' 接收数据
    
57.         ''' </summary>
    
58.         ''' <remarks></remarks>
    
59.         ReceiveData = 4
    
60. 
    
61.         ''' <summary>
    
62.         ''' 回应
    
63.         ''' </summary>
    
64.         ''' <remarks></remarks>
    
65.         Answer = 5
    
66. 
    
67.         ''' <summary>
    
68.         ''' 发送命令
    
69.         ''' </summary>
    
70.         ''' <remarks></remarks>
    
71.         SendCommand = 6
    
72. 
    
73.         ''' <summary>
    
74.         ''' 等待回应
    
75.         ''' </summary>
    
76.         ''' <remarks></remarks>
    
77.         WaitAnswer = 7
    
78. 
    
79.         ''' <summary>
    
80.         ''' 得到回应数据字节数
    
81.         ''' </summary>
    
82.         ''' <remarks></remarks>
    
83.         GetAnswerBytes = 9
    
84. 
    
85.         ''' <summary>
    
86.         ''' 回应的最后部分
    
87.         ''' </summary>
    
88.         ''' <remarks></remarks>
    
89.         AnswerLast = 10
    
90. 
    
91.         ''' <summary>
    
92.         ''' 接收最后部分
    
93.         ''' </summary>
    
94.         ''' <remarks></remarks>
    
95.         ReceiveCRC = 11
    
96.     End Enum
    
97. 
    
98.     ''' <summary>
    
99.     ''' 通讯模块允许的通讯命令编码。
    
100.     ''' </summary>
     
101.     ''' <remarks></remarks>
     
102.     Public Enum enCommandType As Byte
     
103.         ''' <summary>
     
104.         ''' 读线圈，每个字节表示8个线圈
     
105.         ''' </summary>
     
106.         ''' <remarks></remarks>
     
107.         读线圈 = 1
     
108. 
     
109.         ''' <summary>
     
110.         ''' 读离散输入，只读的状态，每个字节表示8个状态
     
111.         ''' </summary>
     
112.         ''' <remarks></remarks>
     
113.         读离散输入 = 2
     
114. 
     
115.         ''' <summary>
     
116.         ''' 强置单个线圈，通断标志：FF 00 ，置线圈ON；00 00 置线圈0FF。
     
117.         ''' </summary>
     
118.         ''' <remarks></remarks>
     
119.         强置单线圈 = 5
     
120. 
     
121.         ''' <summary>
     
122.         ''' 强置多线圈，强置一串连续逻辑线圈的通断。
     
123.         ''' </summary>
     
124.         ''' <remarks></remarks>
     
125.         强置多线圈 = 15
     
126. 
     
127.         ''' <summary>
     
128.         ''' 读取保持寄存器
     
129.         ''' </summary>
     
130.         ''' <remarks></remarks>
     
131.         读取保持寄存器 = 3
     
132. 
     
133.         ''' <summary>
     
134.         '''读取输入寄存器
     
135.         ''' </summary>
     
136.         ''' <remarks></remarks>
     
137.         读取输入寄存器 = 4
     
138. 
     
139.         ''' <summary>
     
140.         ''' 预置单寄存器,把具体二进值装入一个保持寄存器
     
141.         ''' </summary>
     
142.         ''' <remarks></remarks>
     
143.         预置单寄存器 = 6
     
144. 
     
145.         ''' <summary>
     
146.         ''' 预置多寄存器，把具体的二进制值装入一串连续的保持寄存器。
     
147.         ''' </summary>
     
148.         ''' <remarks></remarks>
     
149.         预置多寄存器 = 16
     
150. 
     
151.         ''' <summary>
     
152.         ''' 写多个保持寄存器,并返回多个保持寄存器的数据。(非Modbus标准命令)
     
153.         ''' </summary>
     
154.         ''' <remarks></remarks>
     
155.         读写多寄存器 = 23
     
156.     End Enum
     
157. 
     
158.     ''' <summary>
     
159.     ''' 节点工作模式：主模式、从模式
     
160.     ''' </summary>
     
161.     ''' <remarks></remarks>
     
162.     Public Enum enMasterType
     
163.         ''' <summary>
     
164.         ''' 主站
     
165.         ''' </summary>
     
166.         ''' <remarks></remarks>
     
167.         Master = 1
     
168. 
     
169.         ''' <summary>
     
170.         ''' 从站
     
171.         ''' </summary>
     
172.         ''' <remarks></remarks>
     
173.         Slaver = 2
     
174.     End Enum
     
175. 
     
176. #End Region
     

复制代码

1. #Region "属性和结构"
   
2. 
   
3.     ''' <summary>
   
4.     ''' Modbus通讯模块是以这个命令结构来传递命令和数据的。本命令结构包含了Modbus通讯所需要的各种数据。
   
5.     ''' </summary>
   
6.     ''' <remarks></remarks>
   
7.     Public Structure stCommand
   
8.         ''' <summary>
   
9.         ''' 当模块为Modbus主站，向从站发送命令时，本参数记录需要接收命令的从站地址。
   
10.         ''' 当模块为从站，本参数记录本站地址
    
11.         ''' </summary>
    
12.         ''' <remarks></remarks>
    
13.         Public AddressOfReceive As Byte
    
14. 
    
15.         ''' <summary>
    
16.         ''' 命令代码
    
17.         ''' </summary>
    
18.         ''' <remarks></remarks>
    
19.         Public Command As enCommandType
    
20. 
    
21.         ''' <summary>
    
22.         ''' 读数据偏置量
    
23.         ''' </summary>
    
24.         ''' <remarks></remarks>
    
25.         Public ReadAddress As UInt16
    
26. 
    
27.         ''' <summary>
    
28.         ''' 读数据单位总数
    
29.         ''' </summary>
    
30.         ''' <remarks></remarks>
    
31.         Public ReadCount As UInt16
    
32. 
    
33.         ''' <summary>
    
34.         ''' 写数据偏置量
    
35.         ''' </summary>
    
36.         ''' <remarks></remarks>
    
37.         Public WriteAddress As UInt16
    
38. 
    
39.         ''' <summary>
    
40.         ''' 写数据单位总数
    
41.         ''' </summary>
    
42.         ''' <remarks></remarks>
    
43.         Public WriteCount As UInt16
    
44. 
    
45.         ''' <summary>
    
46.         ''' 数据字节数
    
47.         ''' </summary>
    
48.         ''' <remarks></remarks>
    
49.         Public DataLen As UInt16
    
50. 
    
51.         ''' <summary>
    
52.         ''' 数据数组
    
53.         ''' </summary>
    
54.         ''' <remarks></remarks>
    
55.         Public Data() As Byte
    
56.     End Structure
    
57. 
    
58.     ''' <summary>
    
59.     ''' 通讯状态
    
60.     ''' </summary>
    
61.     ''' <remarks></remarks>
    
62.     Public Structure stState
    
63.         ''' <summary>
    
64.         ''' 通讯正常或故障状态
    
65.         ''' </summary>
    
66.         ''' <remarks></remarks>
    
67.         Public PortState As enCommStateType
    
68. 
    
69.         ''' <summary>
    
70.         ''' 通讯时所处的过程阶段状态
    
71.         ''' </summary>
    
72.         ''' <remarks></remarks>
    
73.         Public WorkState As enWorkStateType
    
74. 
    
75.         ''' <summary>
    
76.         ''' 通讯信息
    
77.         ''' </summary>
    
78.         ''' <remarks></remarks>
    
79.         Public Msg As String
    
80.     End Structure
    
81. 
    
82.     ''' <summary>
    
83.     ''' 读取、设置串口波特率
    
84.     ''' </summary>
    
85.     ''' <value>[in]波特率只能为 9600、19200、38400 。</value>
    
86.     ''' <returns>返回当前波特率</returns>
    
87.     ''' <remarks>波特率只能为 9600、19200、38400。</remarks>
    
88.     Public Property m_iBaudRate() As Long
    
89.         Get
    
90.             Return SerialPort1.BaudRate
    
91.         End Get
    
92.         Set(ByVal Value As Long)
    
93.             Select Case Value
    
94.                 Case 9600, 19200, 38400
    
95.                     SerialPort1.BaudRate = Value
    
96.                 Case Else
    
97.                     SerialPort1.BaudRate = 9600
    
98.             End Select
    
99.         End Set
    
100.     End Property
     
101. 
     
102.     ''' <summary>
     
103.     ''' 设置、读取串口号
     
104.     ''' </summary>
     
105.     ''' <value></value>
     
106.     ''' <returns></returns>
     
107.     ''' <remarks>可通过GetSerialPortNames获取所有的串口名称</remarks>
     
108.     Public Property m_strPortName() As String
     
109.         Get
     
110.             Return SerialPort1.PortName
     
111.         End Get
     
112.         Set(ByVal Value As String)
     
113.             Try
     
114.                 SerialPort1.Close()
     
115.             Catch ex As Exception
     
116. 
     
117.             End Try
     
118. 
     
119.             Try
     
120.                 SerialPort1.PortName = Value
     
121.                 SerialPort1.Open()      '需要保持串口一直打开
     
122.             Catch ex As Exception
     
123.                 MsgBox(ex.ToString)
     
124.             End Try
     
125.         End Set
     
126.     End Property
     
127. 
     
128.     Private enModbusMaster As enMasterType
     
129.     ''' <summary>
     
130.     ''' 设置、返回串口通讯PC机所扮演的主从角色
     
131.     ''' </summary>
     
132.     ''' <value></value>
     
133.     ''' <returns></returns>
     
134.     ''' <remarks>
     
135.     ''' 角色为主，则需要承担通讯的发起者的角色，接收数据不需要回应。
     
136.     ''' 角色为从，则没有主动发出信息的权利，只有当通讯的主节点要求时才能发送数据，对于主节点的命令需要回复
     
137.     ''' </remarks>
     
138.     Public Property m_enModbusMaster() As enMasterType
     
139.         Get
     
140.             Return enModbusMaster
     
141.         End Get
     
142.         Set(ByVal Value As enMasterType)
     
143.             Try
     
144.                 enModbusMaster = Value
     
145.                 m_State.WorkState = enWorkStateType.Idle
     
146.                 m_State.PortState = enCommStateType.Normal
     
147.                 m_State.Msg = ""
     
148.             Catch ex As Exception
     
149.                 MsgBox(ex.ToString)
     
150.             End Try
     
151.         End Set
     
152.     End Property
     
153. 
     
154.     ''' <summary>
     
155.     ''' Modbus通讯状态
     
156.     ''' </summary>
     
157.     ''' <value></value>
     
158.     ''' <returns></returns>
     
159.     ''' <remarks></remarks>
     
160.     Public ReadOnly Property m_ModbusState() As stState
     
161.         Get
     
162.             Return m_State
     
163.         End Get
     
164.     End Property
     
165. #End Region
     
166. 
     
167. #Region "CRC 字节值表"
     
168.     ' CRC 高位字节值表
     
169.     Private auchCRCHi() As Byte = New Byte() { _
     
170.                                                 &H0, &HC1, &H81, &H40, &H1, &HC0, &H80, &H41, &H1, &HC0, _
     
171.                                                 &H80, &H41, &H0, &HC1, &H81, &H40, &H1, &HC0, &H80, &H41, _
     
172.                                                 &H0, &HC1, &H81, &H40, &H0, &HC1, &H81, &H40, &H1, &HC0, _
     
173.                                                 &H80, &H41, &H1, &HC0, &H80, &H41, &H0, &HC1, &H81, &H40, _
     
174.                                                 &H0, &HC1, &H81, &H40, &H1, &HC0, &H80, &H41, &H0, &HC1, _
     
175.                                                 &H81, &H40, &H1, &HC0, &H80, &H41, &H1, &HC0, &H80, &H41, _
     
176.                                                 &H0, &HC1, &H81, &H40, &H1, &HC0, &H80, &H41, &H0, &HC1, _
     
177.                                                 &H81, &H40, &H0, &HC1, &H81, &H40, &H1, &HC0, &H80, &H41, _
     
178.                                                 &H0, &HC1, &H81, &H40, &H1, &HC0, &H80, &H41, &H1, &HC0, _
     
179.                                                 &H80, &H41, &H0, &HC1, &H81, &H40, &H0, &HC1, &H81, &H40, _
     
180.                                                 &H1, &HC0, &H80, &H41, &H1, &HC0, &H80, &H41, &H0, &HC1, _
     
181.                                                 &H81, &H40, &H1, &HC0, &H80, &H41, &H0, &HC1, &H81, &H40, _
     
182.                                                 &H0, &HC1, &H81, &H40, &H1, &HC0, &H80, &H41, &H1, &HC0, _
     
183.                                                 &H80, &H41, &H0, &HC1, &H81, &H40, &H0, &HC1, &H81, &H40, _
     
184.                                                 &H1, &HC0, &H80, &H41, &H0, &HC1, &H81, &H40, &H1, &HC0, _
     
185.                                                 &H80, &H41, &H1, &HC0, &H80, &H41, &H0, &HC1, &H81, &H40, _
     
186.                                                 &H0, &HC1, &H81, &H40, &H1, &HC0, &H80, &H41, &H1, &HC0, _
     
187.                                                 &H80, &H41, &H0, &HC1, &H81, &H40, &H1, &HC0, &H80, &H41, _
     
188.                                                 &H0, &HC1, &H81, &H40, &H0, &HC1, &H81, &H40, &H1, &HC0, _
     
189.                                                 &H80, &H41, &H0, &HC1, &H81, &H40, &H1, &HC0, &H80, &H41, _
     
190.                                                 &H1, &HC0, &H80, &H41, &H0, &HC1, &H81, &H40, &H1, &HC0, _
     
191.                                                 &H80, &H41, &H0, &HC1, &H81, &H40, &H0, &HC1, &H81, &H40, _
     
192.                                                 &H1, &HC0, &H80, &H41, &H1, &HC0, &H80, &H41, &H0, &HC1, _
     
193.                                                 &H81, &H40, &H0, &HC1, &H81, &H40, &H1, &HC0, &H80, &H41, _
     
194.                                                 &H0, &HC1, &H81, &H40, &H1, &HC0, &H80, &H41, &H1, &HC0, _
     
195.                                                 &H80, &H41, &H0, &HC1, &H81, &H40}
     
196. 
     
197.     ' CRC低位字节值表
     
198.     Private auchCRCLo() As Byte = New Byte() { _
     
199.                                                 &H0, &HC0, &HC1, &H1, &HC3, &H3, &H2, &HC2, &HC6, &H6, _
     
200.                                                 &H7, &HC7, &H5, &HC5, &HC4, &H4, &HCC, &HC, &HD, &HCD, _
     
201.                                                 &HF, &HCF, &HCE, &HE, &HA, &HCA, &HCB, &HB, &HC9, &H9, _
     
202.                                                 &H8, &HC8, &HD8, &H18, &H19, &HD9, &H1B, &HDB, &HDA, &H1A, _
     
203.                                                 &H1E, &HDE, &HDF, &H1F, &HDD, &H1D, &H1C, &HDC, &H14, &HD4, _
     
204.                                                 &HD5, &H15, &HD7, &H17, &H16, &HD6, &HD2, &H12, &H13, &HD3, _
     
205.                                                 &H11, &HD1, &HD0, &H10, &HF0, &H30, &H31, &HF1, &H33, &HF3, _
     
206.                                                 &HF2, &H32, &H36, &HF6, &HF7, &H37, &HF5, &H35, &H34, &HF4, _
     
207.                                                 &H3C, &HFC, &HFD, &H3D, &HFF, &H3F, &H3E, &HFE, &HFA, &H3A, _
     
208.                                                 &H3B, &HFB, &H39, &HF9, &HF8, &H38, &H28, &HE8, &HE9, &H29, _
     
209.                                                 &HEB, &H2B, &H2A, &HEA, &HEE, &H2E, &H2F, &HEF, &H2D, &HED, _
     
210.                                                 &HEC, &H2C, &HE4, &H24, &H25, &HE5, &H27, &HE7, &HE6, &H26, _
     
211.                                                 &H22, &HE2, &HE3, &H23, &HE1, &H21, &H20, &HE0, &HA0, &H60, _
     
212.                                                 &H61, &HA1, &H63, &HA3, &HA2, &H62, &H66, &HA6, &HA7, &H67, _
     
213.                                                 &HA5, &H65, &H64, &HA4, &H6C, &HAC, &HAD, &H6D, &HAF, &H6F, _
     
214.                                                 &H6E, &HAE, &HAA, &H6A, &H6B, &HAB, &H69, &HA9, &HA8, &H68, _
     
215.                                                 &H78, &HB8, &HB9, &H79, &HBB, &H7B, &H7A, &HBA, &HBE, &H7E, _
     
216.                                                 &H7F, &HBF, &H7D, &HBD, &HBC, &H7C, &HB4, &H74, &H75, &HB5, _
     
217.                                                 &H77, &HB7, &HB6, &H76, &H72, &HB2, &HB3, &H73, &HB1, &H71, _
     
218.                                                 &H70, &HB0, &H50, &H90, &H91, &H51, &H93, &H53, &H52, &H92, _
     
219.                                                 &H96, &H56, &H57, &H97, &H55, &H95, &H94, &H54, &H9C, &H5C, _
     
220.                                                 &H5D, &H9D, &H5F, &H9F, &H9E, &H5E, &H5A, &H9A, &H9B, &H5B, _
     
221.                                                 &H99, &H59, &H58, &H98, &H88, &H48, &H49, &H89, &H4B, &H8B, _
     
222.                                                 &H8A, &H4A, &H4E, &H8E, &H8F, &H4F, &H8D, &H4D, &H4C, &H8C, _
     
223.                                                 &H44, &H84, &H85, &H45, &H87, &H47, &H46, &H86, &H82, &H42, _
     
224.                                                 &H43, &H83, &H41, &H81, &H80, &H40}
     
225. 
     
226. #End Region
     
227. 
     
228.     '获得组件对象
     
229.     Private TimerOp As New System.Timers.Timer
     
230.     Private SerialPort1 As New System.IO.Ports.SerialPort
     
231. 
     
232.     '命令结构
     
233.     Private m_Cmd As New stCommand
     
234.     Private m_State As New stState
     
235. 
     
236.     '输入输出暂存
     
237.     Private uchCRCHi As Byte = &HFF     ' 高CRC字节初始化
     
238.     Private uchCRCLo As Byte = &HFF     '低CRC 字节初始化  
     
239. 
     
240.     ''' <summary>
     
241.     ''' 通讯结束时发出的消息
     
242.     ''' </summary>
     
243.     ''' <param name="stCmd">[in/out]包含通讯命令所有信息的命令结构</param>
     
244.     ''' <remarks></remarks>
     
245.     Public Event CommunicationOverEvent(ByVal stCmd As stCommand, ByVal stState As stState)
     
246. 
     
247.     ''' <summary>
     
248.     ''' 输入通讯节点地址， 对串口和时钟进行初始化
     
249.     ''' </summary>
     
250.     ''' <param name="BusAddress">[in]节点地址</param>
     
251.     ''' <param name="MasterOrSlaver">[in]节点主从设置</param>
     
252.     ''' <param name="OutTimeSetting">[in]通讯超时设置</param>
     
253.     ''' <param name="PortName">[in]模块使用的串口名称</param>
     
254.     ''' <remarks></remarks>
     
255.     Public Sub New(ByVal BusAddress As Byte, ByVal MasterOrSlaver As enMasterType, ByVal PortName As String, ByVal OutTimeSetting As Int16)
     
256. 
     
257.         '设置时钟超时参数
     
258.         TimerInit(OutTimeSetting)
     
259. 
     
260.         '设置Modbus主从模式
     
261.         enModbusMaster = MasterOrSlaver
     
262. 
     
263.         '设置Modbus节点地址
     
264.         If enModbusMaster = enMasterType.Slaver Then
     
265.             m_Cmd.AddressOfReceive = BusAddress
     
266.         End If
     
267. 
     
268.         '初始化Modbus工作状态
     
269.         m_State.WorkState = enWorkStateType.Idle
     
270.         m_State.PortState = enCommStateType.Normal
     
271. 
     
272.         '串口初始化
     
273.         SerialPortInit(PortName)
     
274.     End Sub
     
275. 
     
276. 
     
277. #Region "串口"
     
278. 
     
279.     ''' <summary>
     
280.     ''' 初始化串口8位数据位2位停止位，无校验，波特率38400，写缓存4096。设置了串口的事件处理函数。
     
281.     ''' </summary>
     
282.     ''' <remarks></remarks>
     
283.     Private Sub SerialPortInit(ByVal PortName As String)
     
284.         SerialPort1.StopBits = IO.Ports.StopBits.One
     
285.         SerialPort1.Parity = IO.Ports.Parity.Odd
     
286.         SerialPort1.BaudRate = 38400
     
287.         SerialPort1.DataBits = 8
     
288.         SerialPort1.ReceivedBytesThreshold = 1
     
289.         SerialPort1.WriteBufferSize = 4096
     
290. 
     
291.         AddHandler SerialPort1.DataReceived, AddressOf OnSerialPortReceivedEvent       '指定事件触发函数
     
292.         AddHandler SerialPort1.ErrorReceived, AddressOf OnSerialErrorReceivedEvent
     
293. 
     
294.         m_strPortName = PortName
     
295.     End Sub
     
296. 
     
297.     ''' <summary>
     
298.     ''' 返回计算机所有串口名称
     
299.     ''' </summary>
     
300.     ''' <param name="PortNames">[out]返回计算机所有串口名称数组</param>
     
301.     ''' <remarks>当需要设置串口时，可能首先调用本函数获取所有的串口名称。</remarks>
     
302.     Public Shared Sub GetSerialPortNames(ByRef PortNames As ArrayList)
     
303.         PortNames = New ArrayList
     
304.         For Each sp As String In My.Computer.Ports.SerialPortNames
     
305.             PortNames.Add(sp)
     
306.         Next
     
307.     End Sub
     
308. 
     
309.     ''' <summary>
     
310.     ''' 关闭串口连接
     
311.     ''' </summary>
     
312.     ''' <remarks></remarks>
     
313.     Public Function ClosePort()
     
314.         Dim str As String = ""
     
315.         Try
     
316.             SerialPort1.Close()
     
317.         Catch ex As Exception
     
318.             str = ex.ToString
     
319.         End Try
     
320.         Return str
     
321.     End Function
     

复制代码

1. 
   
2.     ''' <summary>
   
3.     ''' 打开串口连接
   
4.     ''' </summary>
   
5.     ''' <remarks></remarks>
   
6.     Public Function OpenPort()
   
7.         Dim str As String = ""
   
8.         Try
   
9.             SerialPort1.Open()
   
10.         Catch ex As Exception
    
11.             str = ex.ToString
    
12.         End Try
    
13.         Return str
    
14.     End Function
    
15. 
    
16. 
    
17.     ''' <summary>
    
18.     ''' 对将要输出的命令按照Modbus的格式进行编码，并加入CRC校验
    
19.     ''' </summary>
    
20.     ''' <param name="buffer">[out]按照Modbus协议打包好的数据包</param>
    
21.     ''' <remarks></remarks>
    
22.     Private Sub CommandDecodeOfMaster(ByRef buffer() As Byte)
    
23.         Dim i As UInt16
    
24. 
    
25.         ReDim buffer(1)
    
26.         buffer(0) = m_Cmd.AddressOfReceive
    
27.         buffer(1) = m_Cmd.Command
    
28. 
    
29.         Select Case m_Cmd.Command
    
30.             Case enCommandType.读离散输入, _
    
31.                  enCommandType.读线圈, _
    
32.                  enCommandType.读取输入寄存器, _
    
33.                  enCommandType.读取保持寄存器
    
34. 
    
35.                 ReDim Preserve buffer(2 + 4 - 1)
    
36. 
    
37.                 '要读取数据的偏置量
    
38.                 buffer(2) = (m_Cmd.ReadAddress And &HFF00&) / &H100&
    
39.                 buffer(3) = m_Cmd.ReadAddress And &HFF&
    
40. 
    
41.                 '要读取数据的单位数
    
42.                 buffer(4) = (m_Cmd.ReadCount And &HFF00&) / &H100&
    
43.                 buffer(5) = m_Cmd.ReadCount And &HFF&
    
44. 
    
45.             Case enCommandType.强置单线圈, _
    
46.                  enCommandType.预置单寄存器
    
47. 
    
48.                 ReDim Preserve buffer(2 + 4 - 1)
    
49. 
    
50.                 '要写的单个数据的偏置量
    
51.                 buffer(2) = (m_Cmd.WriteAddress And &HFF00&) / &H100&
    
52.                 buffer(3) = m_Cmd.WriteAddress And &HFF&
    
53. 
    
54.                 m_Cmd.WriteCount = 1
    
55.                 m_Cmd.DataLen = 2
    
56. 
    
57.                 ReDim Preserve m_Cmd.Data(m_Cmd.DataLen - 1)
    
58.                 buffer(4) = m_Cmd.Data(0)
    
59.                 buffer(5) = m_Cmd.Data(1)
    
60. 
    
61.             Case enCommandType.强置多线圈, _
    
62.                  enCommandType.预置多寄存器
    
63. 
    
64.                 ReDim Preserve buffer(2 + 5 + m_Cmd.DataLen - 1)
    
65. 
    
66.                 '要写的数据的偏置量
    
67.                 buffer(2) = (m_Cmd.WriteAddress And &HFF00&) / &H100&
    
68.                 buffer(3) = m_Cmd.WriteAddress And &HFF&
    
69. 
    
70.                 '要写的数据的单位数
    
71.                 buffer(4) = (m_Cmd.WriteCount And &HFF00&) / &H100&
    
72.                 buffer(5) = m_Cmd.WriteCount And &HFF&
    
73. 
    
74.                 '要写入数据的字节数
    
75.                 buffer(6) = m_Cmd.DataLen
    
76. 
    
77.                 '要写入的数据
    
78.                 ReDim Preserve m_Cmd.Data(m_Cmd.DataLen - 1)
    
79.                 For i = 0 To m_Cmd.DataLen - 1 Step 1
    
80.                     buffer(7 + i) = m_Cmd.Data(i)
    
81.                 Next i
    
82. 
    
83.             Case enCommandType.读写多寄存器
    
84. 
    
85.                 ReDim Preserve buffer(2 + 9 + m_Cmd.DataLen - 1)
    
86. 
    
87.                 '要读取数据的偏置量
    
88.                 buffer(2) = (m_Cmd.ReadAddress And &HFF00&) / &H100&
    
89.                 buffer(3) = m_Cmd.ReadAddress And &HFF&
    
90. 
    
91.                 '要读取数据的单位数
    
92.                 buffer(4) = (m_Cmd.ReadCount And &HFF00&) / &H100&
    
93.                 buffer(5) = m_Cmd.ReadCount And &HFF&
    
94. 
    
95.                 '要写的数据的偏置量
    
96.                 buffer(6) = (m_Cmd.WriteAddress And &HFF00&) / &H100&
    
97.                 buffer(7) = m_Cmd.WriteAddress And &HFF&
    
98. 
    
99.                 '要写的数据的单位数
    
100.                 buffer(8) = (m_Cmd.WriteCount And &HFF00&) / &H100&
     
101.                 buffer(9) = m_Cmd.WriteCount And &HFF&
     
102. 
     
103.                 '要写入数据的字节数
     
104.                 buffer(10) = m_Cmd.DataLen
     
105. 
     
106.                 '要写入的数据
     
107.                 ReDim Preserve m_Cmd.Data(m_Cmd.DataLen - 1)
     
108.                 For i = 0 To m_Cmd.DataLen - 1 Step 1
     
109.                     buffer(11 + i) = m_Cmd.Data(i)
     
110.                 Next i
     
111.         End Select
     
112. 
     
113.         '加入CRC校验
     
114.         loadCRC(buffer)
     
115.     End Sub
     
116. 
     
117.     ''' <summary>
     
118.     ''' 向Modbus从站发送命令。
     
119.     ''' </summary>
     
120.     ''' <param name="stCmd">需要发送的命令结构</param>
     
121.     ''' <returns>成功返回空，异常返回错误信息。</returns>
     
122.     ''' <remarks></remarks>
     
123.     Public Function SendCommand(ByVal stCmd As stCommand) As String
     
124.         Dim str As String = ""
     
125.         Dim buffer() As Byte
     
126. 
     
127.         Try
     
128.             If m_enModbusMaster = enMasterType.Slaver Then
     
129.                 str = "本通讯节点为从站，不能主动发出命令。如果确需发送命令和数据，请先将通讯节点的ModbusMaster属性设置为Master。"
     
130.                 Return str
     
131.             End If
     
132. 
     
133.             '如果没有打开串口，则打开
     
134.             If SerialPort1.IsOpen = False Then
     
135.                 SerialPort1.Open()
     
136.             End If
     
137. 
     
138.             TimerOp.Stop()
     
139. 
     
140.             '是主站可以通讯
     
141. 
     
142.             '清空串口发送和接收缓存
     
143.             SerialPort1.DiscardOutBuffer()
     
144.             SerialPort1.DiscardInBuffer()
     
145.             SerialPort1.ReceivedBytesThreshold = 2
     
146. 
     
147.             '保存命令
     
148.             m_Cmd = stCmd
     
149. 
     
150.             '加入从站地址和功能码
     
151.             ReDim buffer(0)
     
152. 
     
153.             '对将要输出的命令按照Modbus的格式进行编码，并加入CRC校验
     
154.             CommandDecodeOfMaster(buffer)
     
155. 
     
156.             '通讯状态进入发送命令状态
     
157.             m_State.WorkState = enWorkStateType.SendCommand
     
158. 
     
159.             '发送数据
     
160.             SerialPort1.Write(buffer, 0, buffer.Length)
     
161. 
     
162.             '通讯状态进入发送命令状态
     
163.             m_State.WorkState = enWorkStateType.WaitAnswer
     
164. 
     
165.             '启动计时
     
166.             TimerOp.Start()
     
167. 
     
168.         Catch ex As Exception
     
169.             m_State.PortState = enCommStateType.Failure
     
170.             m_State.Msg = ex.ToString
     
171.             str = m_State.Msg
     
172.             CommunicationOver()
     
173.         End Try
     
174. 
     
175.         Return str
     
176.     End Function
     
177. 
     
178.     ''' <summary>
     
179.     ''' 数据接收中断中的主站接收函数
     
180.     ''' </summary>
     
181.     ''' <remarks></remarks>
     
182.     Private Sub ReceiveOfMaster()
     
183.         Dim buffer() As Byte
     
184.         Dim str As String = ""
     
185. 
     
186.         ReDim buffer(0)
     
187. 
     
188.         '读取通讯节点地址
     
189.         ReadData(buffer)
     
190. 
     
191.         Try
     
192.             Select Case m_State.WorkState
     
193.                 '空闲
     
194.                 Case enWorkStateType.WaitAnswer
     
195.                     WaitAnswerOfMaster(buffer)
     
196. 
     
197.                 Case enWorkStateType.GetAnswerBytes
     
198.                     '关闭时钟
     
199.                     TimerOp.Stop()
     
200. 
     
201.                     '计算CRC值
     
202.                     MakeCRC(buffer, buffer.Length, uchCRCHi, uchCRCLo)
     
203. 
     
204.                     m_Cmd.DataLen = buffer(0)
     
205. 
     
206.                     '通讯状态进入接收回应剩余数据状态
     
207.                     m_State.WorkState = enWorkStateType.AnswerLast
     
208.                     m_State.Msg = "接收回应剩余数据。"
     
209.                     SerialPort1.ReceivedBytesThreshold = m_Cmd.DataLen + 2
     
210. 
     
211.                     '打开时钟
     
212.                     TimerOp.Start()
     
213. 
     
214.                 Case enWorkStateType.AnswerLast
     
215.                     '关闭时钟
     
216.                     TimerOp.Stop()
     
217. 
     
218.                     '计算CRC值
     
219.                     MakeCRC(buffer, buffer.Length - 2, uchCRCHi, uchCRCLo)
     
220. 
     
221.                     '检查CRC校验,不通过
     
222.                     If (uchCRCHi <> buffer(buffer.Length - 2)) Or (uchCRCLo <> buffer(buffer.Length - 1)) Then
     
223.                         m_State.PortState = enCommStateType.Failure
     
224.                         m_State.Msg = "CRC校验没有通过。"
     
225.                     Else
     
226.                         If m_Cmd.DataLen > 0 Then
     
227.                             '保存数据
     
228.                             ReDim m_Cmd.Data(m_Cmd.DataLen - 1)
     
229.                             Array.Copy(buffer, m_Cmd.Data, m_Cmd.DataLen)
     
230.                         End If
     
231. 
     
232.                         m_State.WorkState = enWorkStateType.Idle
     
233.                         m_State.Msg = "应答接收完成。"
     
234.                     End If
     
235. 
     
236.                     '发送通讯结束消息
     
237.                     RaiseEvent CommunicationOverEvent(m_Cmd, m_State)
     
238. 
     
239.                     '恢复初值
     
240.                     m_State.WorkState = enWorkStateType.Idle
     
241.                     m_State.PortState = enCommStateType.Normal
     
242.                     m_State.Msg = ""
     
243.                     SerialPort1.DiscardInBuffer()
     
244.                     SerialPort1.ReceivedBytesThreshold = 1
     
245. 
     
246.             End Select
     
247. 
     
248. 
     
249.             If m_State.PortState <> enCommStateType.Normal Then
     
250.                 'Modbus命令结束
     
251.                 CommunicationOver()
     
252.             End If
     
253. 
     
254.         Catch ex As Exception
     
255.             m_State.PortState = enCommStateType.Failure
     
256.             m_State.Msg = ex.ToString
     
257. 
     
258.             'Modbus命令结束
     
259.             CommunicationOver()
     
260.         End Try
     
261. 
     
262.     End Sub
     
263. 
     
264.     ''' <summary>
     
265.     ''' 主站发送命令完毕后，等待从站回复的处理函数。
     
266.     ''' </summary>
     
267.     ''' <param name="buffer">[in]接收到的数据包。</param>
     
268.     ''' <remarks></remarks>
     
269.     Private Sub WaitAnswerOfMaster(ByVal buffer() As Byte)
     
270.         Try
     
271.             '核对地址
     
272.             If (CheckAddress(buffer(0)) = "") And ((buffer(1) And &HFF&) = m_Cmd.Command) Then
     
273.                 '关闭时钟
     
274.                 TimerOp.Stop()
     
275. 
     
276.                 uchCRCHi = &HFF     ' 高CRC字节初始化
     
277.                 uchCRCLo = &HFF     '低CRC 字节初始化  
     
278. 
     
279.                 '计算CRC值
     
280.                 MakeCRC(buffer, buffer.Length, uchCRCHi, uchCRCLo)
     
281. 
     
282.                 Select Case m_Cmd.Command
     
283.                     Case enCommandType.读线圈, _
     
284.                          enCommandType.读离散输入, _
     
285.                          enCommandType.读取保持寄存器, _
     
286.                          enCommandType.读取输入寄存器, _
     
287.                          enCommandType.读写多寄存器
     
288. 
     
289.                         '通讯状态进入接收回应数据字节数状态
     
290.                         m_State.WorkState = enWorkStateType.GetAnswerBytes
     
291.                         m_State.Msg = "接收回应数据字节数。"
     
292.                         SerialPort1.ReceivedBytesThreshold = 1
     
293. 
     
294.                     Case enCommandType.强置单线圈, _
     
295.                          enCommandType.预置单寄存器, _
     
296.                          enCommandType.强置多线圈, _
     
297.                          enCommandType.预置多寄存器
     
298. 
     
299.                         '通讯状态进入接收回应剩余数据状态
     
300.                         m_State.WorkState = enWorkStateType.AnswerLast
     
301.                         m_State.Msg = "接收回应剩余数据。"
     
302.                         SerialPort1.ReceivedBytesThreshold = 6
     
303.                 End Select
     
304. 
     
305.                 '开始计时
     
306.                 TimerOp.Start()
     
307.             Else
     
308.                 m_State.PortState = enCommStateType.Failure
     
309.                 m_State.Msg = "回应的从站地址不正确或功能码不对。"
     
310.             End If
     
311.         Catch ex As Exception
     
312.             m_State.PortState = enCommStateType.Failure
     
313.             m_State.Msg = ex.ToString
     
314. 
     
315.             'Modbus命令结束
     
316.             CommunicationOver()
     
317.         End Try
     
318.     End Sub
     
319. 
     
320.     ''' <summary>
     
321.     ''' 通讯结束处理函数
     
322.     ''' </summary>
     
323.     ''' <remarks></remarks>
     
324.     Public Sub CommunicationOver()
     
325.         Try
     
326.             TimerOp.Stop()
     
327. 
     
328.             '发送通讯结束消息
     
329.             RaiseEvent CommunicationOverEvent(m_Cmd, m_State)
     
330. 
     
331.             '恢复初值
     
332.             m_State.WorkState = enWorkStateType.Idle
     
333.             m_State.PortState = enCommStateType.Normal
     
334.             m_State.Msg = ""
     
335. 
     
336.             SerialPort1.DiscardInBuffer()
     
337. 
     
338.             SerialPort1.ReceivedBytesThreshold = 1
     
339.         Catch ex As Exception
     
340. 
     
341.         End Try
     
342.     End Sub
     
343. 
     
344.     ''' <summary>
     
345.     ''' 读取串口缓存的数据
     
346.     ''' </summary>
     
347.     ''' <param name="buffer">[out]将读取出来的数据暂时放置到该数组中</param>
     
348.     ''' <remarks></remarks>
     
349.     Private Sub ReadData(ByRef buffer() As Byte)
     
350.         Dim i As Int16
     
351. 
     
352.         Try
     
353.             '设置数据缓存
     
354.             ReDim buffer(SerialPort1.ReceivedBytesThreshold - 1)
     
355. 
     
356.             '由于SerialPort1数据缓存区的数据数量和read读取的数量可能会不一致，所以通过以下循环不断的执行读数据过程，保证数据被完整取出。
     
357.             i = 0
     
358.             Do
     
359.                 i = i + SerialPort1.Read(buffer, i, SerialPort1.ReceivedBytesThreshold)
     
360.                 If m_State.PortState <> enCommStateType.Normal Then
     
361.                     m_State.Msg = m_State.PortState.ToString
     
362.                     Exit Try
     
363.                 End If
     
364.             Loop Until i >= SerialPort1.ReceivedBytesThreshold
     
365. 
     
366.             m_State.Msg = "成功得到数据。"
     
367.         Catch ex As Exception
     
368.             m_State.PortState = enCommStateType.Failure
     
369.             m_State.Msg = ex.ToString
     
370.         End Try
     
371.     End Sub
     
372. 
     
373.     ''' <summary>
     
374.     ''' 核对通讯对象。
     
375.     ''' </summary>
     
376.     ''' <param name="address">[in]通讯接收节点地址</param>
     
377.     ''' <returns>成功返回空，错误返回错误信息。</returns>
     
378.     ''' <remarks></remarks>
     
379.     Private Function CheckAddress(ByVal address As Int16) As String
     
380.         Dim str As String = ""
     
381. 
     
382.         If (m_Cmd.AddressOfReceive = address) Or (m_Cmd.AddressOfReceive = 0) Or (enModbusMaster = enMasterType.Master) Then
     
383.             str = ""
     
384.         Else
     
385.             str = "本节点不是通讯接收节点。"
     
386.         End If
     
387. 
     
388.         Return str
     
389.     End Function
     
390. 
     
391. 
     
392. 
     
393.     ''' <summary>
     
394.     ''' 计算回应数据的CRC校验值，并将该值加入到数据尾部
     
395.     ''' </summary>
     
396.     ''' <param name="Buffer">[in/out]需要加入校验的数据包</param>
     
397.     ''' <remarks></remarks>
     
398.     Public Sub loadCRC(ByRef Buffer() As Byte)
     
399.         Dim CRCHi As Byte = &HFF     ' 高CRC字节初始化
     
400.         Dim CRCLo As Byte = &HFF     ' 低CRC字节初始化  
     
401. 
     
402.         '计算校验值
     
403.         MakeCRC(Buffer, Buffer.Length, CRCHi, CRCLo)
     
404. 
     
405.         '将校验值加入数据包尾部
     
406.         ReDim Preserve Buffer(Buffer.Length + 1)
     
407.         Buffer(Buffer.Length - 2) = CRCHi
     
408.         Buffer(Buffer.Length - 1) = CRCLo
     
409.     End Sub
     
410. 
     
411.     ''' <summary>
     
412.     '''  计算CRC
     
413.     ''' </summary>
     
414.     ''' <param name="buffer">[in]要计算的数据</param>
     
415.     ''' <param name="CRCHi">[in/out]高CRC字节</param>
     
416.     ''' <param name="CRCLo">[in/out]低CRC 字节</param>
     
417.     ''' <remarks>如果使用本函数来计算全部数据，需要首先初始化uchCRCHi和uchCRCLo为0xFF。</remarks>
     
418.     Private Sub MakeCRC(ByVal buffer() As Byte, ByVal length As UInt16, ByRef CRCHi As Byte, ByRef CRCLo As Byte)
     
419.         Dim uIndex As Byte              ' CRC循环中的索引  
     
420.         Dim DataIndex As UInt16 = 0     '消息索引
     
421.         Dim usDataLen As UInt16         ' 消息中字节数  
     
422. 
     
423.         usDataLen = length
     
424. 
     
425.         '传输消息缓冲区  
     
426.         Do
     
427.             uIndex = CRCHi Xor buffer(DataIndex)  ' 计算CRC */
     
428.             CRCHi = CRCLo Xor auchCRCHi(uIndex)
     
429.             CRCLo = auchCRCLo(uIndex)
     
430. 
     
431.             DataIndex = DataIndex + 1
     
432.         Loop Until DataIndex >= usDataLen
     
433.     End Sub
     
434. 
     

复制代码

1. 
   
2. 
   
3.     ''' <summary>
   
4.     ''' 从站回应处理
   
5.     ''' </summary>
   
6.     ''' <param name="data">[in]将要返回的数据</param>
   
7.     ''' <remarks></remarks>
   
8.     Public Function SendAnswer(ByVal data() As Byte) As String
   
9.         Dim i As Int16
   
10.         Dim buffer() As Byte
    
11.         Dim str As String = ""
    
12. 
    
13.         If (m_enModbusMaster = enMasterType.Master) Then
    
14.             m_State.PortState = enCommStateType.Failure
    
15.             m_State.Msg = "您是主站不能调用本函数,请使用SendCommand函数"
    
16.             Return m_State.Msg
    
17.         End If
    
18. 
    
19.         If m_State.WorkState <> enWorkStateType.Answer Then
    
20.             m_State.PortState = enCommStateType.Failure
    
21.             m_State.Msg = "当前通讯状态不在应答状态"
    
22.             Return m_State.Msg
    
23.         End If
    
24. 
    
25.         Try
    
26.             ReDim buffer(0)
    
27. 
    
28.             Select Case m_Cmd.Command
    
29.                 Case enCommandType.读线圈, _
    
30.                      enCommandType.读离散输入, _
    
31.                      enCommandType.读取保持寄存器, _
    
32.                      enCommandType.读取输入寄存器, _
    
33.                      enCommandType.读写多寄存器
    
34. 
    
35.                     '设置数据包长度
    
36.                     ReDim buffer(3 + data.Length - 1)
    
37. 
    
38.                     '写从站地址, 写功能码
    
39.                     buffer(0) = m_Cmd.AddressOfReceive
    
40.                     buffer(1) = m_Cmd.Command
    
41. 
    
42.                     '写数据字节数
    
43.                     buffer(2) = m_Cmd.DataLen
    
44. 
    
45.                     '写有效数据
    
46.                     For i = 0 To data.Length - 1 Step 1
    
47.                         buffer(3 + i) = data(i)
    
48.                     Next i
    
49. 
    
50.                     '装入CRC校验值
    
51.                     loadCRC(buffer)
    
52. 
    
53.                 Case enCommandType.强置单线圈, _
    
54.                      enCommandType.预置单寄存器
    
55. 
    
56.                     '设置数据包长度
    
57.                     ReDim buffer(5)
    
58. 
    
59.                     '写从站地址, 写功能码
    
60.                     buffer(0) = m_Cmd.AddressOfReceive
    
61.                     buffer(1) = m_Cmd.Command
    
62. 
    
63.                     '写数据偏置值
    
64.                     buffer(2) = (m_Cmd.WriteAddress And &HFF00&) / &H100
    
65.                     buffer(3) = m_Cmd.WriteAddress And &HFF&
    
66. 
    
67.                     '写有效数据
    
68.                     buffer(4) = m_Cmd.Data(0)
    
69.                     buffer(5) = m_Cmd.Data(1)
    
70. 
    
71.                     '装入CRC校验值
    
72.                     loadCRC(buffer)
    
73. 
    
74.                 Case enCommandType.强置多线圈, _
    
75.                      enCommandType.预置多寄存器
    
76. 
    
77.                     '设置数据包长度
    
78.                     ReDim buffer(5)
    
79. 
    
80.                     '写从站地址, 写功能码
    
81.                     buffer(0) = m_Cmd.AddressOfReceive
    
82.                     buffer(1) = m_Cmd.Command
    
83. 
    
84.                     '写数据偏置值
    
85.                     buffer(2) = (m_Cmd.WriteAddress And &HFF00&) / &H100
    
86.                     buffer(3) = m_Cmd.WriteAddress And &HFF&
    
87. 
    
88.                     '写数据单位数
    
89.                     buffer(4) = (m_Cmd.WriteCount And &HFF00&) / &H100
    
90.                     buffer(5) = m_Cmd.WriteCount And &HFF&
    
91. 
    
92.                     '装入CRC校验值
    
93.                     loadCRC(buffer)
    
94.             End Select
    
95. 
    
96.             '发送数据
    
97.             SerialPort1.Write(buffer, 0, buffer.Length)
    
98. 
    
99.             '通讯完成,恢复初值
    
100.             TimerOp.Stop()
     
101.             m_State.WorkState = enWorkStateType.Idle
     
102.             m_State.PortState = enCommStateType.Normal
     
103.             m_State.Msg = ""
     
104.             SerialPort1.DiscardInBuffer()
     
105.             SerialPort1.ReceivedBytesThreshold = 1
     
106. 
     
107.         Catch ex As Exception
     
108.             m_State.PortState = enCommStateType.Failure
     
109.             m_State.Msg = ex.ToString
     
110.             str = m_State.Msg
     
111. 
     
112.             'Modbus命令结束
     
113.             CommunicationOver()
     
114.         End Try
     
115. 
     
116.         Return str
     
117.     End Function
     
118. 
     
119.     ''' <summary>
     
120.     ''' 数据接收中断中的从站接收函数。
     
121.     ''' </summary>
     
122.     ''' <remarks></remarks>
     
123.     Private Sub ReceiveOfSlaver()
     
124.         Dim buffer() As Byte
     
125.         Dim str As String = ""
     
126. 
     
127.         ReDim buffer(0)
     
128. 
     
129.         '读取通讯节点地址
     
130.         ReadData(buffer)
     
131. 
     
132.         Try
     
133.             Select Case m_State.WorkState
     
134.                 '空闲
     
135.                 Case enWorkStateType.Idle
     
136.                     '核对地址
     
137.                     If CheckAddress(buffer(0)) = "" Then
     
138.                         '计算CRC值
     
139.                         uchCRCHi = &HFF     ' 高CRC字节初始化
     
140.                         uchCRCLo = &HFF     '低CRC 字节初始化  
     
141.                         MakeCRC(buffer, buffer.Length, uchCRCHi, uchCRCLo)
     
142. 
     
143.                         '通讯状态进入接收命令状态
     
144.                         m_State.WorkState = enWorkStateType.ReceiveCommand
     
145.                         m_State.Msg = "通过地址核对, 等待输入命令。"
     
146.                         SerialPort1.ReceivedBytesThreshold = 1
     
147. 
     
148.                         '开始计时
     
149.                         TimerOp.Start()
     
150.                     End If
     
151. 
     
152.                     '读取功能码和数据地址
     
153.                 Case enWorkStateType.ReceiveCommand
     
154.                     '关闭时钟()
     
155.                     TimerOp.Stop()
     
156. 
     
157.                     '计算CRC值
     
158.                     MakeCRC(buffer, buffer.Length, uchCRCHi, uchCRCLo)
     
159. 
     
160.                     '读取功能码
     
161.                     m_Cmd.Command = buffer(0)
     
162. 
     
163.                     '读数据的偏置地址
     
164.                     m_State.WorkState = enWorkStateType.ReceiceCommandInfo
     
165.                     m_State.Msg = "接收了功能码，准备接收数据地址和数量信息。"
     
166. 
     
167.                     Select Case m_Cmd.Command
     
168.                         Case enCommandType.读线圈, _
     
169.                              enCommandType.读离散输入, _
     
170.                              enCommandType.读取保持寄存器, _
     
171.                              enCommandType.读取输入寄存器
     
172. 
     
173.                             SerialPort1.ReceivedBytesThreshold = 4
     
174. 
     
175.                         Case enCommandType.强置单线圈, _
     
176.                              enCommandType.预置单寄存器
     
177. 
     
178.                             SerialPort1.ReceivedBytesThreshold = 2
     
179. 
     
180.                         Case enCommandType.强置多线圈, _
     
181.                              enCommandType.预置多寄存器
     
182. 
     
183.                             SerialPort1.ReceivedBytesThreshold = 5
     
184. 
     
185.                         Case enCommandType.读写多寄存器
     
186.                             '需要读取：读数据的数量，写数据的偏置量、写数据数量和字节数
     
187.                             SerialPort1.ReceivedBytesThreshold = 9
     
188. 
     
189.                     End Select
     
190. 
     
191.                     '开始计时
     
192.                     TimerOp.Start()
     
193. 
     
194.                 Case enWorkStateType.ReceiceCommandInfo
     
195.                     '关闭时钟()
     
196.                     TimerOp.Stop()
     
197. 
     
198.                     '计算CRC值
     
199.                     MakeCRC(buffer, buffer.Length, uchCRCHi, uchCRCLo)
     
200. 
     
201.                     Select Case m_Cmd.Command
     
202.                         Case enCommandType.读线圈, _
     
203.                              enCommandType.读离散输入, _
     
204.                              enCommandType.读取保持寄存器, _
     
205.                              enCommandType.读取输入寄存器
     
206. 
     
207.                             '读取数据的偏置地址
     
208.                             m_Cmd.ReadAddress = (buffer(0) * &H100&) Or buffer(1)
     
209.                             m_Cmd.ReadCount = (buffer(2) * &H100&) Or buffer(3)
     
210. 
     
211.                             m_State.WorkState = enWorkStateType.ReceiveCRC
     
212.                             m_State.Msg = "接收了数据地址，准备接收CRC信息。"
     
213.                             SerialPort1.ReceivedBytesThreshold = 2
     
214. 
     
215.                         Case enCommandType.强置单线圈, _
     
216.                              enCommandType.预置单寄存器
     
217. 
     
218.                             m_Cmd.WriteAddress = (buffer(0) * &H100&) Or buffer(1)
     
219.                             m_Cmd.WriteCount = 1
     
220.                             m_Cmd.DataLen = 2
     
221. 
     
222.                             m_State.WorkState = enWorkStateType.ReceiveData
     
223.                             m_State.Msg = "接收了数据地址，准备接收数据。"
     
224.                             SerialPort1.ReceivedBytesThreshold = 2
     
225. 
     
226.                         Case enCommandType.强置多线圈, _
     
227.                              enCommandType.预置多寄存器
     
228. 
     
229.                             '写数据的偏置地址
     
230.                             m_Cmd.WriteAddress = (buffer(0) * &H100&) Or buffer(1)
     
231.                             m_Cmd.WriteCount = (buffer(2) * &H100&) Or buffer(3)
     
232.                             m_Cmd.DataLen = buffer(4)
     
233. 
     
234.                             m_State.WorkState = enWorkStateType.ReceiveData
     
235.                             m_State.Msg = "接收了数据地址，准备接收数据。"
     
236.                             SerialPort1.ReceivedBytesThreshold = m_Cmd.DataLen
     
237. 
     
238.                         Case enCommandType.读写多寄存器
     
239.                             '写数据的偏置地址
     
240.                             m_Cmd.ReadAddress = (buffer(0) * &H100&) Or buffer(1)
     
241.                             m_Cmd.ReadCount = (buffer(2) * &H100&) Or buffer(3)
     
242.                             m_Cmd.WriteAddress = (buffer(4) * &H100&) Or buffer(5)
     
243.                             m_Cmd.WriteCount = (buffer(6) * &H100&) Or buffer(7)
     
244.                             m_Cmd.DataLen = buffer(8)
     
245. 
     
246.                             m_State.WorkState = enWorkStateType.ReceiveData
     
247.                             m_State.Msg = "接收了数据地址，准备接收数据。"
     
248.                             SerialPort1.ReceivedBytesThreshold = m_Cmd.DataLen
     
249. 
     
250.                     End Select
     
251. 
     
252.                     '开始计时
     
253.                     TimerOp.Start()
     
254. 
     
255.                     '读取数据
     
256.                 Case enWorkStateType.ReceiveData
     
257.                     '关闭时钟
     
258.                     TimerOp.Stop()
     
259. 
     
260.                     '计算CRC值
     
261.                     MakeCRC(buffer, buffer.Length, uchCRCHi, uchCRCLo)
     
262. 
     
263.                     ReDim m_Cmd.Data(m_Cmd.DataLen - 1)
     
264.                     Array.Copy(buffer, m_Cmd.Data, m_Cmd.DataLen)
     
265. 
     
266.                     m_State.WorkState = enWorkStateType.ReceiveCRC
     
267.                     m_State.Msg = "获得数据，准备接收CRC信息。"
     
268.                     SerialPort1.ReceivedBytesThreshold = 2
     
269. 
     
270.                     '开始计时
     
271.                     TimerOp.Start()
     
272. 
     
273.                 Case enWorkStateType.ReceiveCRC
     
274.                     '关闭时钟
     
275.                     TimerOp.Stop()
     
276. 
     
277.                     '检查CRC校验
     
278.                     If (uchCRCHi = buffer(0)) And (uchCRCLo = buffer(1)) Then
     
279.                         m_State.Msg = "CRC校验通过，请调用应答函数回应主站。"
     
280. 
     
281.                         '通讯状态进入应答状态
     
282.                         m_State.WorkState = enWorkStateType.Answer
     
283. 
     
284.                         '发送通讯结束消息
     
285.                         RaiseEvent CommunicationOverEvent(m_Cmd, m_State)
     
286. 
     
287.                     Else
     
288.                         m_State.PortState = enCommStateType.Failure
     
289.                         m_State.Msg = "CRC校验错。"
     
290.                     End If
     
291. 
     
292.             End Select
     
293. 
     
294.             If m_State.PortState <> enCommStateType.Normal Then
     
295.                 'Modbus命令结束
     
296.                 CommunicationOver()
     
297.             End If
     
298. 
     
299.         Catch ex As Exception
     
300.             m_State.PortState = enCommStateType.Failure
     
301.             m_State.Msg = ex.ToString
     
302. 
     
303.             'Modbus命令结束
     
304.             CommunicationOver()
     
305.         End Try
     
306.     End Sub
     
307. 
     
308. 
     
309. 
     
310.     ''' <summary>
     
311.     ''' 接收数据中断。根据主站或从站属性调用不同的接收函数。
     
312.     ''' </summary>
     
313.     ''' <param name="sender"></param>
     
314.     ''' <param name="e"></param>
     
315.     ''' <remarks>当串口接收到了指定的接收数量后，将引发本事件。</remarks>
     
316.     Private Sub OnSerialPortReceivedEvent(ByVal sender As Object, ByVal e As System.IO.Ports.SerialDataReceivedEventArgs)
     
317.         If m_enModbusMaster = enMasterType.Slaver Then
     
318.             ReceiveOfSlaver()
     
319.         Else
     
320.             ReceiveOfMaster()
     
321.         End If
     
322. 
     
323.     End Sub
     
324. 
     
325.     ''' <summary>
     
326.     ''' 串口接收错误事件
     
327.     ''' </summary>
     
328.     ''' <param name="sender"></param>
     
329.     ''' <param name="e"></param>
     
330.     ''' <remarks></remarks>
     
331.     Private Sub OnSerialErrorReceivedEvent(ByVal sender As Object, ByVal e As System.IO.Ports.SerialErrorReceivedEventArgs)
     
332.         Dim str As String = ""
     
333. 
     
334.         m_State.PortState = enCommStateType.Failure
     
335.         m_State.Msg = "串口通讯异常。"
     
336. 
     
337.         CommunicationOver()
     
338.     End Sub
     
339. 
     
340. #End Region

复制代码

游客，如果您要查看本帖隐藏内容请回复

谢谢分享

..............................

这个不错。谢谢分享。

嘻嘻。有源文件就好了。。。。。

前面的代码看了，觉得楼主写得很不错，想要看完整的代码！

不能传附件上来吗？

{:soso_e103:} 呵呵额额和，谢谢哦

非常感谢
   手下了

谢谢分享

帅极了，正好在找

谢谢分享,正好学习