谁提供一个vb端口映射软件源码我
Imports System。Net
Imports System。Net。Sockets
Namespace SocketLib '类库文件
'端口映射管理类
Public Class ClsPortMaper
Dim _thrReceiveMap As System。 Threading。Thread
Dim _tcpAcpSocket, _tcpMapSocket As Socket
Dim _strRemoteHost As String
Dim _intRemotePort As Integer
...全部
Imports System。Net
Imports System。Net。Sockets
Namespace SocketLib '类库文件
'端口映射管理类
Public Class ClsPortMaper
Dim _thrReceiveMap As System。
Threading。Thread
Dim _tcpAcpSocket, _tcpMapSocket As Socket
Dim _strRemoteHost As String
Dim _intRemotePort As Integer
Dim _collectionPortMaper As ClsPortMaperCollection
Dim _mcsSendTimeout As Integer = 3000
Dim _mcsReceiveTimeout As Integer = 3000
Public TagName As String
Public Sub New(ByVal tcpAcpSocket As Socket, ByVal tcpMapSocket As Socket, ByVal collectionPortMaper As ClsPortMaperCollection)
Me。
_tcpAcpSocket = tcpAcpSocket
Me。_tcpMapSocket = tcpMapSocket
Me。
_collectionPortMaper = collectionPortMaper
_strRemoteHost = CType(_tcpAcpSocket。
RemoteEndPoint, IPEndPoint)。Address。ToString
_intRemotePort = CType(_tcpAcpSocket。
RemoteEndPoint, IPEndPoint)。Port
TagName = _strRemoteHost & ":" & _intRemotePort
End Sub
Public Sub StartService()
If Me。
_tcpAcpSocket Is Nothing Then
Throw New System。Exception("请求连接Socket为空！")
Return
End If
If Me。
_tcpMapSocket Is Nothing Then
Throw New System。Exception("映射连接Socket为空！")
Return
End If
Me。
_tcpAcpSocket。SetSocketOption(SocketOptionLevel。Socket, SocketOptionName。SendTimeout, _mcsSendTimeout)
Me。
_tcpAcpSocket。SetSocketOption(SocketOptionLevel。Socket, SocketOptionName。ReceiveTimeout, _mcsReceiveTimeout)
Me。
_tcpMapSocket。SetSocketOption(SocketOptionLevel。Socket, SocketOptionName。SendTimeout, _mcsSendTimeout)
Me。
_tcpMapSocket。SetSocketOption(SocketOptionLevel。Socket, SocketOptionName。ReceiveTimeout, _mcsReceiveTimeout)
_collectionPortMaper。
Add(Me)
_collectionPortMaper。RaiseConnectionRequest(Me。_strRemoteHost, Me。
_intRemotePort, Me。_collectionPortMaper。Count)
_thrReceiveMap = New System。
Threading。Thread(AddressOf ReceiveMapService)
_thrReceiveMap。Start()
End Sub
Private Sub ReceiveMapService()
While True
Try
If Me。
_tcpAcpSocket。Poll(0, SelectMode。SelectRead) Then
If Me。
_tcpAcpSocket。Available > 0 Then
Do
Dim bytData(1024) As Byte
Me。
_tcpAcpSocket。Receive(bytData)
Me。
_tcpMapSocket。Send(bytData)
Loop While Me。
_tcpAcpSocket。Available > 0
Else
'Client Closed
StopService(False)
Return
End If
End If
System。
Threading。Thread。Sleep(10)
If Me。_tcpMapSocket。
Poll(0, SelectMode。SelectRead) Then
If Me。
_tcpMapSocket。Available > 0 Then
Do
Dim bytData(1024) As Byte
Me。
_tcpMapSocket。Receive(bytData)
Me。
_tcpAcpSocket。Send(bytData)
Loop While Me。
_tcpMapSocket。Available > 0
Else
'Client Closed
StopService(False)
Return
End If
End If
Catch ex As Exception
MessageBox。
Show(ex。Message)
Return
End Try
System。
Threading。Thread。Sleep(10)
End While
End Sub
Public Sub StopService(ByVal ForceStop As Boolean)
_tcpAcpSocket。
Shutdown(SocketShutdown。Both)
_tcpMapSocket。Shutdown(SocketShutdown。
Both)
_tcpAcpSocket。Close()
_tcpMapSocket。
Close()
_collectionPortMaper。Remove(Me)
_collectionPortMaper。
RaiseConnectionClose(Me。_strRemoteHost, Me。_intRemotePort, Me。_collectionPortMaper。Count)
If ForceStop Then
_thrReceiveMap。
Abort()
End If
End Sub
End Class
'PortMaper管理集
Public Class ClsPortMaperCollection
Inherits System。
Collections。CollectionBase
Public Event ConnectionRequest(ByVal strRemoteHost As String, ByVal intRemotePort As Integer, ByVal intTotalCount As Integer)
Public Event ConnectionClose(ByVal strRemoteHost As String, ByVal intRemotePort As Integer, ByVal intTotalCount As Integer)
Public Sub New()
End Sub
Public Function Add(ByVal objValue As ClsPortMaper) As Integer
Return List。
Add(objValue)
End Function
Public Property Item(ByVal index As Integer) As ClsPortMaper
Get
Return List(index)
End Get
Set(ByVal Value As ClsPortMaper)
List(index) = Value
End Set
End Property
Public ReadOnly Property Item(ByVal TagName As String) As ClsPortMaper
Get
For Each obj As ClsPortMaper In List
If obj。
TagName = TagName Then Return obj
Next
Return Nothing
End Get
End Property
Public Function GetIndex(ByVal TagName As String) As Integer
Dim i As Integer = 0
Do While i 0) And (mapPort >= 0) Then
Me。
_mapHost = mapHost
Me。_mapPort = mapPort
Me。
_mapEndPoint = New IPEndPoint(Dns。Resolve(_mapHost)。AddressList(0), _mapPort)
Else
Throw New Exception("初始化参数错误！")
Return
End If
End Sub
Public Sub Start()
_threadListen = New System。
Threading。Thread(AddressOf ListenService)
_threadListen。Start()
End Sub
Private Sub ListenService()
While True
Do While _listener。
Pending
Dim socAccept As Socket = _listener。
AcceptSocket()
Dim socMap As New Socket(AddressFamily。
InterNetwork, SocketType。Stream, ProtocolType。Tcp)
Try
socMap。
Connect(_mapEndPoint)
Catch ex As Exception
MessageBox。
Show("MapHost连接错误！" & ex。Message, "注意", MessageBoxButtons。OK, MessageBoxIcon。Error)
Return
End Try
Dim objPortMaper As New ClsPortMaper(socAccept, socMap, _portMaperCollection)
objPortMaper。
StartService()
Loop
System。
Threading。Thread。Sleep(100)
End While
End Sub
Private Sub _portMaperCollection_ConnectionRequest(ByVal strRemoteHost As String, ByVal intRemotePort As Integer, ByVal intTotalCount As Integer) Handles _portMaperCollection。
ConnectionRequest
RaiseEvent ConnectionRequest(strRemoteHost, intRemotePort, intTotalCount)
End Sub
Private Sub _portMaperCollection_ConnectionClose(ByVal strRemoteHost As String, ByVal intRemotePort As Integer, ByVal intTotalCount As Integer) Handles _portMaperCollection。
ConnectionClose
RaiseEvent ConnectionClose(strRemoteHost, intRemotePort, intTotalCount)
End Sub
Public Sub StopServer()
_threadListen。
Abort()
_listener。Stop()
While _portMaperCollection。
Count > 0
_portMaperCollection。Item(0)。
StopService(True)
End While
End Sub
End Class
End Namespace 。收起
