教育行業(yè)A股IPO第一股（股票代碼 003032）

全國咨詢/投訴熱線：400-618-4000

Java培訓(xùn)實(shí)戰(zhàn)教程之論Socket的重要性

更新時(shí)間:2016年01月19日14時(shí)37分 來源:傳智播客Java培訓(xùn)學(xué)院 瀏覽次數(shù):

Java培訓(xùn)中 精點(diǎn)、難點(diǎn)知識(shí)總結(jié)匯總
Socket不僅在聊天應(yīng)用程序中需要用到，而且對(duì)于學(xué)習(xí)Asp.net也非常有幫助。你懂得！
實(shí)現(xiàn)服務(wù)端和客戶端互發(fā)信息，以及服務(wù)端向多個(gè)客戶端發(fā)送信息。
     服務(wù)端代碼1：
  1.         public Form1()
  2.         {
  3.             InitializeComponent();
  4.             Control.CheckForIllegalCrossThreadCalls = false;
  5.         }
  7.         //創(chuàng)建監(jiān)聽用的socket
  8.         private void btnStartMonitor_Click(object sender, EventArgs e)
  9.         {
  10.             //監(jiān)聽的ip地址
  11.             IPAddress ip = IPAddress.Parse(txtIP.Text);
  12.             //監(jiān)聽的ip地址和端口號(hào)
  13.             IPEndPoint point = new IPEndPoint(ip, int.Parse(txtPortNumber.Text));
  14.             //監(jiān)聽用的socket
  15.             Socket socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
  17.             //通常每個(gè)套接字地址(協(xié)議/網(wǎng)絡(luò)地址/端口)只允許使用一次
  18.             //綁定監(jiān)聽的ip地址和端口號(hào)
  19.             socket.Bind(point);
  20.             //監(jiān)聽端口   監(jiān)聽隊(duì)列的長(zhǎng)度:同一個(gè)時(shí)間等待的個(gè)數(shù)。
  21.             socket.Listen(10);
  22.             //點(diǎn)擊之后，禁用掉按鈕
  23.             btnStartMonitor.Enabled = false;
  24.             //提示用戶程序開始運(yùn)行了
  25.             ShowMsg("開始運(yùn)行了...");
  27.             //監(jiān)聽端口，如果有客戶端連接，創(chuàng)建通信用socket
  28.             //阻塞窗體的運(yùn)行
  29.             //Socket connSocket = socket.Accept();
  30.             //用線程來解決窗體假死的問題
  31.             Thread th = new Thread(Listen);
  32.             th.IsBackground = true;//后臺(tái)線程
  33.             th.Start(socket);
  34.         }
  36.         //監(jiān)聽是否有客戶端連接
  37.         void Listen(object o)
  38.         {
  39.             //監(jiān)聽用的socket
  40.             Socket socket = o as Socket;
  41.             //監(jiān)聽端口
  42.             Socket connSocket = socket.Accept();
  43.             //顯示遠(yuǎn)程連接的IP地址和端口號(hào)
  44.             ShowMsg(connSocket.RemoteEndPoint.ToString());
  45.         }
  47.         //在文本框顯示信息
  48.         void ShowMsg(string msg)
  49.         {
  50.             txtShowMessage.AppendText(msg + "\r\n");
  51.         }
