一个基于VB.net的异步Socket网络TCP通信可防止任意一端意外终止TCP连接的类，

之前，因为要做一个TCP通信的项目，有研究一下Socket类，但是为了快速完成任务，还是在网上找了一些源码来调试测试，发现很多源码都无法触发TCP连接的任意一端

的突然意外中断连接的事件，于是本人基于他人的源码基础上进行了修改，可以触发这一事件，可使TCP连接的另一端触发对方已经终止TCP连接事件。

以下，奉上本人修改后的源码类：

1）TCP 服务器TCP 侦听类。

[vb] view plain copy print ?

1. ImportsSystem.Net
2. ImportsSystem.Net.sockets
3. ImportsSystem.Threading
4. ImportsSystem.Text
7. '**********************************************************************************************************
8. ''''''类名：Tcpserver
9. ''''''说明：监听主线程，用于监听客户端联接，并记录客户端联接，接收和发送数据
10. ''''''与客户端的联接采用TCP联接
11. '**********************************************************************************************************
14. '''<summary>
15. '''侦听客户端联接
16. '''</summary>
17. PublicClassTcpserver
19. #Region"私有成员"
20. Private_LocationListenSocketAsSocket'本地侦听服务
21. Private_ListenPortAsString'服务器侦听客户端联接的端口
22. Private_MaxClientAsInteger'最大客户端连接数
23. Private_ClientsAsNewSortedList'客户端队列
24. Private_ListenThreadAsThread=nothing'侦听线程
25. Private_ServerStartAsBoolean=False'服务器是否已经启动
26. Private_RecvMaxAsInteger'接收缓冲区大小
27. #EndRegion
29. #Region"事件"
30. '''<summary>
31. '''客户端联接事件
32. '''</summary>
33. '''<paramname="IP">客户端联接IP</param>
34. '''<paramname="Port">客户端联接端口号</param>
35. '''<remarks></remarks>
36. PublicEventClientConnected(ByValIPAsString,ByValPortAsString)
37. '''<summary>
38. '''客户端断开事件
39. '''</summary>
40. '''<paramname="IP">客户端联接IP</param>
41. '''<paramname="Port">客户端联接端口号</param>
42. '''<remarks></remarks>
43. PublicEventClientClose(ByValIPAsString,ByValPortAsString)
44. '''<summary>
45. '''接收到客户端的数据
46. '''</summary>
47. '''<paramname="value">数据</param>
48. '''<paramname="IPAddress">数据来源IP</param>
49. '''<paramname="Port">数据来源端口</param>
50. '''<remarks></remarks>
51. PublicEventDataArrived(ByValvalueAsByte(),ByValLenAsInteger,ByValIPAddressAsString,ByValPortAsString)
52. '''<summary>
53. '''异常数据
54. '''</summary>
55. '''<paramname="ex"></param>
56. '''<remarks></remarks>
57. PublicEventException(ByValexAsException)
59. #EndRegion
61. #Region"属性"
62. '''<summary>
63. '''侦听服务是否已经启动
64. '''</summary>
65. '''<value></value>
66. '''<returns></returns>
67. '''<remarks></remarks>
68. PublicReadOnlyPropertyIsServerStart()AsBoolean
69. Get
70. Return_ServerStart
71. EndGet
72. EndProperty
73. #EndRegion
75. #Region"方法"
76. '''<summary>
77. '''实例　Tcpserver
78. '''</summary>
79. '''<paramname="Port">侦听客户端联接的端口号</param>
80. '''<paramname="MaxClient">最大可以联接的客户端数量</param>
81. '''<paramname="RecvMax">接收缓冲区大小</param>
82. '''<paramname="RecvSleep">接收线程睡眠时间</param>
83. '''<remarks></remarks>
84. SubNew(ByValPortAsString,ByValMaxClientAsInteger,ByValRecvMaxAsInteger,ByValRecvSleepAsInteger)
85. Try
86. DimstrHostNameAsString=Dns.GetHostName()
87. _ListenPort=Port
88. _MaxClient=MaxClient
89. _RecvMax=RecvMax
90. DimstrServerHostAsNewIPEndPoint(IPAddress.Any,Int32.Parse(_ListenPort))
91. '建立TCP侦听
92. _LocationListenSocket=NewSocket(AddressFamily.InterNetwork,SocketType.Stream,ProtocolType.Tcp)
93. _LocationListenSocket.Bind(strServerHost)
94. _LocationListenSocket.Listen(_MaxClient)
95. _LocationListenSocket.SetSocketoption(SocketoptionLevel.Tcp,SocketoptionName.AcceptConnection,1)
96. CatchexAsException
97. RaiseEventException(ex)
98. EndTry
99. EndSub
101. '''<summary>
102. '''开始侦听服务
103. '''</summary>
104. '''<remarks></remarks>
105. PublicSubStartServer()
106. _ServerStart=True
107. Try
108. _ListenThread=NewThread(NewThreadStart(AddressOfListenClient))
109. _ListenThread.Name="监听客户端主线程"
110. _ListenThread.Start()
111. CatchexAsException
112. If(Not_LocationListenSocketIsnothing)Then
113. If_LocationListenSocket.ConnectedThen
114. _LocationListenSocket.Close()
115. EndIf
116. EndIf
117. RaiseEventException(ex)
118. EndTry
119. EndSub
121. '''<summary>
122. '''关闭侦听
123. '''</summary>
124. '''<remarks></remarks>
125. PublicSubClose()
126. Try
127. _ServerStart=False
128. 'CloseAllClient()
129. Thread.Sleep(5)
130. _ListenThread.Abort()
131. _LocationListenSocket.Close()
132. _ListenThread=nothing
133. CatchexAsException
134. RaiseEventException(ex)
135. EndTry
136. EndSub
138. '''<summary>
139. '''客户端侦听线程
140. '''</summary>
141. '''<remarks></remarks>
142. PrivateSubListenClient()
143. DimsKeyAsString
144. While(_ServerStart)
145. Try
146. IfNot_LocationListenSocketIsnothingThen
147. DimclientSocketAsSystem.Net.sockets.socket
148. clientSocket=NewSocket(AddressFamily.InterNetwork,ProtocolType.Tcp)
149. clientSocket=_LocationListenSocket.Accept()
150. IfNotclientSocketIsnothingThen
151. DimclientInfoTAsIPEndPoint=CType(clientSocket.RemoteEndPoint,IPEndPoint)
152. sKey=clientInfoT.Address.ToString&"\&"&clientInfoT.Port.ToString
153. _Clients.Add(sKey,clientSocket)
154. RaiseEventClientConnected(clientInfoT.Address.ToString,clientInfoT.Port.ToString)'举起有客户端联接的事件
155. '启动客户端接收主线程，开始侦听并接收客户端上传的数据
156. DimlbAsNewClientCommunication(_LocationListenSocket,clientSocket,Me)
157. AddHandlerlb.Exception,AddressOfWriteErrorEvent_ClientCommunication
158. DimthrClientAsNewThread(NewThreadStart(AddressOflb.serverThreadProc))
159. thrClient.Name="客户端接收线程,客户端"&clientInfoT.Address.ToString&":"&clientInfoT.Port.ToString
160. thrClient.Start()
161. EndIf
162. EndIf
163. CatchexAsException
164. RaiseEventException(ex)
165. EndTry
166. EndWhile
167. EndSub
169. PrivateSubWriteErrorEvent_ClientCommunication(ByValexAsException)
170. RaiseEventException(ex)
171. EndSub
173. PublicSubCloseClient(ByValIPAsString,ByValPortAsString)
174. GetClientSocket(IP,Port).Close()
175. GetClientClose(IP,Port)
176. EndSub
177. 'PublicSubAlertNoticeClientAll(ByValDepartmentNameAsstring,ByValLineNameAsstring,ByValErrorCodeAsInteger)
178. ''#DepartmentName,LineName,AlertCodeValue.
179. ''''DimmStrAsstring
180. ''''mStr="#"&DepartmentName&","&LineName&","&ErrorCode
181. ''''DimsendByte()AsByte=System.Text.UTF8Encoding.Default.GetBytes(mStr)
182. ''''ForEachscAsSystem.Net.sockets.socketIn_ClientComputers.Values
183. ''''sc.Send(SendByte,SendByte.Length(),SocketFlags.None)
184. ''''Next
185. 'EndSub
186. PublicSubCloseAllClient()
187. ForEachscAsSystem.Net.sockets.socketIn_Clients.Values
188. '断开所有工作站的Socket连接。
189. DimclientInfoTAsIPEndPoint=CType(sc.RemoteEndPoint,IPEndPoint)
190. CloseClient(clientInfoT.Address.ToString,clientInfoT.Port.ToString)
191. Next
192. EndSub
193. #Region"接收客户端的数据"
195. '''<summary>
196. '''接收到客户端的数据-字节数组
197. '''</summary>
198. '''<paramname="value">数据内容</param>
199. '''<paramname="Len">字节长度</param>
200. '''<paramname="IPAddress">发送该数据的IP地址</param>
201. '''<paramname="Port">发送该数据的端口号</param>
202. '''<remarks></remarks>
203. PrivateSubGetData_Byte(ByValvalueAsByte(),ByValPortAsString)
204. Try
205. RaiseEventDataArrived(value,Len,IPAddress,Port)
206. 'CatchexxAsSockets.socketException
207. 'CloseClient(IPAddress,Port)
208. CatchexAsException
209. RaiseEventException(ex)
210. EndTry
211. EndSub
213. '''<summary>
214. '''得到客户端断开或失去客户端联连事件
215. '''</summary>
216. '''<paramname="IP">客户端联接IP</param>
217. '''<paramname="Port">客户端联接端口号</param>
218. '''<remarks></remarks>
219. PrivateSubGetClientClose(ByValIPAsString,ByValPortAsString)
220. Try
221. If_Clients.ContainsKey(IP&"\&"&Port)Then
222. SyncLock_Clients.SyncRoot
223. '_Clients.Item(IP&"\&"&Port)
224. _Clients.Remove(IP&"\&"&Port)
225. EndSyncLock
226. EndIf
227. RaiseEventClientClose(IP,Port)
228. CatchexAsException
229. RaiseEventException(ex)
230. EndTry
231. EndSub
232. #EndRegion
235. #Region"向客户端发送数据"
237. '''<summary>
238. '''向客户端发送信息
239. '''</summary>
240. '''<paramname="value">发送的内容</param>
241. '''<paramname="IPAddress">IP地址</param>
242. '''<paramname="Port">端口号</param>
243. '''<returns>Boolean</returns>
244. '''<remarks></remarks>
245. PublicFunctionSendData(ByValvalueAsByte(),ByValPortAsString)AsBoolean
246. Try
247. DimclientSocketAsSystem.Net.sockets.socket
248. clientSocket=_Clients.Item(IPAddress&"\&"&Port)
249. clientSocket.Send(value,value.Length,SocketFlags.None)
250. ReturnTrue
251. CatchexAsException
252. RaiseEventException(ex)
253. ReturnFalse
254. EndTry
255. EndFunction
256. PublicFunctionSendFile(ByValvalueAsString,ByValPortAsString)AsBoolean
257. Try
258. DimclientSocketAsSystem.Net.sockets.socket
259. clientSocket=_Clients.Item(IPAddress&"\&"&Port)
260. clientSocket.SendFile(value)
261. ReturnTrue
262. CatchexAsException
263. RaiseEventException(ex)
264. ReturnFalse
265. EndTry
266. EndFunction
267. PublicFunctionSendDataToAllClient(ByValvalueAsByte())AsBoolean
268. Try
269. ForEachclientSocketAsSystem.Net.sockets.socketIn_Clients.Values
270. clientSocket.Send(value,SocketFlags.None)
271. Next
272. ReturnTrue
273. CatchexAsException
274. RaiseEventException(ex)
275. ReturnFalse
276. EndTry
277. EndFunction
279. #EndRegion
281. '''<summary>
282. '''得到客户端的Socket联接
283. '''</summary>
284. '''<paramname="IPAddress">客户端的IP</param>
285. '''<paramname="Port">客户端的端口号</param>
286. '''<returns>Socket联接</returns>
287. '''<remarks></remarks>
288. PrivateFunctionGetClientSocket(ByValIPAddressAsString,ByValPortAsString)AsSocket
289. Try
290. DimClientSocketAsSocket
291. ClientSocket=_Clients.Item(IPAddress&"\&"&Port)
292. ReturnClientSocket
293. CatchexAsException
294. RaiseEventException(ex)
295. Returnnothing
296. EndTry
297. EndFunction
298. #EndRegion
300. PrivateClassClientCommunication
301. PublicEventException(ByValexAsException)
303. PrivateServerSocketAsNewSystem.Net.sockets.socket(AddressFamily.InterNetwork,ProtocolType.Tcp)
304. PrivatemyClientSocketAsNewSystem.Net.sockets.socket(AddressFamily.InterNetwork,ProtocolType.Tcp)
305. PrivatemyParentObjectAsTcpserver
306. Privateoldbytes()AsByte
307. Private_IPAddress,_PortAsString
308. PrivateNclientInfoTAsIPEndPoint=nothing
309. PrivateiLenAsInteger
310. PrivateallDoneAsNewManualResetEvent(False)
311. '''<summary>
312. '''实例ClientCommunication类
313. '''</summary>
314. '''<paramname="ServerSocket"></param>
315. '''<paramname="ClientSocket"></param>
316. '''<paramname="ParentObject"></param>
317. '''<remarks></remarks>
318. PublicSubNew(ByValServerSocketAsSocket,ByValClientSocketAsSocket,ByValParentObjectAsTcpserver)
319. Me.ServerSocket=ServerSocket
320. myClientSocket=ClientSocket
321. myParentObject=ParentObject
322. NclientInfoT=CType(myClientSocket.RemoteEndPoint,IPEndPoint)
323. _IPAddress=NclientInfoT.Address.ToString
324. _Port=NclientInfoT.Port.ToString
325. EndSub
327. '''<summary>
328. '''客户端通讯主线程
329. '''</summary>
330. '''<remarks></remarks>
331. PublicSubserverThreadProc()
332. Try
333. DimsbAsNewSocketAndBuffer
334. sb.socket=myClientSocket
335. sb.socket.BeginReceive(sb.Buffer,sb.Buffer.Length,SocketFlags.None,AddressOfReceiveCallBack,sb)
336. 'allDone.WaitOne()
337. CatchexAsException
338. RaiseEventException(ex)
339. EndTry
340. EndSub
342. '''<summary>
343. '''socket异步接收回调函数
344. '''</summary>
345. '''<paramname="ar"></param>
346. '''<remarks></remarks>
347. PrivateSubReceiveCallBack(ByValarAsIAsyncResult)
348. DimsbAsSocketAndBuffer
349. allDone.Set()
350. sb=CType(ar.AsyncState,SocketAndBuffer)
351. Try
352. Ifsb.socket.ConnectedThen
353. iLen=sb.socket.EndReceive(ar)
354. IfiLen>0Then
355. ReDimoldbytes(iLen-1)
356. Array.copy(sb.Buffer,oldbytes,iLen)
357. myParentObject.GetData_Byte(oldbytes,oldbytes.Length,_IPAddress,_Port)
358. sb.socket.BeginReceive(sb.Buffer,sb)
359. Else
360. If(NotmyClientSocketIsnothing)Then
361. IfmyClientSocket.ConnectedThen
362. myClientSocket.Close()
363. Else
364. myClientSocket.Close()
365. EndIf
366. myClientSocket=nothing
367. IfNotNclientInfoTIsnothingThen
368. myParentObject._Clients.Remove(_IPAddress&"\&"&_Port)
369. myParentObject.GetClientClose(_IPAddress,_Port)
370. EndIf
371. EndIf
372. EndIf
373. EndIf
374. CatchexAsException
375. If(NotmyClientSocketIsnothing)Then
376. IfmyClientSocket.ConnectedThen
377. myClientSocket.Close()
378. Else
379. myClientSocket.Close()
380. EndIf
381. myClientSocket=nothing
382. IfNotNclientInfoTIsnothingThen
383. myParentObject._Clients.Remove(_IPAddress&"\&"&_Port)
384. myParentObject.GetClientClose(_IPAddress,_Port)
385. EndIf
386. EndIf
387. RaiseEventException(ex)
388. EndTry
389. EndSub
391. '''<summary>
392. '''异步操作socket缓冲类
393. '''</summary>
394. '''<remarks></remarks>
395. PrivateClassSocketAndBuffer
396. PublicSocketAsSystem.Net.sockets.socket
397. PublicBuffer(8192)AsByte
398. EndClass
399. EndClass
402. EndClass

