学步园

这段时间一直在优化Socket通讯这块，经常和Socket打交道，现在分享给大家一个小的案例，

代码如下：

byte[] m_dataBuffer = new byte [10];
        IAsyncResult m_result;
        public AsyncCallback m_pfnCallBack ;
        private System.Windows.Forms.Button btnClear;
        public Socket m_clientSocket;

//关闭连接

void ButtonCloseClick(object sender, System.EventArgs e)
        {
            if ( m_clientSocket != null )
            {
                m_clientSocket.Close ();
                m_clientSocket = null;
            }        
            Close();
        }

//连接服务器

void ButtonConnectClick(object sender, System.EventArgs e)
        {
            // See if we have text on the IP and Port text fields
            if(textBoxIP.Text == "" || textBoxPort.Text == ""){
                MessageBox.Show("IP Address and Port Number are required to connect to the Server\n");
                return;
            }
            try
            {
                UpdateControls(false);
                // Create the socket instance
                m_clientSocket = new Socket (AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp );
                
                // Cet the remote IP address
                IPAddress ip = IPAddress.Parse (textBoxIP.Text);
                int iPortNo = System.Convert.ToInt16 ( textBoxPort.Text);
                // Create the end point
                IPEndPoint ipEnd = new IPEndPoint (ip,iPortNo);
                // Connect to the remote host
                m_clientSocket.Connect ( ipEnd );
                if(m_clientSocket.Connected) {
                    
                    UpdateControls(true);
                    //Wait for data asynchronously
                    WaitForData();
                }
            }
            catch(SocketException se)
            {
                string str;
                str = "\nConnection failed, is the server running?\n" + se.Message;
                MessageBox.Show (str);
                UpdateControls(false);
            }        
        }     

//发送消息

void ButtonSendMessageClick(object sender, System.EventArgs e)
        {
            try
            {
                string msg = richTextTxMessage.Text;
                // New code to send strings
                NetworkStream networkStream = new NetworkStream(m_clientSocket);
                System.IO.StreamWriter streamWriter = new System.IO.StreamWriter(networkStream);
                streamWriter.WriteLine(msg);
                streamWriter.Flush();
                  
              
            }
            catch(SocketException se)
            {
                MessageBox.Show (se.Message );
            }    
        }

      //等待接收数据

       public void WaitForData()
        {
            try
            {
                if  ( m_pfnCallBack == null )
                {
                    m_pfnCallBack = new AsyncCallback (OnDataReceived);
                }
                SocketPacket theSocPkt = new SocketPacket ();
                theSocPkt.thisSocket = m_clientSocket;
                // Start listening to the data asynchronously
                m_result = m_clientSocket.BeginReceive (theSocPkt.dataBuffer,
                                                        0, theSocPkt.dataBuffer.Length,
                                                        SocketFlags.None,
                                                        m_pfnCallBack,
                                                        theSocPkt);
            }
            catch(SocketException se)
            {
                MessageBox.Show (se.Message );
            }

        }
        public class SocketPacket
        {
            public System.Net.Sockets.Socket thisSocket;
            public byte[] dataBuffer = new byte[1024];
        }
      
        public  void OnDataReceived(IAsyncResult asyn)
        {
            try
            {
                SocketPacket theSockId = (SocketPacket)asyn.AsyncState ;
                int iRx  = theSockId.thisSocket.EndReceive (asyn);
                char[] chars = new char[iRx +  1];
                System.Text.Decoder d = System.Text.Encoding.UTF8.GetDecoder();
                int charLen = d.GetChars(theSockId.dataBuffer, 0, iRx, chars, 0);
                System.String szData = new System.String(chars);
                richTextRxMessage.Text = richTextRxMessage.Text + szData;
                WaitForData();
            }
            catch (ObjectDisposedException )
            {
                System.Diagnostics.Debugger.Log(0,"1","\nOnDataReceived: Socket has been closed\n");
            }
            catch(SocketException se)
            {
                MessageBox.Show (se.Message );
            }
        }    
        private void UpdateControls( bool connected )
        {
            buttonConnect.Enabled = !connected;
            buttonDisconnect.Enabled = connected;
            string connectStatus = connected? "Connected" : "Not Connected";
            textBoxConnectStatus.Text = connectStatus;
        }
        void ButtonDisconnectClick(object sender, System.EventArgs e)
        {
            if ( m_clientSocket != null )
            {
                m_clientSocket.Close();
                m_clientSocket = null;
                UpdateControls(false);
            }
        }
       //----------------------------------------------------    
       // This is a helper function used (for convenience) to
       // get the IP address of the local machine
          //----------------------------------------------------
          String GetIP()
       {       
               String strHostName = Dns.GetHostName();
        
               // Find host by name
               IPHostEntry iphostentry = Dns.GetHostByName(strHostName);
        
               // Grab the first IP addresses
               String IPStr = "";
               foreach(IPAddress ipaddress in iphostentry.AddressList){
                IPStr = ipaddress.ToString();
                   return IPStr;
               }
               return IPStr;
       }