復(fù)制代碼
以上代碼只能讓一個(gè)客戶端連接服務(wù)端，弊端。
     服務(wù)端代碼2完善——循環(huán)接收客戶端連接：
  1.         //監(jiān)聽是否有客戶端連接
  2.        void Listen(object o)
  3.         {
  4.             //監(jiān)聽用的socket
  5.             Socket socket = o as Socket;
  7.             //可以不停地接受客戶端的連接
  8.             while (true)
  9.             {
  10.                 //負(fù)責(zé)通信用的socket
  11.                 Socket connSocket = socket.Accept();
  12.                 //顯示遠(yuǎn)程連接的IP地址和端口號(hào)
  13.                 ShowMsg(connSocket.RemoteEndPoint.ToString());
  14.                 //本機(jī)的IP地址和端口號(hào)
  15.                 //connSocket.LocalEndPoint
  17.                 //接收數(shù)據(jù)
  18.                 byte[] buffer = new byte[1024 * 1023];
  19.                 //接收數(shù)據(jù)，把數(shù)據(jù)發(fā)到buffer中
  20.                 //num是實(shí)際接收到的字節(jié)個(gè)數(shù)
  21.                 int num=connSocket.Receive(buffer);
  22.                 //把實(shí)際有效的字節(jié)轉(zhuǎn)換成字符串
  23.                 string str = Encoding.UTF8.GetString(buffer, 0, num);
  24.                 ShowMsg(str);
  25.             }
  26.         }
復(fù)制代碼
服務(wù)端代碼3完善——循環(huán)接收消息：
  1.         //監(jiān)聽是否有客戶端連接
  2.         void Listen(object o)
  3.         {
  4.             //監(jiān)聽用的socket
  5.             Socket socket = o as Socket;
  7.             //可以不停地接受客戶端的連接
  8.             while (true)
  9.             {
  10.                 //負(fù)責(zé)通信用的socket
  11.                 Socket connSocket = socket.Accept();
  12.                 //顯示遠(yuǎn)程連接的IP地址和端口號(hào)
  13.                 ShowMsg(connSocket.RemoteEndPoint.ToString());
  14.                 //本機(jī)的IP地址和端口號(hào)
  15.                 //connSocket.LocalEndPoint
  17. //循環(huán)接收消息
  18. while(true)
  19. {
  20.                 //接收數(shù)據(jù)
  21.                 byte[] buffer = new byte[1024 * 1023];
  22.                 //接收數(shù)據(jù)，把數(shù)據(jù)發(fā)到buffer中
  23.                 //num是實(shí)際接收到的字節(jié)個(gè)數(shù)
  24.                 int num=connSocket.Receive(buffer);
  25.                 //把實(shí)際有效的字節(jié)轉(zhuǎn)換成字符串
  26.                 string str = Encoding.UTF8.GetString(buffer, 0, num);
  27.                 ShowMsg(str);
  28. }
  29.             }
  30.         }
復(fù)制代碼
服務(wù)端代碼4完善——循環(huán)多個(gè)客戶端并接收信息：
  1.         //監(jiān)聽是否有客戶端連接
  2.         void Listen(object o)
  3.         {
  4.             //監(jiān)聽用的socket
  5.             Socket socket = o as Socket;
  7.             //可以不停地接受客戶端的連接
  8.             while (true)
  9.             {
  10.                 //負(fù)責(zé)通信用的socket
  11.                 Socket connSocket = socket.Accept();
  12.                 //顯示遠(yuǎn)程連接的IP地址和端口號(hào)
  13.                 ShowMsg(connSocket.RemoteEndPoint.ToString());
  14.                 //本機(jī)的IP地址和端口號(hào)
  15.                 //connSocket.LocalEndPoint
  17.                 //線程接收信息
  18.                 Thread th = new Thread(RecMsg);
  19.                 th.IsBackground = true;
  20.                 th.Start(connSocket);            
  21. }
  22.         }
  24.         //接收信息
  25.         void RecMsg(object o)
  26.         {
  27.             //通信用的socket
  28.             Socket connSocket = o as Socket;
  29.             //可以不停地接受客戶端的內(nèi)容
  30.             while (true)
  31.             {
  32.                 //接受數(shù)據(jù)
  33.                 byte[] buffer = new byte[1024 * 1024];
  34.                 //接受數(shù)據(jù)，把數(shù)據(jù)發(fā)到buffer中
  35.                 //num就是實(shí)際接受到的字節(jié)個(gè)數(shù)
  36.                 int num = connSocket.Receive(buffer);
  38. //當(dāng)telnet關(guān)閉，會(huì)不停的發(fā)送空（0）字節(jié)
  40.                 //把實(shí)際有效的字節(jié)轉(zhuǎn)化成字符串
  41.                 string str = Encoding.UTF8.GetString(buffer, 0, num);
  42.                 ShowMsg(connSocket.RemoteEndPoint.ToString() + ":" + str);
  43.                 }
  44.             }
  45.         }
