從TCP三次握手的原理我們可以看到,TCP有“保障”的連接實際上可以看做是兩個單向的連接:一個通道只負責發送,另外一個只負責接收。并且,傳送的信息是以字節為單位保證順序的。
在socket機制中,應用層的程序以send()函數將數據首先發送到本機系統的發送緩存中,我們稱之為SendQ,意指這是一個FIFO(先進先出)的隊列。這個緩存是系統決定的,并不是在我們的程序中指定的。然后socket機制負責將SendQ中的數據以字節為單位,按照順序發送給對方的接收緩存RecvQ中。RecvQ也是一個屬于系統的FIFO緩存隊列。從程序員的角度看,send()函數只負責把數據送入SendQ,而SendQ何時將數據發送則是不可控的。所以,send()通常不會阻塞,只有在不能立即將數據發送給SendQ的時候才會阻塞,這往往是因為SendQ緩存已滿。另外,SendQ并不負責統計每次send()所發送來的字節流的長度,事實上這個長度在TCP中沒有意義,因為所有數據都以字節為單位按照FIFO的形式排列在隊列中,而并不在乎來自于哪一次的send()。這也就是所謂的TCP無邊緣保證,TCP的send()并不在乎每次傳送的數據有多少,而只是致力于將數據以字節為單位按照FIFO的形式排列在SendQ隊列中。我們看一下TCPServerSock和TCPClientSock的TCPSend()方法:
int TCPServerSock::TCPSend(const char* send_data,
const int& data_length) const
{
if (data_length > preBufferSize) {
sockClass::error_info("Data is too large, resize preBufferSize.");
}
int sent_length = send( sockFD,
send_data,
data_length,
0);
if (sent_length < 0) {
sockClass::error_info("send() failed.");
} else if (sent_length != data_length) {
sockClass::error_info("sent unexpected number of bytes.");
}
return sent_length;
}
int TCPClientSock::TCPSend(const char* send_data,
const int& data_length) const
{
if (data_length > preBufferSize) {
sockClass::error_info("Data is too large, resize preBufferSize.");
}
int sent_length = send( sockFD,
send_data,
data_length,
0);
if (sent_length < 0) {
sockClass::error_info("send() failed.");
} else if (sent_length != data_length) {
sockClass::error_info("sent unexpected number of bytes.");
}
return sent_length;
}
可以看到,這兩個方法除了分屬于不同的類名字不一樣,其他都是一樣的。send()的返回值是實際發送的字節長度。
在收信息的另外一邊,當RecvQ沒有數據時,recv()就會阻塞(默認情況下),每當有數據可接收,recv()就會返回實際接收到的數據長度。recv()同樣不在乎每次接收的數據有多少,其參數只有一個最大長度限制,這個限制是應用程序分配給每次recv()儲存數據的緩存大小。所以TCP的send()和recv()不是一一對應的:send()只負責將數據寫入本機的SendQ,而recv()只負責把本機RecvQ中的數據讀出來。假設send()傳送了m+n字節,但是第一次到達遠程目的地的RecvQ中只有m字節,于是這里的recv()就會馬上返回m字節;剩下的n字節第二次才姍姍來遲,那么就需要第二次調用recv()來接收。
int TCPServerSock::TCPReceive() const
{
preReceivedLength = recv( sockFD,
preBuffer,
preBufferSize,
0);
if (preReceivedLength < 0) {
sockClass::error_info("recv() failed.");
} else if (preReceivedLength == 0) {
std::cout << "Client has been disconnected.\n";
return 0;
}
return preReceivedLength;
}
int TCPClientSock::TCPReceive() const
{
preReceivedLength = recv( sockFD,
preBuffer,
preBufferSize,
0);
if (preReceivedLength < 0) {
sockClass::error_info("recv() failed.");
} else if (preReceivedLength == 0) {
std::cout << "Disconnected from server.\n";
return 0;
}
return preReceivedLength;
}
可以看到這2個方法也幾乎是一模一樣——除了名字和對異常信息的描述。因為我們這里并不知道需要recv()的確切長度,所以這里的TCPReceive()也跟recv()一樣,有數據就返回。需要驗證數據長度的,比如echo服務,我們另外寫驗證長度的代碼。
最后需要說明的是,雖然SYN和FIN都會占用一個字節的數據,但是對于應用層的send()和recv()來說是不可見的。FIN會讓recv()返回0,表示連接正常斷開。
posted on 2010-06-07 20:09
lf426 閱讀(4022)
評論(1) 編輯 收藏 引用 所屬分類:
SDL入門教程 、
socket 編程入門教程