日韩性视频-久久久蜜桃-www中文字幕-在线中文字幕av-亚洲欧美一区二区三区四区-撸久久-香蕉视频一区-久久无码精品丰满人妻-国产高潮av-激情福利社-日韩av网址大全-国产精品久久999-日本五十路在线-性欧美在线-久久99精品波多结衣一区-男女午夜免费视频-黑人极品ⅴideos精品欧美棵-人人妻人人澡人人爽精品欧美一区-日韩一区在线看-欧美a级在线免费观看

歡迎訪問 生活随笔!

生活随笔

當前位置: 首頁 > 编程资源 > 编程问答 >内容正文

编程问答

SOCKET通信的基本步骤

發布時間:2023/12/20 编程问答 36 豆豆
生活随笔 收集整理的這篇文章主要介紹了 SOCKET通信的基本步骤 小編覺得挺不錯的,現在分享給大家,幫大家做個參考.

SOCKET通信的基本步驟

? ?1)建立一個服務器ServerSocket,并同時定義好ServerSocket的監聽端口;
???2)ServerSocket 調用accept()方法,使之處于阻塞。
???3)創建一個客戶機Socket,并設置好服務器的IP端口
???4)客戶機發出連接請求,建立連接。
???5)分別取得服務器和客戶端ServerSocket 和Socket的InputStream和OutputStream.
???6)??利用Socket和ServerSocket進行數據通信。 /

在進行網絡編程時,我們常常見到同步(Sync)/異步(Async),阻塞(Block)/非阻塞(Unblock)四種調用方式:
同步:
??????
所謂同步,就是在發出一個功能調用時,在沒有得到結果之前,該調用就不返回。也就是必須一件一件事做,等前一件做完了才能做下一件事。

例如普通B/S模式(同步):提交請求->等待服務器處理->處理完畢返回?這個期間客戶端瀏覽器不能干任何事

異步:
??????
異步的概念和同步相對。當一個異步過程調用發出后,調用者不能立刻得到結果。實際處理這個調用的部件在完成后,通過狀態、通知和回調來通知調用者。

? ? ?例如 ajax請求(異步):?請求通過事件觸發->服務器處理(這是瀏覽器仍然可以作其他事情)->處理完畢

阻塞
?????
阻塞調用是指調用結果返回之前,當前線程會被掛起(線程進入非可執行狀態,在這個狀態下,cpu不會給線程分配時間片,即線程暫停運行)。函數只有在得到結果之后才會返回。

? ? ?有人也許會把阻塞調用和同步調用等同起來,實際上他是不同的。對于同步調用來說,很多時候當前線程還是激活的,只是從邏輯上當前函數沒有返回而已。?例如,我們在socket中調用recv函數,如果緩沖區中沒有數據,這個函數就會一直等待,直到有數據才返回。而此時,當前線程還會繼續處理各種各樣的消息。

非阻塞
??????
非阻塞和阻塞的概念相對應,指在不能立刻得到結果之前,該函數不會阻塞當前線程,而會立刻返回。
對象的阻塞模式和阻塞函數調用
對象是否處于阻塞模式和函數是不是阻塞調用有很強的相關性,但是并不是一一對應的。阻塞對象上可以有非阻塞的調用方式,我們可以通過一定的API去輪詢狀?態,在適當的時候調用阻塞函數,就可以避免阻塞。而對于非阻塞對象,調用特殊的函數也可以進入阻塞調用。函數select就是這樣的一個例子。

?

1. 同步,就是我調用一個功能,該功能沒有結束前,我死等結果。
2. 異步,就是我調用一個功能,不需要知道該功能結果,該功能有結果后通知我(回調通知)
3. 阻塞, ? ? ?就是調用我(函數),我(函數)沒有接收完數據或者沒有得到結果之前,我不會返回。
4. 非阻塞, ?就是調用我(函數),我(函數)立即返回,通過select通知調用者