復(fù)制代碼
服務(wù)端代碼5完善——限制客戶端連接數(shù)：
  1.         //限制連接客戶端的個(gè)數(shù)
  2.         int count=0;
  3.         void Listen(object o)
  4.         {
  5.             //監(jiān)聽用的socket
  6.             Socket socket = o as Socket;
  8.             //可以不停地接受客戶端的連接
  9.             while (count<1000)
  10.             {
  11.                 //負(fù)責(zé)通信用的socket
  12.                 Socket connSocket = socket.Accept();
  13.                 //顯示遠(yuǎn)程連接的IP地址和端口號(hào)
  14.                 ShowMsg(connSocket.RemoteEndPoint.ToString());
  15.                 //本機(jī)的IP地址和端口號(hào)
  16.                 //connSocket.LocalEndPoint
  18.                 //線程接收信息
  19.                 Thread th = new Thread(RecMsg);
  20.                 th.IsBackground = true;
  21.                 th.Start(connSocket);
  22. }
  23.         }
復(fù)制代碼
服務(wù)端代碼6完善——解決“當(dāng)tenet關(guān)閉，會(huì)不停地發(fā)送空（0）字節(jié)”：
  1.         //接收信息
  2.         void RecMsg(object o)
  3.         {
  4.             //通信用的socket
  5.             Socket connSocket = o as Socket;
  6.             //可以不停地接受客戶端的內(nèi)容
  7.             while (true)
  8.             {
  9.                 //接受數(shù)據(jù)
  10.                 byte[] buffer = new byte[1024 * 1024];
  11.                 //接受數(shù)據(jù)，把數(shù)據(jù)發(fā)到buffer中
  12.                 //num就是實(shí)際接受到的字節(jié)個(gè)數(shù)
  13.                 int num = connSocket.Receive(buffer);
  15. //當(dāng)telnet關(guān)閉，會(huì)不停的發(fā)送空（0）字節(jié)
  16.                     //當(dāng)telnet關(guān)閉，會(huì)不停的發(fā)送（0）個(gè)字節(jié)  客戶端斷開
  17.                     if (num == 0)
  18.                     {
  19.                         ShowMsg(connSocket.RemoteEndPoint.ToString() + ":退出");
  20.                         connSocket.Shutdown(SocketShutdown.Receive);
  21.                         connSocket.Close();
  22.                         break;
  23.                     }
  24.                 //把實(shí)際有效的字節(jié)轉(zhuǎn)化成字符串
  25.                 string str = Encoding.UTF8.GetString(buffer, 0, num);
  26.                 ShowMsg(connSocket.RemoteEndPoint.ToString() + ":" + str);
  27.                 }
  28.             }
  29.         }
