基於socket實現的簡單的聊天程序

　 記得八年前第一次使用socket做的一個五子棋程序，需要序列化棋子對象，傳遞到對方的電腦上。　一個偶然的機會，第二次使用socket做點事情。先看聊天服務器端的實現：

     服務器端要實現以下功能：

     1、啟動服務，開啟監聽

     2、持續不斷地接收消息

     3、發送消息

    啟動服務，創建監聽socket，綁定Ip和端口：

        /// <summary>
        /// 啟動服務
        /// </summary>
        private void Start()
        {
            socketwatch = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);

            IPAddress address = IPAddress.Parse("10.0.0.31");

            IPEndPoint point = new IPEndPoint(address, 8025);

            socketwatch.Bind(point);

            //將套接字的監聽隊列長度限制為20  
            socketwatch.Listen(20);

            //創建一個監聽線程  
            threadwatch = new Thread(watchconnecting);

            threadwatch.IsBackground = true;

            threadwatch.Start();
        }

創建接收數據的Socket：

 //監聽客戶端發來的請求  
        private void watchconnecting()
        {
            Socket connection = null;
            while (true)  //持續不斷監聽客戶端發來的請求     
            {
                try
                {
                    connection = socketwatch.Accept();
                }
                catch (Exception ex)
                {
                    MessageBox.Show(ex.Message); //提示套接字監聽異常     
                    break;
                }
                //獲取客戶端的IP和端口號  
                IPAddress clientIP = (connection.RemoteEndPoint as IPEndPoint).Address;
                int clientPort = (connection.RemoteEndPoint as IPEndPoint).Port;

                //讓客戶顯示"連接成功的"的信息  
                string sendmsg = "連接服務端成功！\r\n" + "本地IP:" + clientIP + "，本地端口" + clientPort.ToString();
                byte[] arrSendMsg = Encoding.UTF8.GetBytes(sendmsg);
                connection.Send(arrSendMsg);

                RemoteEndPoint = connection.RemoteEndPoint.ToString(); //客戶端網絡結點號  
                dic.Add(RemoteEndPoint, connection);    //添加客戶端信息  

                IPEndPoint netpoint = connection.RemoteEndPoint as IPEndPoint;

                //創建一個通信線程      
                ParameterizedThreadStart pts = new ParameterizedThreadStart(recv);
                Thread thread = new Thread(pts);
                thread.IsBackground = true;//設置為后台線程，隨着主線程退出而退出     
                //啟動線程     
                thread.Start(connection);
            }
        }

socketwatch.Accept() 會創建一個新的socket，它用來負責和某個客戶端的通訊。

接收數據：

        private void recv(object socketclientpara)
        {

            Socket socketServer = socketclientpara as Socket;
            while (true)
            {
                byte[] arrServerRecMsg = new byte[1024 * 1024];
                try
                {
                    int length = socketServer.Receive(arrServerRecMsg);

                    string strSRecMsg = Encoding.UTF8.GetString(arrServerRecMsg, 0, length);

                    this.Dispatcher.BeginInvoke(DispatcherPriority.Normal,
                              (ThreadStart)delegate()
                              {
                                  MessagePool.Insert(MessagePool.Count, new Message() { MessageInfo = strSRecMsg, IdentityName = socketServer.RemoteEndPoint.ToString() });
                              });
                }
                catch (Exception ex)
                {
                    MessageBox.Show(ex.Message);
                    socketServer.Close();
                    break;
                }
            }
        }

把從客戶端接收過來的字節流變為字符串，然后添加到頁面上。

發送消息：

        private static object lockPool = new object();
        public static ObservableCollection<Message> MessagePool = new ObservableCollection<Message>();
        private void send_Click(object sender, RoutedEventArgs e)
        {
            string msg = this.message.Text;

            this.message.Clear();

            lock (lockPool)
            {
                MessagePool.Insert(MessagePool.Count, new Message() { MessageInfo = msg, IdentityName = "wbq" });
            }

            string sendMsg = msg; 
            byte[] bytes = System.Text.Encoding.UTF8.GetBytes(sendMsg);

            if (dic.Count > 0)
                dic.First().Value.Send(bytes);
        }

dic.First().Value.Send，從字典中獲取到之前創建好的通訊socket，然后調用send方法。

客戶端需要實現以下功能：
1、和服務器建立連接
2、接收數據
3、發送數據

建立連接：

   private void Start()
        {

            //定義一個套接字監聽  
            socketclient = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);


           var servers= GetServers();


           if (servers.Count > 0)
           {

               //獲取文本框中的IP地址  
               IPAddress address = IPAddress.Parse(servers.First().IPToPing);

               //將獲取的IP地址和端口號綁定在網絡節點上  
               IPEndPoint point = new IPEndPoint(address, int.Parse(servers.First().Port));

               try
               {
                   //客戶端套接字連接到網絡節點上，用的是Connect  
                   socketclient.Connect(point);
               }
               catch (Exception)
               {
                   //MessageBox.  
                   MessageBox.Show("連接失敗\r\n");
                   return;
               }

               threadclient = new Thread(recv);

               threadclient.IsBackground = true;

               threadclient.Start();
           }
        }

 

接收消息：

       // 接收服務端發來信息的方法    
        private void recv()//  
        {
            while (true)//持續監聽服務端發來的消息  
            {
                try
                {
                    //定義一個1M的內存緩沖區，用於臨時性存儲接收到的消息  
                    byte[] arrRecvmsg = new byte[1024 * 1024];

                    //將客戶端套接字接收到的數據存入內存緩沖區，並獲取長度  
                    int length = socketclient.Receive(arrRecvmsg);

                    //將套接字獲取到的字符數組轉換為人可以看懂的字符串  
                    string strRevMsg = Encoding.UTF8.GetString(arrRecvmsg, 0, length);

                    this.Dispatcher.BeginInvoke(DispatcherPriority.Normal,
                               (ThreadStart)delegate()
                               {
                                   MessagePool.Insert(MessagePool.Count, new Message() { MessageInfo = strRevMsg, IdentityName = socketclient.RemoteEndPoint.ToString() });
                               });
                }
                catch (Exception ex)
                {
                    MessageBox.Show("遠程服務器已經中斷連接" + ex.Message);
                    break;
                }
            }
        }

發送消息：

        private void send_Click(object sender, RoutedEventArgs e)
        {
            string strRevMsg = this.message.Text;
            this.message.Clear();

            lock (lockPool)
            {
                MessagePool.Insert(MessagePool.Count, new Message() { MessageInfo = strRevMsg, IdentityName = "我(" + socketclient.LocalEndPoint.ToString() + ")" });
            }

            //將輸入的內容字符串轉換為機器可以識別的字節數組     
            byte[] arrClientSendMsg = Encoding.UTF8.GetBytes(strRevMsg);
            //調用客戶端套接字發送字節數組     
            socketclient.Send(arrClientSendMsg);
        }

經過和同事的測試，可以實現簡單的文字聊天，此代碼僅為測試代碼，若要用於實際的項目中，需要很大改進，比如socket異步建立，消息接收和發送等等。