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;
                }
            }
        }