復(fù)制代碼
客戶端代碼1：
  1.         public Form1()
  2.         {
  3.             InitializeComponent();
  4.             Control.CheckForIllegalCrossThreadCalls = false;
  5.         }
  7.         //連接服務(wù)端和發(fā)送信息都要用到同一個(gè)socket，將其定義到外邊
  8.         Socket socket;
  9.         //連接服務(wù)端
  10.         private void btnConnect_Click(object sender, EventArgs e)
  11.         {
  12.             //客戶端連接服務(wù)器的ip地址
  13.             IPAddress ip = IPAddress.Parse(txtIP.Text);
  14.             //客戶端連接的服務(wù)器的ip地址和端口號(hào)
  15.             IPEndPoint point = new IPEndPoint(ip, int.Parse(txtPortNumber.Text));
  16.             //創(chuàng)建連接使用的socket
  17. socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
  18.             try
  19.             {
  20.                 //連接聊天服務(wù)器
  21.                 //服務(wù)器沒開報(bào)錯(cuò)
  22.                 //由于目標(biāo)計(jì)算機(jī)積極拒絕，無法連接。
  23.                 socket.Connect(point);
  24.                 ShowMsg("連接成功");
  25.             }
  26.             catch (Exception ex)
  27.             {
  28.                 ShowMsg(ex.Message);
  29.             }
  30.         }
  32.         void ShowMsg(string msg)
  33.         {
  34.             txtShowMessage.AppendText(msg + "\r\n");
  35.         }
  37.         //發(fā)送消息
  38.         private void btnSendMessage_Click(object sender, EventArgs e)
  39.         {
  40.             if (socket != null)
  41.             {
  42.                 byte[] buffer = Encoding.UTF8.GetBytes(txtInputMessage.Text);
  43.                 socket.Send(buffer);
  44.             }
  45.             else
  46.             {
  47.                 MessageBox.Show("請(qǐng)先連接");
  48.             }
  49.         }
復(fù)制代碼
客戶端代碼7完善——服務(wù)端知道客戶端關(guān)閉的消息：
  1.         //接收信息
  2.         void RecMsg(object o)
  3.         {
  4.             //通信用的socket
  5.             Socket connSocket = o as Socket;
  6.             //可以不停地接受客戶端的內(nèi)容
  7.             while (true)
  8.             {
  9.                 //接受數(shù)據(jù)
  10.                 byte[] buffer = new byte[1024 * 1024];
  11.                 //接受數(shù)據(jù)，把數(shù)據(jù)發(fā)到buffer中
  12.                 //num就是實(shí)際接受到的字節(jié)個(gè)數(shù)
  13.                 int num = -1;
  14.                 try
  15.                 {
  16.         //遠(yuǎn)程主機(jī)強(qiáng)迫關(guān)閉了一個(gè)現(xiàn)有的連接。  當(dāng)客戶端關(guān)閉，服務(wù)端未關(guān)閉時(shí)，報(bào)錯(cuò)。
  17.                     num = connSocket.Receive(buffer);
  18.                     //當(dāng)telnet關(guān)閉，會(huì)不停的發(fā)送（0）個(gè)字節(jié)  客戶端斷開
  19.                     if (num == 0)
  20.                     {
  21.                         ShowMsg(connSocket.RemoteEndPoint.ToString() + ":退出");
  22.                         connSocket.Shutdown(SocketShutdown.Receive);
  23.                         connSocket.Close();
  24.                         break;
  25.                     }
  26.                     //把實(shí)際有效的字節(jié)轉(zhuǎn)化成字符串
  27.                     string str = Encoding.UTF8.GetString(buffer, 0, num);
  28.                     ShowMsg(connSocket.RemoteEndPoint.ToString() + ":" + str);
  29.                 }
  30.                 catch (Exception ex)
  31.                 {
  32.                     ShowMsg(ex.Message);
  33.                     //出現(xiàn)異常，跳出循環(huán)
  34.                     break;
  35.                 }
  36.             }
  37.         }
復(fù)制代碼
服務(wù)端代碼8完善——服務(wù)端給客戶端發(fā)送消息：
  1.         //發(fā)送消息
  2.         private void btnSendMessage_Click(object sender, EventArgs e)
  3.         {
  4.             if (connSocket!=null)
  5.             {
  6.                 byte[] buffer = Encoding.UTF8.GetBytes(txtInputMessage.Text);
  7.                 try
  8.                 {
  9.                     connSocket.Send(buffer);
  10.                 }
  11.                 catch (Exception ex)
  12.                 {
  13.                     ShowMsg(ex.Message);
  14.                 }
  15.             }
  16.         }
