碼上歡樂
相關內容    簡體    繁體

socket 客戶端和服務端通信

本文轉載自   查看原文   2017-09-26 21:16   5243    C#高級特性

客戶端要連接服務器：首先要知道服務器的IP地址。而服務器里有很多的應用程序，每一個應用程序對應一個端口號 所以客戶端想要與服務器中的某個應用程序進行通信就必須要知道那個應用程序的所在服務器的IP地址，及應用程序所對應的端口號

TCP協議：安全穩定，一般不會發生數據丟失，但是效率低。利用TCP發生數據一般經過3次握手(所有效率低，自己百度三次握手) UDP協議：快速，效率高，但是不穩定，容易發生數據丟失（沒有經過三次握手，不管服務器有空沒空，信息全往服務器發，所有效率搞，但服務器忙的時候就沒辦法處理你的數據，容易造成數據丟失，不穩定）

 

首先創建一個解決方案，在解決方案下創建一個“Socket通信”windows窗體應用程序的的項目，用作服務端，然后再在解決方案下創建一個“Socket客戶端”windows窗體應用程序的項目 用作客戶端

Socket通信  （服務器端）

[csharp] view plain copy print?
  1. using System; 
  2. using System.Collections.Generic; 
  3. using System.ComponentModel; 
  4. using System.Data; 
  5. using System.Drawing; 
  6. using System.Linq; 
  7. using System.Net; 
  8. using System.Net.Sockets; 
  9. using System.Text; 
  10. using System.Threading; 
  11. using System.Threading.Tasks; 
  12. using System.Windows.Forms; 
  13.  
  14. namespace Socket通信 
  15. { 
  16.     public partial class Form1 : Form 
  17.     { 
  18.         public Form1() 
  19.         { 
  20.             InitializeComponent(); 
  21.             this.txtPort.Text = "50000"; 
  22.             this.txtIp.Text = "192.168.253.2"; 
  23.  
  24.         } 
  25.  
  26.         private void btnStart_Click(object sender, EventArgs e) 
  27.         { 
  28.             try 
  29.             { 
  30.                 //當點擊開始監聽的時候，在服務器端創建一個負責監聽IP地址跟端口號的Socket   
  31.                 Socket socketWatch = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); 
  32.  
  33.                 //Any:提供一個 IP 地址，指示服務器應偵聽所有網絡接口上的客戶端活動。此字段為只讀。   
  34.                 IPAddress ip = IPAddress.Any; 
  35.                 //IPAddress ip = IPAddress.Parse(this.txtIp.Text); 
  36.  
  37.                 //創建端口號對象；將txtPort.Text控件的值設為服務端的端口號   
  38.                 IPEndPoint point = new IPEndPoint(ip, Convert.ToInt32(txtPort.Text)); 
  39.  
  40.                 //監聽   
  41.                 socketWatch.Bind(point); 
  42.                 ShowMsg("監聽成功"); //注意：這個ShowMeg方法是自己定義的。看下面的代碼可以找到這個方法 
  43.  
  44.                 socketWatch.Listen(10);//連接隊列的最大長度 ;即：一個時間點內最大能讓幾個客戶端連接進來，超過長度就進行排隊   
  45.  
  46.                 //等待客戶端連接;Accept()這個方法能接收客戶端的連接，並為新連接創建一個負責通信的Socket   
  47.                 Thread th = new Thread(Listen); //被線程執行的方法如果有參數的話,參數必須是object類型   
  48.  
  49.                 Control.CheckForIllegalCrossThreadCalls = false; //因為.net不允許跨線程訪問的，所以這里取消跨線程的檢查。.net不檢查是否有跨線程訪問了，所有就不會報： “從不是創建控件“txtLog”的線程訪問它” 這個錯誤了，從而實現了跨線程訪問   
  50.  
  51.                 th.IsBackground = true; //將th這個線程設為后台線程。   
  52.  
  53.                 //Start(object parameter); parameter:一個對象，包含線程執行的方法要使用的數據,即線程執行Listen方法，Listen的參數   
  54.                 th.Start(socketWatch);  //這個括號里的參數其實是Listen()方法的參數。因為Thread th = new Thread(Listen)這個括號里只能寫方法名(函數名) 但是Listen()方法是有參數的，所有就要用Start()方法將它的參數添加進來   
  55.             } 
  56.             catch 
  57.             { } 
  58.  
  59.  
  60.         } 
  61.  
  62.  
  63.         //將遠程連接的客戶端的IP地址和Socket存入集合中 
  64.         Dictionary<string, Socket> dic = new Dictionary<string, Socket>(); 
  65.  
  66.  
  67.         /// <summary>   
  68.         /// 等待客戶端連接，如果監控到有客戶端連接進來就創建一個與之通信的Socket   
  69.         /// </summary>   
  70.         /// <param name="o"></param>   
  71.  
  72.         Socket socketSend;  // 定義一個負責通信的Socket 
  73.         void Listen(object o) //這里為什么不直接傳遞Socket類型的參數呢？ 原因是：被線程執行的方法如果有參數的話,參數必須是object類型   
  74.         { 
  75.             Socket socketWatch = o as Socket; 
  76.  
  77.             while (true) //為什么這里要有個while循環？因為當一個人連接進來的時候創建了與之通信的Socket后就程序就會往下執行了，就不會再回來為第二個人的連接創建負責通信的Socket了。（應該是每個人(每個客戶端)創建一個與之通信的Socket）所以要寫在循環里。   
  78.             { 
  79.                 try 
  80.                 { 
  81.                     //等待客戶端連接;Accept()這個方法能接收客戶端的連接，並為新連接創建一個負責通信的Socket   
  82.                     socketSend = socketWatch.Accept(); 
  83.  
  84.                     dic.Add(socketSend.RemoteEndPoint.ToString(), socketSend); //（根據客戶端的IP地址和端口號找負責通信的Socket，每個客戶端對應一個負責通信的Socket），ip地址及端口號作為鍵，將負責通信的Socket作為值填充到dic鍵值對中。   
  85.  
  86.                     //我們通過負責通信的這個socketSend對象的一個RemoteEndPoint屬性，能夠拿到遠程連過來的客戶端的Ip地址跟端口號   
  87.                     ShowMsg(socketSend.RemoteEndPoint.ToString() + ":" + "連接成功");//效果：192.168.1.32:連接成功   
  88.  
  89.                     comboBox1.Items.Add(socketSend.RemoteEndPoint.ToString()); //將連接過來的每個客戶端都添加到combBox控件中。   
  90.  
  91.  
  92.                     //客戶端連接成功后，服務器應該接收客戶端發來的消息。    
  93.                     Thread getdata = new Thread(GetData); 
  94.                     getdata.IsBackground = true; 
  95.                     getdata.Start(socketSend); 
  96.                 } 
  97.                 catch 
  98.                 { } 
  99.  
  100.             } 
  101.  
  102.         } 
  103.  
  104.  
  105.         /// <summary>   
  106.         /// 服務端不停的接收客戶端發送過來的消息   
  107.         /// </summary>   
  108.         /// <param name="o"></param>   
  109.         void GetData(object o) 
  110.         { 
  111.             Socket socketSend = o as Socket; 
  112.             while (true) 
  113.             { 
  114.                 try 
  115.                 { 
  116.                     //將客戶端發過來的數據先放到一個字節數組里面去   
  117.                     byte[] buffer = new byte[1024 * 1024 * 2]; //創建一個字節數組，字節數組的長度為2M   
  118.  
  119.                     //實際接收到的有效字節數; (利用Receive方法接收客戶端傳過來的數據，然后把數據保存到buffer字節數組中，返回一個接收到的數據的長度)   
  120.                     int r = socketSend.Receive(buffer); 
  121.  
  122.                     if (r == 0) //如果接收到的有效字節數為0 說明客戶端已經關閉了。這時候就跳出循環了。   
  123.                     { 
  124.                         //只有客戶端給用戶發消息，不可能是發0個長度的字節。即便發空消息，空消息也是有過個長度的。所有接收到的有效字節長度為0就代表客戶端已經關閉了   
  125.                         break; 
  126.                     } 
  127.  
  128.  
  129.                     //將buffer這個字節數組里面的數據按照UTF8的編碼，解碼成我們能夠讀懂的的string類型，因為buffer這個數組的實際存儲數據的長度是r個 ，所以從索引為0的字節開始解碼，總共解碼r個字節長度。   
  130.                     string str = Encoding.UTF8.GetString(buffer, 0, r); 
  131.  
  132.  
  133.                     ShowMsg(socketSend.RemoteEndPoint.ToString() + ":" + str); 
  134.                 } 
  135.                 catch 
  136.                 { 
  137.  
  138.                 } 
  139.             } 
  140.         } 
  141.         private void ShowMsg(string str) 
  142.         { 
  143.             txtLog.AppendText(str + "\r\n"); //將str這個字符串添加到txtLog這個文本框中。  
  144.         } 
  145.  
  146.  
  147.         /// <summary> 
  148.         /// 服務器給客戶端發送消息 
  149.         /// </summary> 
  150.         /// <param name="sender"></param> 
  151.         /// <param name="e"></param> 
  152.         private void btnSend_Click(object sender, EventArgs e) 
  153.         { 
  154.  
  155.             if (comboBox1.SelectedItem == null) //如果comboBox控件沒有選中值。就提示用戶選擇客戶端   
  156.             { 
  157.                 MessageBox.Show("請選擇客戶端"); 
  158.                 return; 
  159.             } 
  160.             //服務器要想給客戶端發消息，就需要先拿到負責通信的那個Socket 
  161.  
  162.             string str = txtMes.Text.Trim(); 
  163.             byte[] buffer = System.Text.Encoding.UTF8.GetBytes(str); 
  164.  
  165.             string getIp = comboBox1.SelectedItem as string; //comboBox存儲的是客戶端的（ip+端口號） 
  166.  
  167.             socketSend = dic[getIp] as Socket; //根據這個（ip及端口號）去dic鍵值對中找對應 賦值與客戶端通信的Socket【每個客戶端都有一個負責與之通信的Socket】   
  168.             socketSend.Send(buffer); 
  169.         } 
  170.     } 
  171. } 
 