Imports System.Net
Imports System.Net.sockets
Imports System.Threading
Imports System.Text


'**********************************************************************************************************
'''''' 类名：Tcpserver  
'''''' 说明：监听主线程，用于监听客户端联接，并记录客户端联接，接收和发送数据
'''''' 与客户端的联接采用TCP联接
'**********************************************************************************************************


''' <summary>
''' 侦听客户端联接
''' </summary>
Public Class Tcpserver

#Region "私有成员"
    Private _LocationListenSocket As Socket '本地侦听服务
    Private _ListenPort As String '服务器侦听客户端联接的端口
    Private _MaxClient As Integer '最大客户端连接数
    Private _Clients As New SortedList '客户端队列
    Private _ListenThread As Thread = nothing '侦听线程
    Private _ServerStart As Boolean = False '服务器是否已经启动
    Private _RecvMax As Integer '接收缓冲区大小 
#End Region

#Region "事件"
    ''' <summary>
    ''' 客户端联接事件
    ''' </summary>
    ''' <param name="IP">客户端联接IP</param>
    ''' <param name="Port">客户端联接端口号</param>
    ''' <remarks></remarks>
    Public Event ClientConnected(ByVal IP As String,ByVal Port As String)
    ''' <summary>
    ''' 客户端断开事件
    ''' </summary>
    ''' <param name="IP">客户端联接IP</param>
    ''' <param name="Port">客户端联接端口号</param>
    ''' <remarks></remarks>
    Public Event ClientClose(ByVal IP As String,ByVal Port As String)
    ''' <summary>
    ''' 接收到客户端的数据
    ''' </summary>
    ''' <param name="value">数据</param>
    ''' <param name="IPAddress">数据来源IP</param>
    ''' <param name="Port">数据来源端口</param>
    ''' <remarks></remarks>
    Public Event DataArrived(ByVal value As Byte(),ByVal Len As Integer,ByVal IPAddress As String,ByVal Port As String)
    ''' <summary>
    ''' 异常数据
    ''' </summary>
    ''' <param name="ex"></param>
    ''' <remarks></remarks>
    Public Event Exception(ByVal ex As Exception)

#End Region

#Region "属性"
    ''' <summary>
    ''' 侦听服务是否已经启动
    ''' </summary>
    ''' <value></value>
    ''' <returns></returns>
    ''' <remarks></remarks>
    Public ReadOnly Property IsServerStart() As Boolean
        Get
            Return _ServerStart
        End Get
    End Property
#End Region

#Region "方法"
    ''' <summary>
    ''' 实例　Tcpserver
    ''' </summary>
    ''' <param name="Port">侦听客户端联接的端口号</param>
    ''' <param name="MaxClient">最大可以联接的客户端数量</param>
    ''' <param name="RecvMax">接收缓冲区大小</param>
    ''' <param name="RecvSleep">接收线程睡眠时间</param>
    ''' <remarks></remarks>
    Sub New(ByVal Port As String,ByVal MaxClient As Integer,ByVal RecvMax As Integer,ByVal RecvSleep As Integer)
        Try
            Dim strHostName As String = Dns.GetHostName()
            _ListenPort = Port
            _MaxClient = MaxClient
            _RecvMax = RecvMax
            Dim strServerHost As New IPEndPoint(IPAddress.Any,Int32.Parse(_ListenPort))
            '建立TCP侦听
            _LocationListenSocket = New Socket(AddressFamily.InterNetwork,ProtocolType.Tcp)
            _LocationListenSocket.Bind(strServerHost)
            _LocationListenSocket.Listen(_MaxClient)
            _LocationListenSocket.SetSocketoption(SocketoptionLevel.Tcp,1)
        Catch ex As Exception
            RaiseEvent Exception(ex)
        End Try
    End Sub

    ''' <summary>
    ''' 开始侦听服务
    ''' </summary>
    ''' <remarks></remarks>
    Public Sub StartServer()
        _ServerStart = True
        Try
            _ListenThread = New Thread(New ThreadStart(AddressOf ListenClient))
            _ListenThread.Name = "监听客户端主线程"
            _ListenThread.Start()
        Catch ex As Exception
            If (Not _LocationListenSocket Is nothing) Then
                If _LocationListenSocket.Connected Then
                    _LocationListenSocket.Close()
                End If
            End If
            RaiseEvent Exception(ex)
        End Try
    End Sub

    ''' <summary>
    ''' 关闭侦听
    ''' </summary>
    ''' <remarks></remarks>
    Public Sub Close()
        Try
            _ServerStart = False
            'CloseAllClient()
            Thread.Sleep(5)
            _ListenThread.Abort()
            _LocationListenSocket.Close()
            _ListenThread = nothing
        Catch ex As Exception
            RaiseEvent Exception(ex)
        End Try
    End Sub

    ''' <summary>
    ''' 客户端侦听线程
    ''' </summary>
    ''' <remarks></remarks>
    Private Sub ListenClient()
        Dim sKey As String
        While (_ServerStart)
            Try
                If Not _LocationListenSocket Is nothing Then
                    Dim clientSocket As System.Net.sockets.socket
                    clientSocket = New Socket(AddressFamily.InterNetwork,ProtocolType.Tcp)
                    clientSocket = _LocationListenSocket.Accept()
                    If Not clientSocket Is nothing Then
                        Dim clientInfoT As IPEndPoint = CType(clientSocket.RemoteEndPoint,IPEndPoint)
                        sKey = clientInfoT.Address.ToString & "\&" & clientInfoT.Port.ToString
                        _Clients.Add(sKey,clientSocket)
                        RaiseEvent ClientConnected(clientInfoT.Address.ToString,clientInfoT.Port.ToString) '举起有客户端联接的事件
                        '启动客户端接收主线程，开始侦听并接收客户端上传的数据
                        Dim lb As New ClientCommunication(_LocationListenSocket,Me)
                        AddHandler lb.Exception,AddressOf WriteErrorEvent_ClientCommunication
                        Dim thrClient As New Thread(New ThreadStart(AddressOf lb.serverThreadProc))
                        thrClient.Name = "客户端接收线程,客户端" & clientInfoT.Address.ToString & ":" & clientInfoT.Port.ToString
                        thrClient.Start()
                    End If
                End If
            Catch ex As Exception
                RaiseEvent Exception(ex)
            End Try
        End While
    End Sub

    Private Sub WriteErrorEvent_ClientCommunication(ByVal ex As Exception)
        RaiseEvent Exception(ex)
    End Sub

    Public Sub CloseClient(ByVal IP As String,ByVal Port As String)
        GetClientSocket(IP,Port).Close()
        GetClientClose(IP,Port)
    End Sub
    'Public Sub AlertNoticeClientAll(ByVal DepartmentName As String,ByVal LineName As String,ByVal ErrorCode As Integer)
    '    '#DepartmentName,AlertCodeValue.
    '    ' ''Dim mStr As String
    '    ' ''mStr = "#" & DepartmentName & "," & LineName & "," & ErrorCode
    '    ' ''Dim SendByte() As Byte = System.Text.UTF8Encoding.Default.GetBytes(mStr)
    '    ' ''For Each sc As System.Net.sockets.socket In _ClientComputers.Values
    '    ' ''    sc.Send(SendByte,SocketFlags.None)
    '    ' ''Next
    'End Sub
    Public Sub CloseAllClient()
        For Each sc As System.Net.sockets.socket In _Clients.Values
            '断开所有工作站的Socket连接。
            Dim clientInfoT As IPEndPoint = CType(sc.RemoteEndPoint,IPEndPoint)
            CloseClient(clientInfoT.Address.ToString,clientInfoT.Port.ToString)
        Next
    End Sub
#Region "接收客户端的数据"

    ''' <summary>
    ''' 接收到客户端的数据-字节数组
    ''' </summary>
    ''' <param name="value">数据内容</param>
    ''' <param name="Len">字节长度</param>
    ''' <param name="IPAddress">发送该数据的IP地址</param>
    ''' <param name="Port">发送该数据的端口号</param>
    ''' <remarks></remarks>
    Private Sub GetData_Byte(ByVal value As Byte(),ByVal Port As String)
        Try
            RaiseEvent DataArrived(value,Port)
            'Catch exx As Sockets.socketException
            '    CloseClient(IPAddress,Port)
        Catch ex As Exception
            RaiseEvent Exception(ex)
        End Try
    End Sub

    ''' <summary>
    ''' 得到客户端断开或失去客户端联连事件
    ''' </summary>
    ''' <param name="IP">客户端联接IP</param>
    ''' <param name="Port">客户端联接端口号</param>
    ''' <remarks></remarks>
    Private Sub GetClientClose(ByVal IP As String,ByVal Port As String)
        Try
            If _Clients.ContainsKey(IP & "\&" & Port) Then
                SyncLock _Clients.SyncRoot
                    '_Clients.Item(IP & "\&" & Port)
                    _Clients.Remove(IP & "\&" & Port)
                End SyncLock
            End If
            RaiseEvent ClientClose(IP,Port)
        Catch ex As Exception
            RaiseEvent Exception(ex)
        End Try
    End Sub
#End Region


#Region "向客户端发送数据"

    ''' <summary>
    ''' 向客户端发送信息
    ''' </summary>
    ''' <param name="value">发送的内容</param>
    ''' <param name="IPAddress">IP地址</param>
    ''' <param name="Port">端口号</param>
    ''' <returns> Boolean</returns>
    ''' <remarks></remarks>
    Public Function SendData(ByVal value As Byte(),ByVal Port As String) As Boolean
        Try
            Dim clientSocket As System.Net.sockets.socket
            clientSocket = _Clients.Item(IPAddress & "\&" & Port)
            clientSocket.Send(value,SocketFlags.None)
            Return True
        Catch ex As Exception
            RaiseEvent Exception(ex)
            Return False
        End Try
    End Function
    Public Function SendFile(ByVal value As String,ByVal Port As String) As Boolean
        Try
            Dim clientSocket As System.Net.sockets.socket
            clientSocket = _Clients.Item(IPAddress & "\&" & Port)
            clientSocket.SendFile(value)
            Return True
        Catch ex As Exception
            RaiseEvent Exception(ex)
            Return False
        End Try
    End Function
    Public Function SendDataToAllClient(ByVal value As Byte()) As Boolean
        Try
            For Each clientSocket As System.Net.sockets.socket In _Clients.Values
                clientSocket.Send(value,SocketFlags.None)
            Next
            Return True
        Catch ex As Exception
            RaiseEvent Exception(ex)
            Return False
        End Try
    End Function

#End Region

    ''' <summary>
    ''' 得到客户端的Socket联接
    ''' </summary>
    ''' <param name="IPAddress">客户端的IP</param>
    ''' <param name="Port">客户端的端口号</param>
    ''' <returns>Socket联接</returns>
    ''' <remarks></remarks>
    Private Function GetClientSocket(ByVal IPAddress As String,ByVal Port As String) As Socket
        Try
            Dim ClientSocket As Socket
            ClientSocket = _Clients.Item(IPAddress & "\&" & Port)
            Return ClientSocket
        Catch ex As Exception
            RaiseEvent Exception(ex)
            Return nothing
        End Try
    End Function
