一、TCP協(xié)議、Socket編程流程TCP/IP協(xié)議及socket封裝 二、Send 和 Recv的基本介紹2.1 Send函數(shù)int send( SOCKET s, const char FAR *buf, int len, int flags );
不論是客戶還是服務(wù)器應(yīng)用程序都用send函數(shù)來向TCP連接的另一端發(fā)送數(shù)據(jù)??蛻舫绦蛞话阌胹end函數(shù)向服務(wù)器發(fā)送請求,而服務(wù)器則通常用send函數(shù)來向客戶程序發(fā)送應(yīng)答。 參數(shù)說明: 第一個參數(shù)指定發(fā)送端套接字描述符;第二個參數(shù)指明一個存放應(yīng)用程序要發(fā)送數(shù)據(jù)的緩沖區(qū);第三個參數(shù)指明實(shí)際要發(fā)送的數(shù)據(jù)的字節(jié)數(shù);第四個參數(shù)一般置0。12341234 這里只描述同步Socket的send函數(shù)的執(zhí)行流程。當(dāng)調(diào)用該函數(shù)時, 要注意send函數(shù)把buf中的數(shù)據(jù)成功copy到s的發(fā)送緩沖的剩余空間里后它就返回了,但是此時這些數(shù)據(jù)并不一定馬上被傳到連接的另一端。如果協(xié)議在后續(xù)的傳送過程中出現(xiàn)網(wǎng)絡(luò)錯誤的話,那么下一個Socket函數(shù)就會返回SOCKET_ERROR。(每一個除send外的Socket函數(shù)在執(zhí)行的最開始總要先等待套接字的發(fā)送緩沖中的數(shù)據(jù)被協(xié)議傳送完畢才能繼續(xù),如果在等待時出現(xiàn)網(wǎng)絡(luò)錯誤,那么該Socket函數(shù)就返回 SOCKET_ERROR) 注意:在Unix系統(tǒng)下,如果send在等待協(xié)議傳送數(shù)據(jù)時網(wǎng)絡(luò)斷開的話,調(diào)用send的進(jìn)程會接收到一個SIGPIPE信號,進(jìn)程對該信號的默認(rèn)處理是進(jìn)程終止。 通過測試發(fā)現(xiàn),異步socket的send函數(shù)在網(wǎng)絡(luò)剛剛斷開時還能發(fā)送返回相應(yīng)的字節(jié)數(shù),同時使用select檢測也是可寫的,但是過幾秒鐘之后,再send就會出錯了,返回-1。select也不能檢測出可寫了。 2.2 Recv函數(shù)int recv( SOCKET s, char FAR *buf, int len, int flags);
不論是客戶還是服務(wù)器應(yīng)用程序都用recv函數(shù)從TCP連接的另一端接收數(shù)據(jù)。 參數(shù)說明: 第一個參數(shù)指定接收端套接字描述符;第二個參數(shù)指明一個緩沖區(qū),該緩沖區(qū)用來存放recv函數(shù)接收到的數(shù)據(jù);第三個參數(shù)指明buf的長度;第四個參數(shù)一般置0。12341234 這里只描述同步Socket的recv函數(shù)的執(zhí)行流程。當(dāng)應(yīng)用程序調(diào)用recv函數(shù)時,recv先等待s的發(fā)送緩沖中的數(shù)據(jù)被協(xié)議傳送完畢, 特別提醒: 如果recv在copy時出錯,那么它返回SOCKET_ERROR; 注意:在Unix系統(tǒng)下,如果recv函數(shù)在等待協(xié)議接收數(shù)據(jù)時網(wǎng)絡(luò)斷開了,那么調(diào)用recv的進(jìn)程會接收到一個SIGPIPE信號,進(jìn)程對該信號的默認(rèn)處理是進(jìn)程終止。 int send ( SOCKET s, const char FAR * buf, int len, int flags );
三、常見問題問題1:send函數(shù)每次最多可以發(fā)送多少數(shù)據(jù)?是int的最大值嗎? 問題二:如果buffer中的數(shù)據(jù)過大,我也只需要調(diào)用一次send函數(shù),而底層到底是一次傳輸成功還是陸續(xù)傳輸我不用管了嗎? 問題三:阻塞和非阻塞的區(qū)別? 特別注意:You can use setsockopt to enlarge the buffer. 作為一個套接字,它擁有兩個緩沖,接收數(shù)據(jù)緩沖和發(fā)送數(shù)據(jù)緩沖(此緩沖不同與你自己定義的緩沖),當(dāng)有數(shù)據(jù)到達(dá)時,首先進(jìn)入的 問題四:緩沖區(qū)怎么理解? recv函數(shù)也是一樣的,它并不是直接從網(wǎng)絡(luò)中獲取數(shù)據(jù),而是從輸入緩沖區(qū)中讀取數(shù)據(jù)。 輸入輸出緩沖區(qū),系統(tǒng)會為每個socket都單獨(dú)分配,并且是在socket創(chuàng)建的時候自動生成的。一般來說,默認(rèn)的輸入輸出緩沖區(qū)大小為8K。套接字關(guān)閉的時候,輸出緩沖區(qū)的數(shù)據(jù)不會丟失,會由協(xié)議發(fā)送到另一方;而輸入緩沖區(qū)的數(shù)據(jù)則會丟失。 四、 對于數(shù)據(jù)接收不完整的情況,可以考慮從以下幾個方面解決:1:利用SetSocketOpt()函數(shù)將接收方套接子接收緩沖設(shè)為足夠大?。?/strong> 具體操作:在send()的時候,返回的是實(shí)際發(fā)送出去的字節(jié)(同步)或發(fā)送到socket緩沖區(qū)的字節(jié)(異步);系統(tǒng)默認(rèn)的狀態(tài)發(fā)送和接收一次為8688字節(jié)(約為8.5K);在實(shí)際的過程中發(fā)送數(shù)據(jù)和接收數(shù)據(jù)量比較大,可以設(shè)置socket緩沖區(qū),而避免了send(),recv()不斷的循環(huán)收發(fā): // 接收緩沖區(qū)int nRecvBuf=32*1024;//設(shè)置為32Ksetsockopt(s,SOL_SOCKET,SO_RCVBUF,(const char*)&nRecvBuf,sizeof(int));//發(fā)送緩沖區(qū)int nSendBuf=32*1024;//設(shè)置為32Ksetsockopt(s,SOL_SOCKET,SO_SNDBUF,(const char*)&nSendBuf,sizeof(int));123456123456 2.基于winsock API,比較實(shí)用,自己寫的,簡單又粗暴同時還有技巧~ bool SendAll(SOCKET &sock, char*buffer, int size){ while (size>0) { int SendSize= send(sock, buffer, size, 0); if(SOCKET_ERROR==SendSize) return false; size = size - SendSize;//用于循環(huán)發(fā)送且退出功能 buffer+=SendSize;//用于計算已發(fā)buffer的偏移量 } return true;}bool RecvAll(SOCKET &sock, char*buffer, int size){ while (size>0)//剩余部分大于0 { int RecvSize= recv(sock, buffer, size, 0); if(SOCKET_ERROR==RecvSize) return false; size = size - RecvSize; buffer+=RecvSize; } return true;}
3.設(shè)置為阻塞方式: int flags = fcntl(sock, F_GETFL, 0); fcntl(sock, F_SETFL, flags | O_NONBLOCK);1212 假設(shè)當(dāng)前代碼為服務(wù)器,并且已經(jīng)執(zhí)行過如下代碼, 當(dāng)sock為阻塞模式,調(diào)用accept會阻塞直到一個請求到來 當(dāng)sock為非阻塞模式,accept會返回-1,errno設(shè)置為EAGAIN或者EWOULDBLOCK 3.在recv函數(shù)之前加sleep(0.01)函數(shù),而不是recv之后,但是感覺這樣沒什么效果。 五、 參考資料,特此感謝,如有侵權(quán),立刪!1.關(guān)于setsockopt:https://blog.csdn.net/youxiazzz12/article/details/25634143 |
|