Socket客戶端 （客戶端）

[csharp] view plain copy print?
  1. using System; 
  2. using System.Collections.Generic; 
  3. using System.ComponentModel; 
  4. using System.Data; 
  5. using System.Drawing; 
  6. using System.Linq; 
  7. using System.Net; 
  8. using System.Net.Sockets; 
  9. using System.Text; 
  10. using System.Threading; 
  11. using System.Threading.Tasks; 
  12. using System.Windows.Forms; 
  13.  
  14. namespace Socket客戶端 
  15. { 
  16.     public partial class Form1 : Form 
  17.     { 
  18.         public Form1() 
  19.         { 
  20.             InitializeComponent(); 
  21.             this.txtIp.Text = "192.168.253.2"; //因為我們要在客戶端連接服務端,所以這里是服務端的IP 
  22.             this.txtPort.Text = "50000"; //因為我們要在客戶端連接服務端，所以這里服務端的端口號 
  23.         } 
  24.  
  25.         Socket socketSend; 
  26.         private void btnStart_Click(object sender, EventArgs e) 
  27.         { 
  28.             try 
  29.             { 
  30.                 //創建負責通信的Socket 
  31.                 socketSend = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); 
  32.  
  33.                 IPAddress ip = IPAddress.Parse(this.txtIp.Text); 
  34.  
  35.                 //創建一個IPEndPoint類的實例，用遠程服務器的IP地址和端口號來初始化它 
  36.                 IPEndPoint point = new IPEndPoint(ip, Convert.ToInt32(this.txtPort.Text)); 
  37.  
  38.                 //獲得要連接的遠程服務器應用程序的IP地址和端口號，並建立與遠程服務器的連接 
  39.                 socketSend.Connect(point); 
  40.  
  41.                 ShowMsg("連接成功"); 
  42.  
  43.  
  44.                 //開啟一個新的線程，不停的接收服務端發送過來的消息 
  45.                 Thread th = new Thread(GetData); 
  46.                 th.IsBackground = true;  //IsBackground獲取或設置一個值，該值指示某個線程是否為后台線程。 
  47.                 th.Start(); 
  48.  
  49.             } 
  50.             catch 
  51.             { 
  52.  
  53.             } 
  54.  
  55.         } 
  56.         void ShowMsg(string str) 
  57.         { 
  58.             this.txtLog.AppendText("\r\n"+str + "\r\n"); 
  59.         } 
  60.  
  61.  
  62.         /// <summary>   
  63.         /// 客戶端不停的接收服務端發送過來的消息   
  64.         /// </summary>   
  65.         /// <param name="o"></param>   
  66.         void GetData(object o) 
  67.         { 
  68.  
  69.             while (true) 
  70.             { 
  71.                 try 
  72.                 { 
  73.                     //將服務端發過來的數據先放到一個字節數組里面去   
  74.                     byte[] buffer = new byte[1024 * 1024 * 2]; //創建一個字節數組，字節數組的長度為2M   
  75.  
  76.                     //實際接收到的有效字節數; (利用Receive方法接收客戶端傳過來的數據，然后把數據保存到buffer字節數組中，返回一個接收到的數據的長度)   
  77.                     int r = socketSend.Receive(buffer); 
  78.  
  79.                     if (r == 0) //如果接收到的有效字節數為0 說明客戶端已經關閉了。這時候就跳出循環了。   
  80.                     { 
  81.                         //只有客戶端給用戶發消息，不可能是發0個長度的字節。即便發空消息，空消息也是有過個長度的。所有接收到的有效字節長度為0就代表客戶端已經關閉了   
  82.                         break; 
  83.                     } 
  84.  
  85.  
  86.                     //將buffer這個字節數組里面的數據按照UTF8的編碼，解碼成我們能夠讀懂的的string類型，因為buffer這個數組的實際存儲數據的長度是r個 ，所以從索引為0的字節開始解碼，總共解碼r個字節長度。   
  87.                     string str = Encoding.UTF8.GetString(buffer, 0, r); 
  88.  
  89.                     //RemoteEndPoint方法是獲取服務器的IP地址和端口號 
  90.                     ShowMsg(socketSend.RemoteEndPoint.ToString() + ":" + str); 
  91.                 } 
  92.                 catch 
  93.                 { 
  94.  
  95.                 } 
  96.             } 
  97.         } 
  98.  
  99.  
  100.         /// <summary> 
  101.         /// 客戶端給服務器發送消息 
  102.         /// </summary> 
  103.         /// <param name="sender"></param> 
  104.         /// <param name="e"></param> 
  105.         private void btnSend_Click(object sender, EventArgs e) 
  106.         { 
  107.             //獲取輸入框輸入的數據 
  108.             string str = txtMes.Text.Trim(); 
  109.             //將輸入框的數據轉換成二進制數據 
  110.             byte[] buffer = System.Text.Encoding.UTF8.GetBytes(str); 
  111.  
  112.             //Send方法是將數據發送到連接的Socket 
  113.             socketSend.Send(buffer); 
  114.  
  115.             this.txtLog.AppendText("我自己：" + this.txtMes.Text); 
  116.             this.txtMes.Text = ""; 
  117.         } 
  118.  
  119.         private void Form1_Load(object sender, EventArgs e) 
  120.         { 
  121.             //在程序加載的時候取消跨線程的檢查 
  122.             Control.CheckForIllegalCrossThreadCalls = false; 
  123.         } 
  124.     } 
  125. } 
 

 

 