#End Region

    Private Class ClientCommunication
        Public Event Exception(ByVal ex As Exception)

        Private ServerSocket As New System.Net.sockets.socket(AddressFamily.InterNetwork,ProtocolType.Tcp)
        Private myClientSocket As New System.Net.sockets.socket(AddressFamily.InterNetwork,ProtocolType.Tcp)
        Private myParentObject As Tcpserver
        Private oldbytes() As Byte
        Private _IPAddress,_Port As String
        Private NclientInfoT As IPEndPoint = nothing
        Private iLen As Integer
        Private allDone As New ManualResetEvent(False)
        ''' <summary>
        ''' 实例ClientCommunication类
        ''' </summary>
        ''' <param name="ServerSocket"></param>
        ''' <param name="ClientSocket"></param>
        ''' <param name="ParentObject"></param>
        ''' <remarks></remarks>
        Public Sub New(ByVal ServerSocket As Socket,ByVal ClientSocket As Socket,ByVal ParentObject As Tcpserver)
            Me.ServerSocket = ServerSocket
            myClientSocket = ClientSocket
            myParentObject = ParentObject
            NclientInfoT = CType(myClientSocket.RemoteEndPoint,IPEndPoint)
            _IPAddress = NclientInfoT.Address.ToString
            _Port = NclientInfoT.Port.ToString
        End Sub

        ''' <summary>
        ''' 客户端通讯主线程
        ''' </summary>
        ''' <remarks></remarks>
        Public Sub serverThreadProc()
            Try
                Dim sb As New SocketAndBuffer
                sb.socket = myClientSocket
                sb.socket.BeginReceive(sb.Buffer,AddressOf ReceiveCallBack,sb)
                'allDone.WaitOne()
            Catch ex As Exception
                RaiseEvent Exception(ex)
            End Try
        End Sub

        ''' <summary>
        ''' socket异步接收回调函数
        ''' </summary>
        ''' <param name="ar"></param>
        ''' <remarks></remarks>
        Private Sub ReceiveCallBack(ByVal ar As IAsyncResult)
            Dim sb As SocketAndBuffer
            allDone.Set()
            sb = CType(ar.AsyncState,SocketAndBuffer)
            Try
                If sb.socket.Connected Then
                    iLen = sb.socket.EndReceive(ar)
                    If iLen > 0 Then
                        ReDim oldbytes(iLen - 1)
                        Array.copy(sb.Buffer,iLen)
                        myParentObject.GetData_Byte(oldbytes,_Port)
                        sb.socket.BeginReceive(sb.Buffer,sb)
                    Else
                        If (Not myClientSocket Is nothing) Then
                            If myClientSocket.Connected Then
                                myClientSocket.Close()
                            Else
                                myClientSocket.Close()
                            End If
                            myClientSocket = nothing
                            If Not NclientInfoT Is nothing Then
                                myParentObject._Clients.Remove(_IPAddress & "\&" & _Port)
                                myParentObject.GetClientClose(_IPAddress,_Port)
                            End If
                        End If
                    End If
                End If
            Catch ex As Exception
                If (Not myClientSocket Is nothing) Then
                    If myClientSocket.Connected Then
                        myClientSocket.Close()
                    Else
                        myClientSocket.Close()
                    End If
                    myClientSocket = nothing
                    If Not NclientInfoT Is nothing Then
                        myParentObject._Clients.Remove(_IPAddress & "\&" & _Port)
                        myParentObject.GetClientClose(_IPAddress,_Port)
                    End If
                End If
                RaiseEvent Exception(ex)
            End Try
        End Sub

        ''' <summary>
        ''' 异步操作socket缓冲类
        ''' </summary>
        ''' <remarks></remarks>
        Private Class SocketAndBuffer
            Public Socket As System.Net.sockets.socket
            Public Buffer(8192) As Byte
        End Class
    End Class


