P2P即时通讯示例程序，既是服务端也是客户端
private void Listening() { Socket socket = null; //获取本机第一个可用的IP地址 myIPAddress = (IPAddress)Dns.GetHostAddresses(Dns.GetHostName()).GetValue(1); Random r = new Random(); while(true) { try { //随机产生一个0~65535之间的端口号 myPort = r.Next(65535); //创建TcpListner对象,在本机的IP和port端口监听连接到该IP和端口的请求 tcpListener = new TcpListener(myIPAddress, myPort); //开始监听,如果不出现异常，则说明IP地址和端口号可用 tcpListener.Start(); //显示IP地址和端口 ShowLocalIpAndPort(); ShowMyMessage(string.Format("尝试端口{0}监听成功",myPort)); ShowMyMessage(string.Format("<message>[{0}]{1:h点m分s秒}开始在{2}端口监听与本机的连接",myIPAddress,DateTime.Now,myPort)); break; } catch { //继续while循环，以便随机找下一个可用端口号，同时显示失败信息 ShowMyMessage(string.Format("尝试端口{0}监听失败",myPort)); } } while(true) { try{ //使用阻塞方式接收客户端连接，根据连接信息创建TcpClient对象 //注意：AccpetSocet接收到新的连接请求才会继续执行其后的语句 socket = tcpListener.AcceptSocket(); //如果再往下执行，说明已经根据客户端连接请求创建了套接字 //使用创建的套接字接收客户端发送的信息 NetworkStream stream = new NetworkStream(socket); StreamReader sr = new StreamReader(stream); string receiveMessage = sr.ReadLine(); //接收消息 int i1 = receiveMessage.IndexOf(","); int i2 = receiveMessage.IndexOf(",",i1 1); int i3 = receiveMessage.IndexOf(",",i2 1); string ipString = receiveMessage.Substring(0,i1); string portString = receiveMessage.Substring(i1 1,i2-i1-1); string messageTypeString = receiveMessage.Substring(i2 1,i3-i2-1); string messageString = receiveMessage.Substring(i3 1); ShowMyMessage(ipString,portString,messageTypeString,messageString); } catch{ //通过停止TcpListener使AcceptSocket方法出现异常 //在异常处理中关闭套接字并终止线程 if (socket != null) { if (socket.Connected) { socket.Shutdown(SocketShutdown.Receive); } socket.Close(); } myThread.Abort(); } } } delegate void ShowMessageDelegate(string str); private void ShowMyMessage(string str) { //比较调用的线程和创建的线程是否为同一个线程 //如果不是，结果为ture if (this.lbMessage.InvokeRequired == true) { //如果结果为true,则自动通过代理执行eles中语句的功能 //这里只需要传入参数str即可 //但是执行的功能会始终与else中的指定的功能相同，区别仅是通过代理完成 ShowMessageDelegate messageDelegate = new ShowMessageDelegate(ShowMyMessage); this.Invoke(messageDelegate,new object[]{str}); } else{ //在这里指定如果是同一个线程需要完成什么功能 //如果是不同的线程，系统会自动通过代理实现这里指定的功能 lbMessage.Items.Add(str); } } delegate void ShowMessageDelegate2(string ipString, string portString, string messageTypeString, string messageString); private void ShowMyMessage(string ipString, string portString, string messageTypeString, string messageString) { if (this.lbMessage.InvokeRequired == true) { ShowMessageDelegate2 messageDelegate = new ShowMessageDelegate2(ShowMyMessage); this.Invoke(messageDelegate,new object[]{ipString,portString ,messageTypeString,messageString}); } else{ //messageType的含义为 //connect前缀：第1次连接 //check前缀：检查接收者是否在线 //message前缀：聊天信息 int myfriendIndex = CheckMyFriend(ipString,portString); switch(messageTypeString) { case "connect": if (myfriendIndex == -1) { ListViewItem myFriendItem= new ListViewItem(new string[]{ipString,portString,"是"}); lvMyFriend.Items.Add(myFriendItem); //添加好友时，同时发送消息让好友也加自己为好友，同时向好友发送：“哈哈，我上线了”的文本消息 lbMessage.Items.Add(string.Format("[{0}:{1}说：{2}", ipString, portString, messageString)); } break; case "check": if (myfriendIndex == -1) { ListViewItem myFriendItem = new ListViewItem(new string[]{ipString,portString,"是"}); lvMyFriend.Items.Add(myFriendItem); } //不显要显示 break; case "message": lbMessage.Items.Add(string.Format("[{0}:{1}说：{2}",ipString,portString,messageString)); break; default : lbMessage.Items.Add(string.Format("什么意思呀：“{0}”",messageString)); break; } } }
评论