同步IO和異步IO的區別就在于:數據拷貝的時候進程是否阻塞!

阻塞IO和非阻塞IO的區別就在于:應用程序的調用是否立即返回!

對于舉個簡單c/s 模式:

同步:提交請求->等待服務器處理->處理完畢返回這個期間客戶端瀏覽器不能干任何事
異步:請求通過事件觸發->服務器處理(這是瀏覽器仍然可以作其他事情)->處理完畢 同步和異步都只針對于本機SOCKET而言的。

同步和異步,阻塞和非阻塞,有些混用,其實它們完全不是一回事,而且它們修飾的對象也不相同。
阻塞和非阻塞是指當進程訪問的數據如果尚未就緒,進程是否需要等待,簡單說這相當于函數內部的實現區別,也就是未就緒時是直接返回還是等待就緒;

而同步和異步是指訪問數據的機制,同步一般指主動請求并等待I/O操作完畢的方式,當數據就緒后在讀寫的時候必須阻塞(區別就緒與讀寫二個階段,同步的讀寫必須阻塞),異步則指主動請求數據后便可以繼續處理其它任務,隨后等待I/O,操作完畢的通知,這可以使進程在數據讀寫時也不阻塞。(等待"通知")


// 客戶端: 綜合運用以上闡述的使用Visual C#進行Socket網絡程序開發的知識,下面的程序段完整地實現了Web頁面下載功能。用戶只需在窗體上輸入遠程主機名(Dns 主機名或以點分隔的四部分表示法格式的 IP 地址)和預保存的本地文件名,并利用專門提供Http服務的80端口,就可以獲取遠程主機頁面并保存在本地機指定文件中。如果保存格式是.htm格式,你就可以在Internet瀏覽器中打開該頁面。適當添加代碼,你甚至可以實現一個簡單的瀏覽器程序。
??
??
??實現此功能的主要源代碼如下:
??
??//"開始"按鈕事件
??private void button1_Click(object sender, System.EventArgs e)? {
???//取得預保存的文件名
???string fileName=textBox3.Text.Trim();
???//遠程主機
???string hostName=textBox1.Text.Trim();
???//端口
???int port=Int32.Parse(textBox2.Text.Trim());
???//得到主機信息
???IPHostEntry ipInfo=Dns.GetHostByName(hostName);
???//取得IPAddress[]
???IPAddress[] ipAddr=ipInfo.AddressList;
???//得到ip
???IPAddress ip=ipAddr[0];
???//組合出遠程終結點
???IPEndPoint hostEP=new IPEndPoint(ip,port);
???//創建Socket 實例
???Socket socket=new Socket(AddressFamily.InterNetwork,SocketType.Stream,ProtocolType.Tcp);
???try
???{
???//嘗試連接
???socket.Connect(hostEP);
???}
???catch(Exception se)
???{
???MessageBox.Show("連接錯誤"+se.Message,"提示信息
???,MessageBoxButtons.RetryCancel,MessageBoxIcon.Information);
??}
??//發送給遠程主機的請求內容串
??string sendStr="GET / HTTP/1.1\r\nHost: " + hostName +
??"\r\nConnection: Close\r\n\r\n";
???//創建bytes字節數組以轉換發送串
???byte[] bytesSendStr=new byte[1024];
???//將發送內容字符串轉換成字節byte數組
???bytesSendStr=Encoding.ASCII.GetBytes(sendStr);
??try
??{
??//向主機發送請求
??socket.Send(bytesSendStr,bytesSendStr.Length,0);
??}
??catch(Exception ce)
???{
???MessageBox.Show("發送錯誤:"+ce.Message,"提示信息
???,MessageBoxButtons.RetryCancel,MessageBoxIcon.Information);
???}
???//聲明接收返回內容的字符串
???string recvStr="";
???//聲明字節數組,一次接收數據的長度為1024字節
???byte[] recvBytes=new byte[1024];
???//返回實際接收內容的字節數
???int bytes=0;
??//循環讀取,直到接收完所有數據
??while(true)
??{
?? bytes=socket.Receive(recvBytes,recvBytes.Length,0);
?? //讀取完成后退出循環
?? if(bytes<=0)
?? break;
?? //將讀取的字節數轉換為字符串
?? recvStr+=Encoding.ASCII.GetString(recvBytes,0,bytes);
??}
??//將所讀取的字符串轉換為字節數組
??byte[] content=Encoding.ASCII.GetBytes(recvStr);
???try
???{
??? //創建文件流對象實例
??? FileStream fs=new FileStream(fileName,FileMode.OpenOrCreate,FileAccess.ReadWrite);
?? //寫入文件
?? fs.Write(content,0,content.Length);
??}
??catch(Exception fe)
???{
??? MessageBox.Show("文件創建/寫入錯誤:"+fe.Message,"提示信息",MessageBoxButtons.RetryCancel,MessageBoxIcon.Information);
???}
??? //禁用Socket
??? socket.Shutdown(SocketShutdown.Both);
??? //關閉Socket
??? socket.Close();
???}
???}

// /client端
using System;
using System.Text;
using System.IO;
using System.Net;
using System.Net.Sockets;
namespace socketsample
{
 class Class1
 {
  static void Main()
  {
   try
   {
    int port = 2000;
    string host = "127.0.0.1";
    IPAddress ip = IPAddress.Parse(host);
    IPEndPoint ipe = new IPEndPoint(ip, port);
    Socket c = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
    c.Connect(ipe);
    string sendStr = "hello!This is a socket test";
    byte[] bs = Encoding.ASCII.GetBytes(sendStr);
    c.Send(bs, bs.Length, 0);
    string recvStr = "";
    byte[] recvBytes = new byte[1024];
    int bytes;
    bytes = c.Receive(recvBytes, recvBytes.Length, 0);
    recvStr += Encoding.ASCII.GetString(recvBytes, 0, bytes);
    Console.WriteLine(recvStr);
    c.Close();
   }
   catch (ArgumentNullException e)
   {
    Console.WriteLine("ArgumentNullException: {0}", e);
   }
   catch (SocketException e)
   {
    Console.WriteLine("SocketException: {0}", e);
   }
   Console.ReadLine();
  }
 }
}
//server端
using System;
using System.Text;
using System.IO;
using System.Net;
using System.Net.Sockets;
namespace Project1
{
 class Class2
 {
  static void Main()
  {
   try
   {
    int port = 2000;
    string host = "127.0.0.1";
    IPAddress ip = IPAddress.Parse(host);
    IPEndPoint ipe = new IPEndPoint(ip, port);
    Socket s = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
    s.Bind(ipe);
    s.Listen(0);
    Socket temp = s.Accept();
    string recvStr = "";
    byte[] recvBytes = new byte[1024];
    int bytes;
    bytes = temp.Receive(recvBytes, recvBytes.Length, 0);
    recvStr += Encoding.ASCII.GetString(recvBytes, 0, bytes);
    Console.WriteLine(recvStr);
    string sendStr = "Ok!Sucess!";
    byte[] bs = Encoding.ASCII.GetBytes(sendStr);
    temp.Send(bs, bs.Length, 0);
    temp.Shutdown(SocketShutdown.Both);
    temp.Close();
    s.Shutdown(SocketShutdown.Both);
    s.Close();
   }
   catch (ArgumentNullException e)
   {
    Console.WriteLine("ArgumentNullException: {0}", e);
   }
   catch (SocketException e)
   {
    Console.WriteLine("SocketException: {0}", e);
   }
   Console.ReadLine();
  }
 }
}

總結

以上是生活随笔為你收集整理的SOCKET通信的基本步骤的全部內容,希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯,歡迎將生活随笔推薦給好友。