End Class

2）TCP 客户端连接通信类

[vb] view plain copy print ?

1. ImportsSystem.Net
2. ImportsSystem.Net.sockets
3. ImportsSystem.Threading
5. PublicClassTCPClient
6. #Region"私有成员"
7. Private_LocationClientSocketAsSocket'本地侦听服务
8. Private_LocalPortAsString'本地端口
9. Private_LocalHostNameAsString
10. Private_LocalIPAsString
11. PrivateautoEventAsAutoResetEvent
12. Private_RemoteHostNameAsString'遠程端計算機名
13. Private_RemoteIPAsString'遠程端計算機IP
14. Private_RemotePortAsString'遠程端計算機Port
15. Private_RemoteIPOrHostNameAsString
16. 'Private_MaxClientAsInteger'最大客户端连接数
17. 'Private_ClientsAsNewSortedList'客户端队列
18. 'Private_ListenThreadAsThread=nothing'侦听线程
19. 'Private_ServerStartAsBoolean=False'服务器是否已经启动
20. Private_RecvMaxAsInteger'接收缓冲区大小
22. PrivateClientThreadAsThread
23. 'PrivateClitenStreamAsNetworkStream
24. PrivateIsstopAsBoolean=False
26. #EndRegion
28. #Region"事件"
29. '''<summary>
30. '''客户端联接事件
31. '''</summary>
32. '''<remarks></remarks>
33. PublicEventClientConnected()
34. '''<summary>
35. '''客户端断开事件
36. '''</summary>
37. '''<remarks></remarks>
38. PublicEventClientClosed()
39. '''<summary>
40. '''接收到客户端的数据
41. '''</summary>
42. '''<paramname="value">数据</param>
43. '''<remarks></remarks>
44. PublicEventDataArrived(ByValvalueAsByte(),ByValLenAsInteger)
45. '''<summary>
46. '''异常数据
47. '''</summary>
48. '''<paramname="ex"></param>
49. '''<remarks></remarks>
50. PublicEventException(ByValexAsException)
51. #EndRegion
53. #Region"属性"
54. '''<summary>
55. '''是否已經連接
56. '''</summary>
57. '''<value></value>
58. '''<returns></returns>
59. '''<remarks></remarks>
60. PublicReadOnlyPropertyConnected()AsBoolean
61. Get
62. Return_LocationClientSocket.Connected
63. EndGet
64. EndProperty
66. '''<summary>
67. '''本地計算機名稱
68. '''</summary>
69. '''<value></value>
70. '''<returns></returns>
71. '''<remarks></remarks>
72. PublicReadOnlyPropertyLocalHostName()AsString
73. Get
74. Return_LocalHostName
75. EndGet
76. EndProperty
78. '''<summary>
79. '''本地計算IP
80. '''</summary>
81. '''<value></value>
82. '''<returns></returns>
83. '''<remarks></remarks>
84. PublicReadOnlyPropertyLocalIP()AsString
85. Get
86. Return_LocalIP
87. EndGet
88. EndProperty
90. '''<summary>
91. '''本地計算機端口
92. '''</summary>
93. '''<value></value>
94. '''<returns></returns>
95. '''<remarks></remarks>
96. PublicReadOnlyPropertyLocalPort()AsString
97. Get
98. Return_LocalPort
99. EndGet
100. EndProperty
102. '''<summary>
103. '''遠程計算機IP
104. '''</summary>
105. '''<value></value>
106. '''<returns></returns>
107. '''<remarks></remarks>
108. PublicReadOnlyPropertyRemoteIP()AsString
109. Get
110. Return_RemoteIP
111. EndGet
113. EndProperty
115. '''<summary>
116. '''遠程計算機端口
117. '''</summary>
118. '''<value></value>
119. '''<returns></returns>
120. '''<remarks></remarks>
121. PublicReadOnlyPropertyRemotePort()AsString
122. Get
123. Return_RemotePort
124. EndGet
126. EndProperty
128. '''<summary>
129. '''遠程計算機名稱
130. '''</summary>
131. '''<value></value>
132. '''<returns></returns>
133. '''<remarks></remarks>
134. PublicReadOnlyPropertyRemoteHostName()AsString
135. Get
136. Return_RemoteHostName
137. EndGet
139. EndProperty
140. #EndRegion
142. #Region"方法"
143. '''<summary>
144. '''实例　Tcpserver
145. '''</summary>
146. '''<paramname="RemoteIPOrHostName">需要連接服務的IP地址或計算機名稱</param>
147. '''<paramname="Port">侦听客户端联接的端口号</param>
148. '''<paramname="RecvMax">接收缓冲区大小</param>
149. '''<paramname="RecvSleep">接收线程睡眠时间</param>
150. '''<remarks></remarks>
151. SubNew(ByValRemoteIPOrHostNameAsString,ByValPortAsString,ByValRecvSleepAsInteger)
152. Try
153. _LocalHostName=Dns.GetHostName()
155. '_RemoteIP=Dns.GetHostAddresses(RemoteIPOrHostName)(0).ToString
156. _RemotePort=Port
157. _RecvMax=RecvMax
158. _RemoteIPOrHostName=RemoteIPOrHostName
159. _RemotePort=Port
160. 'DimstrServerHostAsNewIPEndPoint(IPAddress.Any,Int32.Parse(_ListenPort))
162. '建立TCP侦听
163. _LocationClientSocket=NewSocket(AddressFamily.InterNetwork,ProtocolType.Tcp)
164. autoEvent=NewAutoResetEvent(False)
165. DimcThreadAsNewThread(NewThreadStart(AddressOfConnectHost))
166. cThread.Start()
167. autoEvent.WaitOne(1000,False)
168. cThread.Abort()
169. CatchexAsException
170. RaiseEventException(ex)
171. EndTry
172. EndSub
173. PublicSubConnectHost()
174. Try
175. DimremoteIPAsNet.IPAddress=nothing
176. IfIPAddress.TryParse(_RemoteIPOrHostName,remoteIP)Then
177. '_LocationClientSocket.BeginConnect()
178. _LocationClientSocket.Connect(remoteIP,_RemotePort)
179. '_RemoteIP=RemoteHostName
181. Else
182. _LocationClientSocket.Connect(_RemoteIPOrHostName,_RemotePort)
183. _RemoteHostName=RemoteHostName
184. EndIf
186. If_LocationClientSocket.ConnectedThen
187. _LocationClientSocket.SendBufferSize=_RecvMax
188. _LocationClientSocket.ReceiveBufferSize=_RecvMax
190. DimclientInfoTAsIPEndPoint
192. clientInfoT=CType(_LocationClientSocket.RemoteEndPoint,IPEndPoint)
193. _RemoteIP=clientInfoT.Address.ToString
194. 'DimremoteHostAsNet.IPHostEntry
196. _RemoteHostName=Dns.GetHostEntry(_RemoteIP).HostName
198. clientInfoT=CType(_LocationClientSocket.LocalEndPoint,IPEndPoint)
200. _LocalIP=clientInfoT.Address.ToString
201. _LocalPort=clientInfoT.Port.ToString
203. Isstop=False
205. RaiseEventClientConnected()
207. ClientThread=NewThread(NewThreadStart(AddressOfClientListen))
208. ClientThread.Start()
209. autoEvent.Set()
210. EndIf
211. CatchexAsException
213. EndTry
216. EndSub
218. '''<summary>
219. '''關閉客戶端連接
220. '''</summary>
221. '''<remarks></remarks>
222. PublicSubClose()
223. Try
224. If_LocationClientSocketIsnothingThenExitSub
225. Isstop=True
226. IfNotClientThreadIsnothingThen
227. Thread.Sleep(5)
228. ClientThread.Abort()
229. EndIf
230. _LocationClientSocket.Close()
231. _LocationClientSocket=nothing
232. ClientThread=nothing
233. RaiseEventClientClosed()
234. CatchexAsException
235. RaiseEventException(ex)
236. EndTry
238. EndSub
240. '''<summary>
241. '''实例　Tcpserver
242. '''</summary>
243. '''<paramname="value">發送的資料,二進制數組</param>
244. '''<remarks></remarks>
245. PublicFunctionSendData(ByValvalueAsByte())AsBoolean
246. Try
247. _LocationClientSocket.Send(value)
248. CatchexAsException
249. RaiseEventException(ex)
250. EndTry
251. EndFunction
253. PrivateSubClientListen()
254. DimtmpByt(8192)AsByte
255. DimrecData()AsByte
256. DimRAsInteger
257. WhileNotIsstop
258. Try
259. If_LocationClientSocket.Poll(50,SelectMode.SelectWrite)Then
260. R=_LocationClientSocket.Receive(tmpByt)
261. IfR>0Then
262. ReDimrecData(R-1)
263. Array.copy(tmpByt,recData,R)
264. RaiseEventDataArrived(recData,recData.Length)
265. Else
266. If(Not_LocationClientSocketIsnothing)Then
267. _LocationClientSocket.Close()
268. _LocationClientSocket=nothing
269. Isstop=True
270. RaiseEventClientClosed()
271. EndIf
272. EndIf
273. EndIf
274. CatchsexAsSocketException
275. Ifsex.ErrorCode=10054Then
276. If(Not_LocationClientSocketIsnothing)Then
277. _LocationClientSocket.Close()
278. _LocationClientSocket=nothing
279. Isstop=True
280. RaiseEventClientClosed()
281. EndIf
282. Else
283. RaiseEventException(sex)
284. EndIf
285. CatchexAsException
286. RaiseEventException(ex)
287. EndTry
288. EndWhile
289. EndSub
290. #EndRegion
292. EndClass

Imports System.Net
Imports System.Net.sockets
Imports System.Threading

Public Class TCPClient
#Region "私有成员"
    Private _LocationClientSocket As Socket '本地侦听服务
    Private _LocalPort As String '本地端口
    Private _LocalHostName As String
    Private _LocalIP As String
    Private autoEvent As AutoResetEvent
    Private _RemoteHostName As String '遠程端計算機名
    Private _RemoteIP As String     '遠程端計算機IP
    Private _RemotePort As String   '遠程端計算機Port
    Private _RemoteIPOrHostName As String
    'Private _MaxClient As Integer '最大客户端连接数
    'Private _Clients As New SortedList '客户端队列
    'Private _ListenThread As Thread = nothing '侦听线程
    'Private _ServerStart As Boolean = False '服务器是否已经启动
    Private _RecvMax As Integer '接收缓冲区大小 

    Private ClientThread As Thread
    'Private ClitenStream As NetworkStream
    Private Isstop As Boolean = False

#End Region

#Region "事件"
    ''' <summary>
    ''' 客户端联接事件
    ''' </summary> 
    ''' <remarks></remarks>
    Public Event ClientConnected()
    ''' <summary>
    ''' 客户端断开事件
    ''' </summary>
    ''' <remarks></remarks>
    Public Event ClientClosed()
    ''' <summary>
    ''' 接收到客户端的数据
    ''' </summary>
    ''' <param name="value">数据</param>
    ''' <remarks></remarks>
    Public Event DataArrived(ByVal value As Byte(),ByVal Len As Integer)
    ''' <summary>
    ''' 异常数据
    ''' </summary>
    ''' <param name="ex"></param>
    ''' <remarks></remarks>
    Public Event Exception(ByVal ex As Exception)
#End Region

#Region "属性"
    ''' <summary>
    ''' 是否已經連接
    ''' </summary>
    ''' <value></value>
    ''' <returns></returns>
    ''' <remarks></remarks>
    Public ReadOnly Property Connected() As Boolean
        Get
            Return _LocationClientSocket.Connected
        End Get
    End Property

    ''' <summary>
    ''' 本地計算機名稱
    ''' </summary>
    ''' <value></value>
    ''' <returns></returns>
    ''' <remarks></remarks>
    Public ReadOnly Property LocalHostName() As String
        Get
            Return _LocalHostName
        End Get
    End Property

    ''' <summary>
    ''' 本地計算IP
    ''' </summary>
    ''' <value></value>
    ''' <returns></returns>
    ''' <remarks></remarks>
    Public ReadOnly Property LocalIP() As String
        Get
            Return _LocalIP
        End Get
    End Property

    ''' <summary>
    ''' 本地計算機端口
    ''' </summary>
    ''' <value></value>
    ''' <returns></returns>
    ''' <remarks></remarks>
    Public ReadOnly Property LocalPort() As String
        Get
            Return _LocalPort
        End Get
    End Property

    ''' <summary>
    ''' 遠程計算機IP
    ''' </summary>
    ''' <value></value>
    ''' <returns></returns>
    ''' <remarks></remarks>
    Public ReadOnly Property RemoteIP() As String
        Get
            Return _RemoteIP
        End Get

    End Property

    ''' <summary>
    ''' 遠程計算機端口
    ''' </summary>
    ''' <value></value>
    ''' <returns></returns>
    ''' <remarks></remarks>
    Public ReadOnly Property RemotePort() As String
        Get
            Return _RemotePort
        End Get

    End Property

    ''' <summary>
    ''' 遠程計算機名稱
    ''' </summary>
    ''' <value></value>
    ''' <returns></returns>
    ''' <remarks></remarks>
    Public ReadOnly Property RemoteHostName() As String
        Get
            Return _RemoteHostName
        End Get

    End Property
#End Region

#Region "方法"
    ''' <summary>
    ''' 实例　Tcpserver
    ''' </summary>
    ''' <param name="RemoteIPOrHostName">需要連接服務的IP地址或計算機名稱</param>
    ''' <param name="Port">侦听客户端联接的端口号</param>
    ''' <param name="RecvMax">接收缓冲区大小</param>
    ''' <param name="RecvSleep">接收线程睡眠时间</param>
    ''' <remarks></remarks>
    Sub New(ByVal RemoteIPOrHostName As String,ByVal Port As String,ByVal RecvSleep As Integer)
        Try
            _LocalHostName = Dns.GetHostName()

            '_RemoteIP = Dns.GetHostAddresses(RemoteIPOrHostName)(0).ToString
            _RemotePort = Port
            _RecvMax = RecvMax
            _RemoteIPOrHostName = RemoteIPOrHostName
            _RemotePort = Port
            'Dim strServerHost As New IPEndPoint(IPAddress.Any,Int32.Parse(_ListenPort))

            '建立TCP侦听
            _LocationClientSocket = New Socket(AddressFamily.InterNetwork,ProtocolType.Tcp)
            autoEvent = New AutoResetEvent(False)
            Dim cThread As New Thread(New ThreadStart(AddressOf ConnectHost))
            cThread.Start()
            autoEvent.WaitOne(1000,False)
            cThread.Abort()
        Catch ex As Exception
            RaiseEvent Exception(ex)
        End Try
    End Sub
    Public Sub ConnectHost()
        Try
            Dim remoteIP As Net.IPAddress = nothing
            If IPAddress.TryParse(_RemoteIPOrHostName,remoteIP) Then
                '_LocationClientSocket.BeginConnect()
                _LocationClientSocket.Connect(remoteIP,_RemotePort)
                '_RemoteIP = RemoteHostName

            Else
                _LocationClientSocket.Connect(_RemoteIPOrHostName,_RemotePort)
                _RemoteHostName = RemoteHostName
            End If

            If _LocationClientSocket.Connected Then
                _LocationClientSocket.SendBufferSize = _RecvMax
                _LocationClientSocket.ReceiveBufferSize = _RecvMax

                Dim clientInfoT As IPEndPoint

                clientInfoT = CType(_LocationClientSocket.RemoteEndPoint,IPEndPoint)
                _RemoteIP = clientInfoT.Address.ToString
                'Dim remoteHost As Net.IPHostEntry

                _RemoteHostName = Dns.GetHostEntry(_RemoteIP).HostName

                clientInfoT = CType(_LocationClientSocket.LocalEndPoint,IPEndPoint)

                _LocalIP = clientInfoT.Address.ToString
                _LocalPort = clientInfoT.Port.ToString

                Isstop = False

                RaiseEvent ClientConnected()

                ClientThread = New Thread(New ThreadStart(AddressOf ClientListen))
                ClientThread.Start()
                autoEvent.Set()
            End If
        Catch ex As Exception

        End Try


    End Sub

    ''' <summary>
    ''' 關閉客戶端連接
    ''' </summary>
    ''' <remarks></remarks>
    Public Sub Close()
        Try
            If _LocationClientSocket Is nothing Then Exit Sub
            Isstop = True
            If Not ClientThread Is nothing Then
                Thread.Sleep(5)
                ClientThread.Abort()
            End If
            _LocationClientSocket.Close()
            _LocationClientSocket = nothing
            ClientThread = nothing
            RaiseEvent ClientClosed()
        Catch ex As Exception
            RaiseEvent Exception(ex)
        End Try

    End Sub

    ''' <summary>
    ''' 实例　Tcpserver
    ''' </summary>
    ''' <param name="value">發送的資料,二進制數組</param>
    ''' <remarks></remarks>
    Public Function SendData(ByVal value As Byte()) As Boolean
        Try
            _LocationClientSocket.Send(value)
        Catch ex As Exception
            RaiseEvent Exception(ex)
        End Try
    End Function

    Private Sub ClientListen()
        Dim tmpByt(8192) As Byte
        Dim recData() As Byte
        Dim R As Integer
        While Not Isstop
            Try
                If _LocationClientSocket.Poll(50,SelectMode.SelectWrite) Then
                    R = _LocationClientSocket.Receive(tmpByt)
                    If R > 0 Then
                        ReDim recData(R - 1)
                        Array.copy(tmpByt,R)
                        RaiseEvent DataArrived(recData,recData.Length)
                    Else
                        If (Not _LocationClientSocket Is nothing) Then
                            _LocationClientSocket.Close()
                            _LocationClientSocket = nothing
                            Isstop = True
                            RaiseEvent ClientClosed()
                        End If
                    End If
                End If
            Catch sex As SocketException
                If sex.ErrorCode = 10054 Then
                    If (Not _LocationClientSocket Is nothing) Then
                        _LocationClientSocket.Close()
                        _LocationClientSocket = nothing
                        Isstop = True
                        RaiseEvent ClientClosed()
                    End If
                Else
                    RaiseEvent Exception(sex)
                End If
            Catch ex As Exception
                RaiseEvent Exception(ex)
            End Try
        End While
    End Sub
#End Region

End Class

窗体调用TCP 类如下

服务器端：

[vb] view plain copy print ?

1. PublicWithEventsMyClientAsTcpserver

Public WithEvents MyClient As Tcpserver

客户机端：

[vb] view plain copy print ?

1. PublicWithEventsMyClientAsTCPClient

Public WithEvents MyClient As TCPClient

原文地址：https://www.jb51.cc/vb/258325.html