P2P的简单示例:VB.net版
点击次数：19 次 发布日期：2008-11-27 00:17:37 作者：源代码网
|
源代码网推荐 源代码网推荐 服务器端在启动成功后.输入help可以查看到服务器相关命令. 源代码网推荐 源代码网推荐 客户端在登陆成功后.输入help可以查看客户端相关命令.(登陆时用户名随便.) 源代码网推荐 源代码网推荐 以下是服务器端: 源代码网推荐 源代码网推荐 Imports System.Net 源代码网推荐 Imports System.Net.Sockets 源代码网推荐 Imports System.Text 源代码网推荐 Imports System.Threading 源代码网推荐 Imports System.Collections 源代码网推荐 源代码网推荐 Module myUDPServer 源代码网推荐 源代码网推荐 #Region "全局变量" 源代码网推荐 源代码网推荐 Dim ServerSocket As New Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp) 源代码网推荐 Dim ipep As IPEndPoint = New IPEndPoint(IPAddress.Any, 11000) 源代码网推荐 源代码网推荐 Dim htUserList As New Hashtable "用来保存在线用户和用户的"IP和端口" 源代码网推荐 源代码网推荐 Dim userName(0) As String 源代码网推荐 Dim userIPEP(0) As IPEndPoint 源代码网推荐 Dim userTime(0) As Integer 源代码网推荐 源代码网推荐 Dim timerDelegate As New TimerCallback(AddressOf onLineTimeOut) 源代码网推荐 源代码网推荐 #End Region 源代码网推荐 源代码网推荐 #Region "参数" 源代码网推荐 源代码网推荐 "以下是客户端到服务器端的消息开头 源代码网推荐 Const LOGININ As String = "10" "请求登陆的消息|||消息形式:10+自己的用户名 源代码网推荐 Const LOGINOUT As String = "11" "请求登出的消息|||消息形式:11+自己的用户名 源代码网推荐 Const GETULIST As String = "12" "请求获得在线用户列表|||消息形式:12 源代码网推荐 Const P2PCONN As String = "13" "请求P2P连接的消息|||消息形式:13+自己的用户名+|+对方的用户名 源代码网推荐 Const HOLDLINE As String = "14" "保持连接.|||消息开式:14+自己的用户名 源代码网推荐 源代码网推荐 "以下是服务器到客户端的消息开头 源代码网推荐 Const HVUSER As String = "20" "用户名已存在 源代码网推荐 Const GETUSER As String = "21" "在线用户列表|||消息格式:21+用户名+EP 源代码网推荐 Const MAKHOLD As String = "22" "打洞命令|||消息格式:22+IP 源代码网推荐 Const LOGINOK As String = "23" "登陆成功 源代码网推荐 Const SERVCLS As String = "24" "服务器关闭 源代码网推荐 Const MSGEND As String = "25" "消息结束 源代码网推荐 源代码网推荐 "以下是服务器端的命名 源代码网推荐 Const EXITPRO As String = "EXIT" "退出命令 源代码网推荐 Const SHOWULIST As String = "SHOWUSER" "显示在线用户 源代码网推荐 Const HELP As String = "HELP" "显示帮助 源代码网推荐 源代码网推荐 #End Region 源代码网推荐 源代码网推荐 #Region "方法" 源代码网推荐 源代码网推荐 "主函数,程序入口 源代码网推荐 Sub Main() 源代码网推荐 源代码网推荐 "获得服务器的IP地址 源代码网推荐 Dim addressList As System.Net.IPAddress() = Dns.GetHostByName(Dns.GetHostName()).AddressList 源代码网推荐 Dim ServerIP As IPAddress = addressList(0) 源代码网推荐 源代码网推荐 ServerSocket.Bind(ipep) 源代码网推荐 Console.WriteLine("服务器正在启动....") 源代码网推荐 Console.WriteLine("服务器IP:" & ServerIP.ToString & " 正在监听" & ipep.Port.ToString & "端口") 源代码网推荐 Dim listenTH As New Thread(AddressOf listen) 源代码网推荐 listenTH.Start() "启用监听的线程 源代码网推荐 Console.WriteLine("服务器启动成功.....") 源代码网推荐 源代码网推荐 Dim timer As New Timer(timerDelegate, Nothing, 0, 5000) 源代码网推荐 源代码网推荐 Dim SVInput As String 源代码网推荐 While True 源代码网推荐 Console.Write("Server>") 源代码网推荐 SVInput = Console.ReadLine().ToUpper 源代码网推荐 Select Case SVInput 源代码网推荐 Case EXITPRO 源代码网推荐 listenTH.Abort() 源代码网推荐 ServerSocket.Close() 源代码网推荐 Exit Sub 源代码网推荐 Case SHOWULIST 源代码网推荐 showUser() 源代码网推荐 Case HELP 源代码网推荐 Console.Write("*********************************" & Chr(10) & Chr(13) & "exit:输出当前程序" & Chr(10) & Chr(13) & "showuser:显示当前在线用户例表" & Chr(10) & Chr(13) & "help:显示帮助" & Chr(10) & Chr(13) & "*********************************" & Chr(10) & Chr(13)) 源代码网推荐 Case Else 源代码网推荐 Console.WriteLine("*********************************" & Chr(10) & Chr(13) & "笨瓜,你输入的不是有效的命令." & Chr(10) & Chr(13) & "*********************************") 源代码网推荐 End Select 源代码网推荐 End While 源代码网推荐 源代码网推荐 源代码网推荐 End Sub 源代码网推荐 源代码网推荐 "打印在线用户 源代码网推荐 Sub showUser() 源代码网推荐 Dim hava As Boolean = False 源代码网推荐 If userName.Length <> 0 Then 源代码网推荐 Dim i As Integer 源代码网推荐 For i = 1 To userName.Length - 1 源代码网推荐 If userName(i) <> "" Then 源代码网推荐 hava = True 源代码网推荐 Exit For 源代码网推荐 End If 源代码网推荐 Next 源代码网推荐 If hava = False Then 源代码网推荐 Console.WriteLine("*********************************" & Chr(10) & Chr(13) & "当前没有用户在线" & Chr(10) & Chr(13) & "*********************************") 源代码网推荐 Exit Sub 源代码网推荐 End If 源代码网推荐 Console.WriteLine("*********************************") 源代码网推荐 For i = 1 To userName.Length - 1 源代码网推荐 If userName(i) <> "" Then 源代码网推荐 Console.WriteLine("用户名:" & userName(i) & " 地址:" & userIPEP(i).ToString) 源代码网推荐 End If 源代码网推荐 Next 源代码网推荐 Console.WriteLine("*********************************") 源代码网推荐 Else 源代码网推荐 Console.WriteLine("*********************************" & Chr(10) & Chr(13) & "当前没有用户在线" & Chr(10) & Chr(13) & "*********************************") 源代码网推荐 End If 源代码网推荐 End Sub 源代码网推荐 源代码网推荐 "服务器监听函数 源代码网推荐 Sub listen() 源代码网推荐 源代码网推荐 While True 源代码网推荐 源代码网推荐 Try 源代码网推荐 Dim recv As Integer = 0 源代码网推荐 Dim data As [Byte]() = New Byte(1024) {} 源代码网推荐 Dim sender As New IPEndPoint(IPAddress.Any, 0) 源代码网推荐 Dim tempRemoteEP As EndPoint = CType(sender, EndPoint) 源代码网推荐 recv = ServerSocket.ReceiveFrom(data, tempRemoteEP) 源代码网推荐 源代码网推荐 "Console.WriteLine(Encoding.Unicode.GetString(data)) 源代码网推荐 源代码网推荐 Dim msgHead As String = Encoding.Unicode.GetString(data, 0, 4) 源代码网推荐 Select Case msgHead 源代码网推荐 Case LOGININ 源代码网推荐 Dim LoginThing As String = userLogin(data, tempRemoteEP, recv) 源代码网推荐 If LoginThing = HVUSER Then 源代码网推荐 sendMsg(HVUSER, tempRemoteEP) 源代码网推荐 ElseIf LoginThing = LOGINOK Then 源代码网推荐 sendMsg(LOGINOK, tempRemoteEP) 源代码网推荐 源代码网推荐 End If 源代码网推荐 源代码网推荐 Case LOGINOUT 源代码网推荐 userloginout(data, recv) 源代码网推荐 源代码网推荐 Case GETULIST 源代码网推荐 Dim userinfo As String = getUserList() 源代码网推荐 sendMsg(userinfo, tempRemoteEP) 源代码网推荐 源代码网推荐 Case P2PCONN 源代码网推荐 questP2PConn(data, recv) 源代码网推荐 源代码网推荐 Case HOLDLINE 源代码网推荐 holdOnLine(data, recv) 源代码网推荐 End Select 源代码网推荐 源代码网推荐 Catch e As Exception 源代码网推荐 "Console.WriteLine(e.ToString) 源代码网推荐 End Try 源代码网推荐 End While 源代码网推荐 源代码网推荐 End Sub 源代码网推荐 源代码网推荐 "转发P2P连接请求 源代码网推荐 Private Sub questP2PConn(ByVal data() As Byte, ByVal recv As Integer) 源代码网推荐 源代码网推荐 Dim recvStr As String = Encoding.Unicode.GetString(data, 4, recv - 4) 源代码网推荐 Dim split() As String = recvStr.Split("|") 源代码网推荐 源代码网推荐 Dim fromEP As IPEndPoint 源代码网推荐 Dim toEP As IPEndPoint 源代码网推荐 Dim i As Integer 源代码网推荐 For i = 1 To userName.Length - 1 源代码网推荐 If userName(i) = split(0) Then 源代码网推荐 fromEP = userIPEP(i) 源代码网推荐 End If 源代码网推荐 If userName(i) = split(1) Then 源代码网推荐 toEP = userIPEP(i) 源代码网推荐 End If 源代码网推荐 Next 源代码网推荐 Dim holdbytes() As Byte = Encoding.Unicode.GetBytes(MAKHOLD & fromEP.ToString) 源代码网推荐 ServerSocket.SendTo(holdbytes, toEP) 源代码网推荐 End Sub 源代码网推荐 源代码网推荐 "函数.返回所有在线用户.其格式:用户名+|+用户IPEP+| 源代码网推荐 Private Function getUserList() As String 源代码网推荐 Dim userInfo As String = GETUSER 源代码网推荐 Dim i As Integer 源代码网推荐 For i = 1 To userName.Length - 1 源代码网推荐 If userName(i) <> "" Then 源代码网推荐 userInfo += userName(i) & "|" & userIPEP(i).ToString & "|" 源代码网推荐 End If 源代码网推荐 Next 源代码网推荐 Return userInfo 源代码网推荐 End Function 源代码网推荐 源代码网推荐 "用户登陆,直接返回登陆是否成功的值 源代码网推荐 Private Function userLogin(ByVal data As Byte(), ByVal userEP As IPEndPoint, ByVal recvCount As Integer) As String 源代码网推荐 源代码网推荐 Dim Uname As String = Encoding.Unicode.GetString(data, 4, recvCount - 4) 源代码网推荐 源代码网推荐 Dim Uinfobytes() As Byte 源代码网推荐 源代码网推荐 Dim i As Integer 源代码网推荐 Dim j As Integer 源代码网推荐 源代码网推荐 For i = 1 To userName.Length - 1 源代码网推荐 If Uname = userName(i) Then 源代码网推荐 Return HVUSER 源代码网推荐 End If 源代码网推荐 Next 源代码网推荐 源代码网推荐 For i = 1 To userName.Length - 1 源代码网推荐 If userName(i) = "" Then 源代码网推荐 userName(i) = Uname 源代码网推荐 userIPEP(i) = userEP 源代码网推荐 userTime(i) = 60 源代码网推荐 Console.Write(Chr(10) & Chr(13) & "*********************************" & Chr(10) & Chr(13) & Uname.Trim & "上线了." & "用户地址:" & userEP.ToString & Chr(10) & Chr(13) & "*********************************" & Chr(10) & Chr(13)) 源代码网推荐 Console.Write("Server>") 源代码网推荐 源代码网推荐 Uinfobytes = Encoding.Unicode.GetBytes(LOGININ & userName(i) & "|" & userIPEP(i).ToString) 源代码网推荐 源代码网推荐 For j = 1 To userName.Length - 1 源代码网推荐 If userName(j) <> "" And userName(j) <> Uname Then 源代码网推荐 ServerSocket.SendTo(Uinfobytes, userIPEP(j)) 源代码网推荐 End If 源代码网推荐 Next 源代码网推荐 Return LOGINOK 源代码网推荐 End If 源代码网推荐 Next 源代码网推荐 源代码网推荐 Dim userCount As Integer = userName.Length 源代码网推荐 源代码网推荐 ReDim Preserve userName(userCount) 源代码网推荐 ReDim Preserve userIPEP(userCount) 源代码网推荐 ReDim Preserve userTime(userCount) 源代码网推荐 源代码网推荐 userName(userName.Length - 1) = Uname 源代码网推荐 userIPEP(userIPEP.Length - 1) = userEP 源代码网推荐 userTime(userTime.Length - 1) = 60 源代码网推荐 源代码网推荐 Console.Write(Chr(10) & Chr(13) & "*********************************" & Chr(10) & Chr(13) & Uname.Trim & "上线了." & "用户地址:" & userEP.ToString & Chr(10) & Chr(13) & "*********************************" & Chr(10) & Chr(13)) 源代码网推荐 Console.Write("Server>") 源代码网推荐 源代码网推荐 Uinfobytes = Encoding.Unicode.GetBytes(LOGININ & userName(userName.Length - 1) & "|" & userIPEP(userName.Length - 1).ToString) 源代码网推荐 源代码网推荐 For j = 1 To userName.Length - 1 源代码网推荐 If userName(j) <> "" And userName(j) <> Uname Then 源代码网推荐 ServerSocket.SendTo(Uinfobytes, userIPEP(j)) 源代码网推荐 End If 源代码网推荐 Next 源代码网推荐 Return LOGINOK 源代码网推荐 源代码网推荐 End Function 源代码网推荐 源代码网推荐 "用户登出 源代码网推荐 Private Sub userloginout(ByVal data As Byte(), ByVal recvCount As Integer) 源代码网推荐 源代码网推荐 Dim i As Integer 源代码网推荐 Dim Uname As String = Encoding.Unicode.GetString(data, 4, recvCount - 4) 源代码网推荐 源代码网推荐 For i = 1 To userName.Length - 1 源代码网推荐 源代码网推荐 If Uname = userName(i) Then 源代码网推荐 源代码网推荐 Dim loginOutMsg As String = LOGINOUT & userName(i) 源代码网推荐 源代码网推荐 源代码网推荐 userName(i) = "" 源代码网推荐 userIPEP(i) = Nothing 源代码网推荐 userTime(i) = 0 源代码网推荐 源代码网推荐 Dim j As Integer 源代码网推荐 For j = 1 To userName.Length - 1 源代码网推荐 If userName(j) <> "" Then 源代码网推荐 源代码网推荐 sendMsg(loginOutMsg, userIPEP(j)) 源代码网推荐 源代码网推荐 End If 源代码网推荐 Next 源代码网推荐 源代码网推荐 Console.WriteLine(Chr(10) & Chr(13) & "*********************************") 源代码网推荐 Console.WriteLine("用户" & Uname & "下线了.") 源代码网推荐 Console.WriteLine("*********************************") 源代码网推荐 Console.Write("Server>") 源代码网推荐 源代码网推荐 Exit For 源代码网推荐 源代码网推荐 End If 源代码网推荐 源代码网推荐 Next 源代码网推荐 源代码网推荐 End Sub 源代码网推荐 源代码网推荐 "保持用户在线的过程 源代码网推荐 Private Sub holdOnLine(ByVal data As Byte(), ByVal recvCount As Integer) 源代码网推荐 源代码网推荐 Dim Uname As String = Encoding.Unicode.GetString(data, 4, recvCount - 4) 源代码网推荐 源代码网推荐 Dim i As Integer 源代码网推荐 源代码网推荐 For i = 1 To userName.Length - 1 源代码网推荐 源代码网推荐 If Uname = userName(i) Then 源代码网推荐 源代码网推荐 userTime(i) = 60 源代码网推荐 Exit For 源代码网推荐 源代码网推荐 End If 源代码网推荐 源代码网推荐 Next 源代码网推荐 源代码网推荐 End Sub 源代码网推荐 源代码网推荐 "用户超时退出 源代码网推荐 Private Sub onLineTimeOut(ByVal state As [Object]) 源代码网推荐 源代码网推荐 Dim i As Integer 源代码网推荐 源代码网推荐 For i = 1 To userName.Length - 1 源代码网推荐 源代码网推荐 If userTime(i) > 0 Then 源代码网推荐 源代码网推荐 userTime(i) -= 5 源代码网推荐 源代码网推荐 If userTime(i) <= 0 Then 源代码网推荐 源代码网推荐 Dim loginoutmsg As String = LOGINOUT & userName(i) 源代码网推荐 源代码网推荐 Console.WriteLine(Chr(10) & Chr(13) & "*********************************") 源代码网推荐 Console.WriteLine("用户" & userName(i) & "下线了.") 源代码网推荐 Console.WriteLine("*********************************") 源代码网推荐 Console.Write("Server>") 源代码网推荐 源代码网推荐 userName(i) = "" 源代码网推荐 userIPEP(i) = Nothing 源代码网推荐 源代码网推荐 Dim ULoginOutbytes() As Byte = Encoding.Unicode.GetBytes(loginoutmsg) 源代码网推荐 源代码网推荐 Dim j As Integer 源代码网推荐 For j = 1 To userName.Length - 1 源代码网推荐 源代码网推荐 If userName(j) <> "" Then 源代码网推荐 If userIPEP(j) Is Nothing Then 源代码网推荐 Else 源代码网推荐 ServerSocket.SendTo(ULoginOutbytes, userIPEP(j)) 源代码网推荐 End If 源代码网推荐 End If 源代码网推荐 源代码网推荐 Next 源代码网推荐 源代码网推荐 End If 源代码网推荐 源代码网推荐 End If 源代码网推荐 源代码网推荐 Next 源代码网推荐 源代码网推荐 End Sub 源代码网推荐 源代码网推荐 "发送消息的函数 源代码网推荐 Sub sendMsg(ByVal msg As String, ByVal remoteEP As IPEndPoint) 源代码网推荐 Dim sendBytes As [Byte]() = Encoding.Unicode.GetBytes(msg) 源代码网推荐 Try 源代码网推荐 源代码网推荐 ServerSocket.SendTo(sendBytes, remoteEP) 源代码网推荐 源代码网推荐 Catch e As Exception 源代码网推荐 Console.WriteLine(e.ToString()) 源代码网推荐 End Try 源代码网推荐 End Sub 源代码网推荐 源代码网推荐 #End Region 源代码网推荐 源代码网推荐 End Module 源代码网推荐 源代码网推荐 以下是客户端: 源代码网推荐 源代码网推荐 Imports System.Net 源代码网推荐 Imports System.Net.Sockets 源代码网推荐 Imports System.Text 源代码网推荐 Imports System.Threading 源代码网推荐 源代码网推荐 源代码网推荐 Module Module1 源代码网推荐 源代码网推荐 #Region "参数" 源代码网推荐 源代码网推荐 "以下是客户端到服务器端的消息开头 源代码网推荐 Const LOGININ As String = "10" "请求登陆的消息|||消息形式:10+自己的用户名 源代码网推荐 Const LOGINOUT As String = "11" "请求登出的消息|||消息形式:11+自己的用户名 源代码网推荐 Const GETULIST As String = "12" "请求获得在线用户列表|||消息形式:12+自己的用户名 源代码网推荐 Const P2PCONN As String = "13" "请求P2P连接的消息|||消息形式:13+自己的用户名+对方的用户名 源代码网推荐 Const HOLDLINE As String = "14" "保持连接.|||消息开式:14+自己的用户名 源代码网推荐 源代码网推荐 "以下是服务器到客户端的消息开头 源代码网推荐 Const HVUSER As String = "20" "用户名已存在 源代码网推荐 Const GETUSER As String = "21" "在线用户列表|||消息格式:21+用户名+EP 源代码网推荐 Const MAKHOLD As String = "22" "打洞命令|||消息格式:22+IP 源代码网推荐 Const LOGINOK As String = "23" "登陆成功 源代码网推荐 Const SERVCLS As String = "24" "服务器关闭 源代码网推荐 Const MSGEND As String = "25" "消息结束 源代码网推荐 源代码网推荐 "以下是客户端到客户端的消息开头 源代码网推荐 Const HOLDOK As String = "30" "打洞成功 源代码网推荐 Const CHATMSG As String = "31" "聊天消息 源代码网推荐 Const CHTMSGEND As String = "32" "聊天消息发送成功 源代码网推荐 源代码网推荐 "以下是客户端的命名 源代码网推荐 Const EXITPRO As String = "EXIT" "退出命令 源代码网推荐 Const SHOWULIST As String = "SHOWUSER" "显示在线用户 源代码网推荐 Const HELP As String = "HELP" "显示帮助 源代码网推荐 Const SEND As String = "SEND" "发送消息 源代码网推荐 源代码网推荐 #End Region 源代码网推荐 源代码网推荐 #Region "全局全量" 源代码网推荐 源代码网推荐 Delegate Sub myMethodDelegate(ByRef myInData As Byte()) "登陆时用的事件 源代码网推荐 源代码网推荐 "Dim MaxTry As Integer = 5 源代码网推荐 Dim msgSendEnd As Boolean = False "消息是否发送成功,若发送成功,则会返回结束消息 源代码网推荐 Dim ThListen As New Thread(AddressOf listen) "监听的线程 源代码网推荐 Dim ClientSocket As New Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp) "客户端套节字的定义 源代码网推荐 Dim username As String "当前用户名 源代码网推荐 Dim ServerEP As IPEndPoint "服务器的IPEP 源代码网推荐 Dim holdBytes As [Byte]() = Encoding.Unicode.GetBytes(HOLDLINE & username) "和服务器保持连接连接时用到的byte数组 源代码网推荐 Dim OLUserName() As String 源代码网推荐 Dim OLUserEP() As IPEndPoint 源代码网推荐 Dim getUrecCount As Integer 源代码网推荐 Dim testHold As Boolean = False 源代码网推荐 Dim testChat As Boolean = False 源代码网推荐 源代码网推荐 Private receiveDone As ManualResetEvent "在登陆时用来阻塞线程,等待收到数据 源代码网推荐 Private sendDone As ManualResetEvent "用来阴塞发送消息的线程.等待收到回送的确认消息 源代码网推荐 Private getUDone As ManualResetEvent "用来阻塞请求好友名单的线程,等待接收好友名单 源代码网推荐 Private holdDone As ManualResetEvent "用来阻塞打洞时的线程 源代码网推荐 Private chatDone As ManualResetEvent "用来阻塞发送聊天消息时的线程 源代码网推荐 源代码网推荐 Dim timerDelegate As New TimerCallback(AddressOf holdonline) "为保持在线状态弄得 源代码网推荐 源代码网推荐 #End Region 源代码网推荐 源代码网推荐 #Region "方法" 源代码网推荐 源代码网推荐 "主函数,程序入口 源代码网推荐 Sub Main() 源代码网推荐 Dim InputIP As String 源代码网推荐 Dim InputOK As Boolean = False 源代码网推荐 源代码网推荐 源代码网推荐 "判断输入的IP,并且保存服务器的IPEP 源代码网推荐 While InputOK <> True 源代码网推荐 Console.Write("请输入服务器IP:") 源代码网推荐 InputIP = Console.ReadLine() 源代码网推荐 Try 源代码网推荐 ServerEP = New IPEndPoint(IPAddress.Parse(InputIP), 11000) 源代码网推荐 InputOK = True 源代码网推荐 Catch 源代码网推荐 Console.WriteLine("你输入的服务器IP不正确,请重新输入.") 源代码网推荐 InputOK = False 源代码网推荐 End Try 源代码网推荐 End While 源代码网推荐 源代码网推荐 Dim bool As Boolean = False 源代码网推荐 源代码网推荐 "判断用户是否登陆成功 源代码网推荐 While bool <> True 源代码网推荐 源代码网推荐 Dim LoginOK As Boolean = Login() 源代码网推荐 If LoginOK = True Then 源代码网推荐 bool = True 源代码网推荐 Else 源代码网推荐 Console.Write("是否重试:输入Y重试,输入任意值退出程序:") 源代码网推荐 Dim tempYN As String = Console.ReadLine.ToUpper 源代码网推荐 If tempYN = "Y" Then 源代码网推荐 bool = False 源代码网推荐 Else 源代码网推荐 Exit Sub 源代码网推荐 End If 源代码网推荐 End If 源代码网推荐 源代码网推荐 End While 源代码网推荐 源代码网推荐 Console.WriteLine("用户名:" & username) 源代码网推荐 holdBytes = Encoding.Unicode.GetBytes(HOLDLINE & username) 源代码网推荐 "登陆成功后.用一个timer,每隔50秒向服务器发送消息,保持在线状态跟在主机注册的端口 源代码网推荐 Dim timer As New Timer(timerDelegate, Nothing, 10000, 50000) 源代码网推荐 源代码网推荐 "请求在线名单 源代码网推荐 Console.WriteLine("正在获取在线名单,请稍后....") 源代码网推荐 Dim getUbool As Boolean = False 源代码网推荐 While getUbool <> True 源代码网推荐 getUbool = getU() 源代码网推荐 If getUbool = False Then 源代码网推荐 Console.Write("是否重试:输入Y重试,输入任意值退出程序:") 源代码网推荐 Dim tempYN As String = Console.ReadLine.ToUpper 源代码网推荐 If tempYN = "Y" Then 源代码网推荐 bool = False 源代码网推荐 Else 源代码网推荐 Exit Sub 源代码网推荐 End If 源代码网推荐 End If 源代码网推荐 End While 源代码网推荐 源代码网推荐 ThListen.Start() 源代码网推荐 源代码网推荐 "用来处理客户端的一些命令 源代码网推荐 Dim SVInput As String 源代码网推荐 While True 源代码网推荐 Console.Write("Client>") 源代码网推荐 SVInput = Console.ReadLine().ToUpper 源代码网推荐 Select Case SVInput 源代码网推荐 Case EXITPRO 源代码网推荐 exitApp() 源代码网推荐 ThListen.Abort() 源代码网推荐 ClientSocket.Close() 源代码网推荐 Exit Sub 源代码网推荐 Case SHOWULIST 源代码网推荐 Console.WriteLine("*********************************") 源代码网推荐 showUserList() 源代码网推荐 Console.WriteLine("*********************************") 源代码网推荐 Case HELP 源代码网推荐 Console.Write("*********************************" & Chr(10) & Chr(13) & "exit:输出当前程序" & Chr(10) & Chr(13) & "showuser:显示当前在线用户例表" & Chr(10) & Chr(13) & "send:发送消息.格式:send 用户名 消息" & Chr(10) & Chr(13) & "help:显示帮助" & Chr(10) & Chr(13) & "*********************************" & Chr(10) & Chr(13)) 源代码网推荐 Case Else 源代码网推荐 If SVInput.Substring(0, 4) = "SEND" Then 源代码网推荐 Dim split() As String = SVInput.Split(" ") 源代码网推荐 If split.Length = 3 Then 源代码网推荐 sendChatMsg(split(1), split(2)) 源代码网推荐 Else 源代码网推荐 Console.WriteLine("*********************************" & Chr(10) & Chr(13) & "你输入的命令格式不正确.send命令格式为:send 用户名 你的消息" & Chr(10) & Chr(13) & "*********************************") 源代码网推荐 End If 源代码网推荐 Else 源代码网推荐 Console.WriteLine("*********************************" & Chr(10) & Chr(13) & "笨瓜,你输入的不是有效的命令." & Chr(10) & Chr(13) & "*********************************") 源代码网推荐 End If 源代码网推荐 End Select 源代码网推荐 End While 源代码网推荐 源代码网推荐 End Sub 源代码网推荐 源代码网推荐 "登陆函数 源代码网推荐 Private Function Login() As Boolean 源代码网推荐 源代码网推荐 receiveDone = New ManualResetEvent(False) 源代码网推荐 Dim userBytes As [Byte]() 源代码网推荐 源代码网推荐 Dim userOK As Boolean = False 源代码网推荐 源代码网推荐 Console.Write("请输入你的用户名:") 源代码网推荐 源代码网推荐 "判断用户名是否符合格式 源代码网推荐 While (userOK <> True) 源代码网推荐 username = Console.ReadLine.ToUpper 源代码网推荐 userBytes = Encoding.Unicode.GetBytes(LOGININ & username) 源代码网推荐 源代码网推荐 If userBytes.Length > 24 Or userBytes.Length < 10 Then 源代码网推荐 Console.WriteLine("用户名不得小于6个字节,且不得大于20个字节.") 源代码网推荐 Console.Write("请重新输入你的用户名:") 源代码网推荐 Else 源代码网推荐 userOK = True 源代码网推荐 End If 源代码网推荐 End While 源代码网推荐 源代码网推荐 "向服务器发送客户消息 源代码网推荐 ClientSocket.SendTo(userBytes, ServerEP) 源代码网推荐 源代码网推荐 Dim data As [Byte]() = New Byte(1024) {} 源代码网推荐 源代码网推荐 Dim comStr As String = Encoding.Unicode.GetString(data, 0, 4) 源代码网推荐 源代码网推荐 "异面的接收服务器回送的消息 源代码网推荐 Dim DGrecv As New myMethodDelegate(AddressOf recvLogin) 源代码网推荐 DGrecv.BeginInvoke(data, Nothing, Nothing) 源代码网推荐 源代码网推荐 "等待服务器回送消息的时长为10秒,否则为服务器超时 源代码网推荐 receiveDone.WaitOne(30000, True) 源代码网推荐 源代码网推荐 Dim recvStr As String = Encoding.Unicode.GetString(data, 0, 4) 源代码网推荐 源代码网推荐 If recvStr = comStr Then 源代码网推荐 Console.WriteLine("服务器超时.登陆失败!!") 源代码网推荐 Return False 源代码网推荐 End If 源代码网推荐 源代码网推荐 If Encoding.Unicode.GetString(data, 0, 4) = LOGINOK Then 源代码网推荐 Console.WriteLine("登陆成功!!") 源代码网推荐 Return True 源代码网推荐 ElseIf Encoding.Unicode.GetString(data, 0, 4) = HVUSER Then 源代码网推荐 Console.WriteLine("用户名重复.登陆失败!!") 源代码网推荐 Return False 源代码网推荐 Else 源代码网推荐 Console.WriteLine("服务器未知错误,登陆失败!!") 源代码网推荐 Return False 源代码网推荐 End If 源代码网推荐 源代码网推荐 End Function 源代码网推荐 源代码网推荐 "登出函数 源代码网推荐 Private Sub exitApp() 源代码网推荐 源代码网推荐 Dim loginOutStr As String = LOGINOUT & username 源代码网推荐 Dim sendBytes As [Byte]() = Encoding.Unicode.GetBytes(loginOutStr) 源代码网推荐 ClientSocket.SendTo(sendBytes, ServerEP) 源代码网推荐 源代码网推荐 End Sub 源代码网推荐 源代码网推荐 "请求好友列表的函数 源代码网推荐 Private Function getU() As Boolean 源代码网推荐 源代码网推荐 getUDone = New ManualResetEvent(False) 源代码网推荐 Dim getUbytes As Byte() = Encoding.Unicode.GetBytes(GETULIST) 源代码网推荐 ClientSocket.SendTo(getUbytes, ServerEP) 源代码网推荐 源代码网推荐 Dim data As [Byte]() = New Byte(4056) {} 源代码网推荐 Dim comStr As String = Encoding.Unicode.GetString(data, 0, 4) 源代码网推荐 源代码网推荐 Dim GUrecv As New myMethodDelegate(AddressOf recvGetU) 源代码网推荐 GUrecv.BeginInvoke(data, Nothing, Nothing) 源代码网推荐 源代码网推荐 getUDone.WaitOne(30000, True) 源代码网推荐 源代码网推荐 Dim recvStr As String = Encoding.Unicode.GetString(data, 0, 4) 源代码网推荐 源代码网推荐 If recvStr = comStr Then 源代码网推荐 Console.WriteLine("服务器超时.或取好友名单失败!!") 源代码网推荐 Return False 源代码网推荐 End If 源代码网推荐 源代码网推荐 If Encoding.Unicode.GetString(data, 0, 4) = GETUSER Then 源代码网推荐 getUserList(data, getUrecCount) 源代码网推荐 Console.WriteLine("获取在线名单成功!!") 源代码网推荐 showUserList() 源代码网推荐 Return True 源代码网推荐 Else 源代码网推荐 Console.WriteLine("服务器未知错误,获取在线名单失败!!") 源代码网推荐 Return False 源代码网推荐 End If 源代码网推荐 源代码网推荐 End Function 源代码网推荐 源代码网推荐 "登陆时用来异步的接收服务器发送的消息 源代码网推荐 Sub recvLogin(ByRef inData As Byte()) 源代码网推荐 源代码网推荐 ClientSocket.Receive(inData) 源代码网推荐 receiveDone.Set() 源代码网推荐 源代码网推荐 End Sub 源代码网推荐 源代码网推荐 "请求好友名单时用来异步接收服务器发送的消息 源代码网推荐 Sub recvGetU(ByRef inData As Byte()) 源代码网推荐 源代码网推荐 getUrecCount = ClientSocket.Receive(inData) 源代码网推荐 getUDone.Set() 源代码网推荐 源代码网推荐 End Sub 源代码网推荐 源代码网推荐 "处理收到的在线用户信息 源代码网推荐 Private Sub getUserList(ByVal userInfobytes() As Byte, ByVal reccount As Integer) 源代码网推荐 源代码网推荐 Dim ustr As String = Encoding.Unicode.GetString(userInfobytes, 4, reccount - 4) 源代码网推荐 源代码网推荐 Dim splitStr() As String = Nothing 源代码网推荐 源代码网推荐 splitStr = Ustr.Split("|") 源代码网推荐 源代码网推荐 Dim IPEPSplit() As String = Nothing 源代码网推荐 源代码网推荐 Dim i As Integer = 0 源代码网推荐 源代码网推荐 Dim k As Integer 源代码网推荐 For k = 0 To splitStr.Length - 2 Step 2 源代码网推荐 ReDim Preserve OLUserName(i) 源代码网推荐 ReDim Preserve OLUserEP(i) 源代码网推荐 源代码网推荐 OLUserName(i) = splitStr(k) 源代码网推荐 IPEPSplit = splitStr(k + 1).Split(":") 源代码网推荐 OLUserEP(i) = New IPEndPoint(IPAddress.Parse(IPEPSplit(0)), IPEPSplit(1)) 源代码网推荐 源代码网推荐 IPEPSplit = Nothing 源代码网推荐 i += 1 源代码网推荐 Next 源代码网推荐 源代码网推荐 End Sub 源代码网推荐 源代码网推荐 "显示在线用户 源代码网推荐 Private Sub showUserList() 源代码网推荐 Dim i As Integer 源代码网推荐 For i = 0 To OLUserName.Length - 1 源代码网推荐 If OLUserName(i) <> "" Then 源代码网推荐 Console.WriteLine("用户名:" & OLUserName(i) & " 用户IP:" & OLUserEP(i).ToString) 源代码网推荐 End If 源代码网推荐 Next 源代码网推荐 End Sub 源代码网推荐 源代码网推荐 "客户程序监听的函数 源代码网推荐 Sub listen() 源代码网推荐 源代码网推荐 While True 源代码网推荐 源代码网推荐 Try 源代码网推荐 Dim recv As Integer = 0 "收到的字节数 源代码网推荐 Dim data As [Byte]() = New Byte(1024) {} "缓冲区大小 源代码网推荐 Dim sender As New IPEndPoint(IPAddress.Any, 0) 源代码网推荐 Dim tempRemoteEP As EndPoint = CType(sender, EndPoint) 源代码网推荐 recv = ClientSocket.ReceiveFrom(data, tempRemoteEP) 源代码网推荐 源代码网推荐 Dim msgHead As String = Encoding.Unicode.GetString(data, 0, 4) "获得消息头的内容 源代码网推荐 Select Case msgHead 源代码网推荐 Case MSGEND 源代码网推荐 msgSendEnd = True 源代码网推荐 sendDone.Set() 源代码网推荐 Case LOGININ 源代码网推荐 addOnLine(data, recv) 源代码网推荐 Case LOGINOUT 源代码网推荐 removeOnLine(data, recv) 源代码网推荐 Case MSGEND 源代码网推荐 msgSendEnd = True 源代码网推荐 sendDone.Set() 源代码网推荐 Case MAKHOLD 源代码网推荐 Console.WriteLine(Chr(10) & Chr(13) & "收到打洞消息.") 源代码网推荐 makeHold(data, recv) 源代码网推荐 Console.Write("Client>") 源代码网推荐 Case CHATMSG 源代码网推荐 showChatMsg(data, recv) 源代码网推荐 Case HOLDOK 源代码网推荐 testHold = True 源代码网推荐 holdDone.Set() 源代码网推荐 Case CHTMSGEND 源代码网推荐 testChat = True 源代码网推荐 chatDone.Set() 源代码网推荐 End Select 源代码网推荐 源代码网推荐 Catch 源代码网推荐 End Try 源代码网推荐 源代码网推荐 End While 源代码网推荐 End Sub 源代码网推荐 源代码网推荐 "发送聊天消息 源代码网推荐 Private Sub sendChatMsg(ByVal remoteUser As String, ByVal chatMsgStr As String) 源代码网推荐 源代码网推荐 If remoteUser = username Then 源代码网推荐 Console.WriteLine("猪头,你想干什么!!!") 源代码网推荐 Exit Sub 源代码网推荐 End If 源代码网推荐 源代码网推荐 Dim i As Integer 源代码网推荐 源代码网推荐 Dim remoteUEP As IPEndPoint 源代码网推荐 For i = 0 To OLUserName.Length - 1 源代码网推荐 If remoteUser = OLUserName(i) Then 源代码网推荐 remoteUEP = OLUserEP(i) 源代码网推荐 Exit For 源代码网推荐 End If 源代码网推荐 If i = OLUserName.Length - 1 Then 源代码网推荐 Console.WriteLine("找不到你想发送的用户.") 源代码网推荐 Exit Sub 源代码网推荐 End If 源代码网推荐 Next 源代码网推荐 源代码网推荐 Dim msgbytes() As Byte = Encoding.Unicode.GetBytes(CHATMSG & username & "|" & chatMsgStr) 源代码网推荐 Dim holdbytes() As Byte = Encoding.Unicode.GetBytes(P2PCONN & username & "|" & remoteUser) 源代码网推荐 源代码网推荐 chatDone = New ManualResetEvent(False) 源代码网推荐 ClientSocket.SendTo(msgbytes, remoteUEP) 源代码网推荐 chatDone.WaitOne(10000, True) 源代码网推荐 If testChat = True Then 源代码网推荐 testChat = False 源代码网推荐 Exit Sub 源代码网推荐 End If 源代码网推荐 源代码网推荐 testHold = False 源代码网推荐 While testHold <> True 源代码网推荐 Console.WriteLine("打洞ing.....") 源代码网推荐 holdDone = New ManualResetEvent(False) 源代码网推荐 ClientSocket.SendTo(holdbytes, remoteUEP) 源代码网推荐 ClientSocket.SendTo(holdbytes, ServerEP) 源代码网推荐 holdDone.WaitOne(10000, True) 源代码网推荐 If testHold = True Then 源代码网推荐 Exit While 源代码网推荐 Else 源代码网推荐 Console.WriteLine("打洞超时,发送消息失败.") 源代码网推荐 Console.Write("是否重试,按Y重试,按任意值结束发送:") 源代码网推荐 Dim YorN As String = Console.ReadLine().ToUpper 源代码网推荐 If YorN = "Y" Then 源代码网推荐 testHold = False 源代码网推荐 Else 源代码网推荐 Exit Sub 源代码网推荐 End If 源代码网推荐 End If 源代码网推荐 End While 源代码网推荐 源代码网推荐 While testChat <> True 源代码网推荐 Console.WriteLine("打洞成功,正在准备发送.....") 源代码网推荐 chatDone = New ManualResetEvent(False) 源代码网推荐 ClientSocket.SendTo(msgbytes, remoteUEP) 源代码网推荐 chatDone.WaitOne(10000, True) 源代码网推荐 If testChat = True Then 源代码网推荐 Console.WriteLine("消息发送成功!!") 源代码网推荐 Exit While 源代码网推荐 Else 源代码网推荐 Console.WriteLine("发送超时,发送消息失败.") 源代码网推荐 Console.Write("是否重试,按Y重试,按任意值结束发送:") 源代码网推荐 Dim YorN As String = Console.ReadLine().ToUpper 源代码网推荐 If YorN = "Y" Then 源代码网推荐 testChat = False 源代码网推荐 Else 源代码网推荐 Exit Sub 源代码网推荐 End If 源代码网推荐 End If 源代码网推荐 End While 源代码网推荐 testHold = False 源代码网推荐 testChat = False 源代码网推荐 End Sub 源代码网推荐 源代码网推荐 "处理聊天消息 源代码网推荐 Private Sub showChatMsg(ByVal indata() As Byte, ByVal recvcount As Integer) 源代码网推荐 Dim msgStr As String = Encoding.Unicode.GetString(indata, 4, recvcount - 4) 源代码网推荐 Dim splitStr() As String = msgStr.Split("|") 源代码网推荐 Dim fromUname As String = splitStr(0) 源代码网推荐 Dim msg As String = splitStr(1) 源代码网推荐 Console.WriteLine(Chr(10) & Chr(13) & "收到来自" & fromUname & "的消息:" & msg) 源代码网推荐 Console.Write("Client>") 源代码网推荐 Dim i As Integer 源代码网推荐 For i = 0 To OLUserName.Length - 1 源代码网推荐 If OLUserName(i) = fromUname Then 源代码网推荐 Exit For 源代码网推荐 End If 源代码网推荐 Next 源代码网推荐 Dim tempbytes() As Byte = Encoding.Unicode.GetBytes(CHTMSGEND) 源代码网推荐 ClientSocket.SendTo(tempbytes, OLUserEP(i)) 源代码网推荐 End Sub 源代码网推荐 源代码网推荐 "处理打洞函数 源代码网推荐 Private Sub makeHold(ByVal indata() As Byte, ByVal recvcount As Integer) 源代码网推荐 Dim makholdstr As String = Encoding.Unicode.GetString(indata, 4, recvcount) 源代码网推荐 Dim ipepstr() As String = makholdstr.Split(":") 源代码网推荐 Dim holdEP As IPEndPoint = New IPEndPoint(IPAddress.Parse(ipepstr(0)), ipepstr(1)) 源代码网推荐 源代码网推荐 Dim holdbytes() As Byte = Encoding.Unicode.GetBytes(HOLDOK & username) 源代码网推荐 ClientSocket.SendTo(holdbytes, holdEP) 源代码网推荐 Console.WriteLine("回送打洞消息.") 源代码网推荐 End Sub 源代码网推荐 源代码网推荐 "处理用户上线的函数 源代码网推荐 Private Sub addOnLine(ByVal inData() As Byte, ByVal recvCount As Integer) 源代码网推荐 Dim inStr As String = Encoding.Unicode.GetString(inData, 4, recvCount - 4) 源代码网推荐 Dim userinfo() As String = inStr.Split("|") 源代码网推荐 Dim strUserEP() As String = userinfo(1).Split(":") 源代码网推荐 源代码网推荐 Dim i As Integer 源代码网推荐 For i = 0 To OLUserName.Length - 1 源代码网推荐 If OLUserName(i) = "" Then 源代码网推荐 OLUserName(i) = userinfo(0) 源代码网推荐 OLUserEP(i) = New IPEndPoint(IPAddress.Parse(strUserEP(0)), strUserEP(1)) 源代码网推荐 Console.WriteLine(Chr(10) & Chr(13) & "用户" & OLUserName(i) & "上线了. 用户地址:" & OLUserEP(i).ToString) 源代码网推荐 Console.Write("Client>") 源代码网推荐 Exit Sub 源代码网推荐 End If 源代码网推荐 Next 源代码网推荐 源代码网推荐 ReDim Preserve OLUserName(i + 1) 源代码网推荐 ReDim Preserve OLUserEP(i + 1) 源代码网推荐 源代码网推荐 OLUserName(i + 1) = userinfo(0) 源代码网推荐 OLUserEP(i + 1) = New IPEndPoint(IPAddress.Parse(strUserEP(0)), strUserEP(1)) 源代码网推荐 源代码网推荐 Console.WriteLine(Chr(10) & Chr(13) & "用户" & OLUserName(i + 1) & "上线了. 用户地址:" & OLUserEP(i + 1).ToString) 源代码网推荐 Console.Write("Client>") 源代码网推荐 源代码网推荐 End Sub 源代码网推荐 源代码网推荐 "处理用户下线的函数 源代码网推荐 Private Sub removeOnLine(ByVal inData() As Byte, ByVal recvCount As Integer) 源代码网推荐 Dim offUname As String = Encoding.Unicode.GetString(inData, 4, recvCount - 4) 源代码网推荐 源代码网推荐 Dim i As Integer 源代码网推荐 For i = 0 To OLUserName.Length - 1 源代码网推荐 If OLUserName(i) = offUname Then 源代码网推荐 OLUserName(i) = "" 源代码网推荐 OLUserEP(i) = Nothing 源代码网推荐 Console.WriteLine(Chr(10) & Chr(13) & "用户" & offUname & "下线了.") 源代码网推荐 Console.Write("Client>") 源代码网推荐 Exit Sub 源代码网推荐 End If 源代码网推荐 Next 源代码网推荐 End Sub 源代码网推荐 源代码网推荐 "发送消息的函数 源代码网推荐 Public Function sendmsg(ByVal msg As String, ByVal sendToIPEP As IPEndPoint) As String 源代码网推荐 源代码网推荐 Dim sendBytes As [Byte]() = Encoding.Unicode.GetBytes(msg) 源代码网推荐 源代码网推荐 "判断发送的字节数是否超过了服务器缓冲区大小 源代码网推荐 If sendBytes.Length > 1024 Then 源代码网推荐 Return "W输入的字数太多" 源代码网推荐 End If 源代码网推荐 源代码网推荐 "判断消息是否发送成功 源代码网推荐 While msgSendEnd = False 源代码网推荐 源代码网推荐 sendDone = New ManualResetEvent(False) 源代码网推荐 源代码网推荐 Try 源代码网推荐 源代码网推荐 ClientSocket.SendTo(sendBytes, sendToIPEP) 源代码网推荐 源代码网推荐 sendDone.WaitOne(10000, True) "阻塞线程10秒 源代码网推荐 源代码网推荐 If msgSendEnd = False Then 源代码网推荐 Console.WriteLine("消息发送超时") 源代码网推荐 Else 源代码网推荐 Exit While 源代码网推荐 End If 源代码网推荐 源代码网推荐 Catch e As Exception 源代码网推荐 源代码网推荐 Console.WriteLine("发送消息失败" & e.ToString) 源代码网推荐 Exit Function 源代码网推荐 源代码网推荐 End Try 源代码网推荐 源代码网推荐 Console.Write("是否重试?按Y重试,按任意键退出:") 源代码网推荐 Dim userInput As String = Console.ReadLine.ToUpper 源代码网推荐 源代码网推荐 If userInput = "Y" Then 源代码网推荐 Else 源代码网推荐 msgSendEnd = False 源代码网推荐 Exit Function 源代码网推荐 End If 源代码网推荐 源代码网推荐 End While 源代码网推荐 源代码网推荐 msgSendEnd = False 源代码网推荐 源代码网推荐 End Function 源代码网推荐 源代码网推荐 "用保持在线状态的函数 源代码网推荐 Private Sub holdonline(ByVal state As [Object]) 源代码网推荐 ClientSocket.SendTo(holdBytes, ServerEP) 源代码网推荐 End Sub 源代码网推荐 源代码网推荐 #End Region 源代码网推荐 源代码网推荐 End Module 源代码网推荐 源代码网推荐 源代码网推荐 源代码网推荐 作者Blog：http://blog.csdn.net/ekinwt/ 源代码网推荐 源代码网供稿. |