復(fù)制代碼
客戶端代碼2完善——客戶端接收服務(wù)端發(fā)送的消息：
  1.         //接收消息
  2.         void RecMsg()
  3.         {
  4.             while (true)
  5.             {
  6.                 byte[] buffer = new byte[1024 * 1024];
  7.                 try
  8.                 {
  9.                     int num = socket.Receive(buffer);
  10.                     string str = Encoding.UTF8.GetString(buffer, 1, num );
  11.                     ShowMsg(str);
  12.                 }
  13.                 catch (Exception ex)
  14.                 {
  15.                     ShowMsg(ex.Message);
  16.                     break;
  17.                 }
  18.             }
  19.         }
  20. //由于接收消息是一個(gè)死循環(huán)，需要用到線程
  21.                 //線程接受消息
  22.                 Thread th = new Thread(RecMsg);
  23.                 th.IsBackground = true;
  24.                 th.Start();
復(fù)制代碼
服務(wù)端代碼9完善——服務(wù)端給指定客戶端發(fā)送消息：
  1.         //存儲(chǔ)通信用的socket字典
  2.         Dictionary<string, Socket> dic = new Dictionary<string, Socket>();
  4.         //限制連接客戶端的個(gè)數(shù)
  5.         int count = 0;
  6.         //監(jiān)聽是否有客戶端連接
  7.         void Listen(object o)
  8.         {
  9.             //監(jiān)聽用的socket
  10.             Socket socket = o as Socket;
  12.             //可以不停地接受客戶端的連接
  13.             while (count < 100)
  14.             {
  15.                 count++;
  16.                 //監(jiān)聽端口，如果有客戶端連接，創(chuàng)建通信用socket
  17.                 Socket connSocket = socket.Accept();
  18.                 //顯示遠(yuǎn)程連接的IP地址和端口號(hào)
  19.                 ShowMsg(connSocket.RemoteEndPoint.ToString());
  20.                 //本機(jī)的IP地址和端口號(hào)
  21.                 //connSocket.LocalEndPoint
  23.                 //保存當(dāng)前登錄的客戶端的socket
  24.                 string ipport = connSocket.RemoteEndPoint.ToString();
  25.                 cboUser.Items.Add(ipport);
  26.                 dic.Add(ipport, connSocket);
  28.                 //線程接收信息
  29.                 Thread th = new Thread(RecMsg);
  30.                 th.IsBackground = true;
  31.                 th.Start(connSocket);
  32.             }
  33.         }
  35.         //發(fā)送消息
  36.         private void btnSendMessage_Click(object sender, EventArgs e)
  37.         {
  38.             //獲取下拉框中選擇的ip和端口號(hào)
  39.             string ipport = cboUser.Text;
  40.             if (!string.IsNullOrEmpty(ipport))
  41.             {
  42.                 byte[] buffer = Encoding.UTF8.GetBytes(txtInputMessage.Text);
  43.                 try
  44.                 {
  45.                     //根據(jù)key獲得socket
  46.                     Socket connSocket = dic[ipport];
  47.                     connSocket.Send(buffer);
  48.                 }
  49.                 catch (Exception ex)
  50.                 {
  51.                     ShowMsg(ex.Message);
  52.                 }
  53.             }
  54.             else
  55.             {
  56.                 MessageBox.Show("請(qǐng)選擇客戶端");
  57.             }
  58.         }
復(fù)制代碼
Java培訓(xùn)學(xué)院始終認(rèn)為你將會(huì)是最優(yōu)秀的存在，你就是最棒的,看好你,加油！??！
本文版權(quán)歸傳智播客Java培訓(xùn)學(xué)院所有，歡迎轉(zhuǎn)載，轉(zhuǎn)載請(qǐng)注明作者出處。謝謝！
作者：傳智播客Java培訓(xùn)學(xué)院
首發(fā)：http://8y3kgpwe.cn/javaee 
0 分享到：
和我們?cè)诰€交談！