當這兩個項目（服務端，和客戶端）都寫好后，怎么測試呢？

首先我們將服務端設置啟動項，然后啟動調試，

然后我們在將鼠標移動到“Socket客戶端” （客戶端）這個項目下，鼠標右鍵項目名稱“Socket客戶端”--》調試--》啟動實例 就可以了。

 

開打開始命令  cmd   telnet 10.18.16.46 5000    即telnet 服務器ip地址  綁定的端口號

如果用命令，需要在 控制面板--》程序和功能--》打開或關閉windows功能  將Telnet 服務器，和Telnet客戶端打上鈎

 

---------------------------------------------------------------------------------------------------------------

注釋一下：

 

//創建一個用來監聽的Socket對象（參數1：表示采用IPv4,參數2：表示使用數據流來傳輸數據，而不是數據包 參數3：表示采用Tcp協議）

 

Socket skConn =newSocket(AddressFamily.InterNetwork,SocketType.Stream,ProtocolType.Tcp);

 

//創建IP和監聽端口(參數1:IP地址 參數2：端口號是9999)

 

IPEndPoint endPoint=newIPEndPoint(IPAddress.Parse("192.168.253.3"),9999);


免責聲明！

本站轉載的文章為個人學習借鑒使用，本站對版權不負任何法律責任。如果侵犯了您的隱私權益，請聯系本站郵箱yoyou2525@163.com刪除。



猜您在找 socket實現客戶端和服務端 客戶端和服務端之間的通信（UDP） socket通信之客戶端與服務端通信 PHP socket服務端與客戶端的簡易通信 Python socket編程客戶端與服務端通信 linux網絡編程之用socket實現簡單客戶端和服務端的通信（基於UDP） python實現兩台不同主機之間進行通信（客戶端和服務端）——Socket 通過Socket實現TCP編程，用戶登錄之服務器相應客戶端，客戶端和服務端之間的通信 c++ Socket客戶端和服務端示例版本三（多線程版本） Socket（TCP)客戶端請求和服務端監聽和鏈接基礎(附例子)
 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM