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通信的基本步骤的全部內容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： sift算法_图像配准SIFT
- 下一篇： 常用UCI数据集链接，mark