日韩黑丝制服一区视频播放|日韩欧美人妻丝袜视频在线观看|九九影院一级蜜桃|亚洲中文在线导航|青草草视频在线观看|婷婷五月色伊人网站|日本一区二区在线|国产AV一二三四区毛片|正在播放久草视频|亚洲色图精品一区

分享

TCP通信接收數(shù)據(jù)不完整的解決方法

 行走在理想邊緣 2021-06-26

一、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 );
  • 1

  • 1

不論是客戶還是服務(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先比較待發(fā)送數(shù)據(jù)的長度len套接字s的發(fā)送緩沖的長度,
(1)如果len大于s的發(fā)送緩沖區(qū)的長度,該函數(shù)返回SOCKET_ERROR;
(2)如果len小于或者等于s的發(fā)送緩沖區(qū)的長度,那么send先檢查協(xié)議
是否正在發(fā)送s的發(fā)送緩沖中的數(shù)據(jù),如果是就等待協(xié)議把數(shù)據(jù)發(fā)送完,如果協(xié)議還沒有開始發(fā)送s的發(fā)送緩沖中的數(shù)據(jù)或者s的發(fā)送緩沖中沒有數(shù)據(jù),那么 send就比較s的發(fā)送緩沖區(qū)的剩余空間和len,(2.1)如果len大于剩余空間大小send就一直等待協(xié)議把s的發(fā)送緩沖中的數(shù)據(jù)發(fā)送完,(2.2)如果len小于剩余空間大小send就僅僅把buf中的數(shù)據(jù)copy到剩余空間里(注意并不是send把s的發(fā)送緩沖中的數(shù)據(jù)傳到連接的另一端的,而是協(xié)議傳的,send僅僅是把buf中的數(shù)據(jù)copy到s的發(fā)送緩沖區(qū)的剩余空間里)。
如果send函數(shù)copy數(shù)據(jù)成功,就返回實(shí)際copy的字節(jié)數(shù),
如果send在copy數(shù)據(jù)時出現(xiàn)錯誤,那么send就返回SOCKET_ERROR;如果send在等待協(xié)議傳送數(shù)據(jù)時網(wǎng)絡(luò)斷開的話,那么send函數(shù)也返回SOCKET_ERROR。

要注意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);
  • 1

  • 1

不論是客戶還是服務(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é)議傳送完畢,
(1)如果協(xié)議在傳送s的發(fā)送緩沖中的數(shù)據(jù)時出現(xiàn)網(wǎng)絡(luò)錯誤,那么recv函數(shù)返回SOCKET_ERROR,
(2)如果s的發(fā)送緩沖中沒有數(shù)據(jù)或者數(shù)據(jù)被協(xié)議成功發(fā)送完畢后,recv先檢查套接字s的接收緩沖區(qū),如果s接收緩沖區(qū)中沒有數(shù)據(jù)或者協(xié)議正在接收數(shù)據(jù),那么recv就一直等待,直到協(xié)議把數(shù)據(jù)接收完畢。當(dāng)協(xié)議把數(shù)據(jù)接收完畢,recv函數(shù)就把s的接收緩沖中的數(shù)據(jù)copy到buf中

特別提醒:
協(xié)議接收到的數(shù)據(jù)可能大于buf的長度,所以在這種情況下要調(diào)用幾次recv函數(shù)才能把s的接收緩沖中的數(shù)據(jù)copy完。recv函數(shù)僅僅是copy數(shù)據(jù),真正的接收數(shù)據(jù)是協(xié)議來完成的,recv函數(shù)返回其實(shí)際copy的字節(jié)數(shù)。

如果recv在copy時出錯,那么它返回SOCKET_ERROR;
如果recv函數(shù)在等待協(xié)議接收數(shù)據(jù)時網(wǎng)絡(luò)中斷了,那么它返回0。

注意:在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

  • 2

  • 3

  • 4

  • 5

  • 6

  • 1

  • 2

  • 3

  • 4

  • 5

  • 6

三、常見問題

問題1:send函數(shù)每次最多可以發(fā)送多少數(shù)據(jù)?是int的最大值嗎?
答:不是int的最大值

問題二:如果buffer中的數(shù)據(jù)過大,我也只需要調(diào)用一次send函數(shù),而底層到底是一次傳輸成功還是陸續(xù)傳輸我不用管了嗎?
答:recv到的數(shù)據(jù)流可能是斷斷續(xù)續(xù)的,你要把他們放在一起然后解碼。

問題三:阻塞和非阻塞的區(qū)別?
答:Send分為阻塞和非阻塞,
阻塞模式下,如果正常的話,會直到把你所需要發(fā)送的數(shù)據(jù)發(fā)完再返回;
非阻塞模式,會根據(jù)你的socket在底層的可用緩沖區(qū)的大小,來將你的緩沖區(qū)當(dāng)中的數(shù)據(jù)拷貝過去,有多大緩沖區(qū)就拷貝多少,緩沖區(qū)滿了就立即返回,這個時候的返回值,只表示拷貝到緩沖區(qū)多少數(shù)據(jù),但是并不代表發(fā)送多少數(shù)據(jù),同時剩下的部分需要你再次調(diào)用send才會再一次拷貝到底層緩沖區(qū)。

特別注意:You can use setsockopt to enlarge the buffer.

作為一個套接字,它擁有兩個緩沖,接收數(shù)據(jù)緩沖發(fā)送數(shù)據(jù)緩沖(此緩沖不同與你自己定義的緩沖),當(dāng)有數(shù)據(jù)到達(dá)時,首先進(jìn)入的
就是接收數(shù)據(jù)緩沖,然后用戶從這個緩沖中將數(shù)據(jù)讀出來,這就是套接字接受的過程,這個緩沖的大小可以自己用**SetSocketOpt()**設(shè)定,
同時操作系統(tǒng)對它有一個默認(rèn)大小,如果對方在很短時間內(nèi)發(fā)送大量數(shù)據(jù)到達(dá)這個套接子時,可能它沒來得及接收完,因此接收緩沖處于
滿的狀態(tài),再有數(shù)據(jù)來的時候就進(jìn)不去了,因此對方的 SEND可能就返回錯誤,在對方發(fā)送的數(shù)據(jù)量很小時不會出現(xiàn)這種情況,當(dāng)數(shù)據(jù)量很大時,情況就很明顯了,很容易造成收不到的情況。同樣,發(fā)送方的發(fā)送緩沖也有相對應(yīng)的問題。

問題四:緩沖區(qū)怎么理解?
答:socket緩沖區(qū)每一個socket在被創(chuàng)建之后,系統(tǒng)都會給它分配兩個緩沖區(qū),即輸入緩沖區(qū)和輸出緩沖區(qū)。
在這里插入圖片描述
send函數(shù)并不是直接將數(shù)據(jù)傳輸?shù)骄W(wǎng)絡(luò)中,而是負(fù)責(zé)將數(shù)據(jù)寫入輸出緩沖區(qū),數(shù)據(jù)從輸出緩沖區(qū)發(fā)送到目標(biāo)主機(jī)是由TCP協(xié)議完成的。數(shù)據(jù)寫入到輸出緩沖區(qū)之后,send函數(shù)就可以返回了,數(shù)據(jù)是否發(fā)送出去,是否發(fā)送成功,何時到達(dá)目標(biāo)主機(jī),都不由它負(fù)責(zé)了,而是由協(xié)議負(fù)責(zé)。

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í)用,自己寫的,簡單又粗暴同時還有技巧~
這樣包裝的目的顯而易見,防止send或者 recv不完整,這樣你想發(fā)一個
幾MB直接調(diào)用下面方法就okay,不會少發(fā)~

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;}
  • 1

  • 2

  • 3

  • 4

  • 5

  • 6

  • 7

  • 8

  • 9

  • 10

  • 11

  • 12

  • 13

  • 14

  • 15

  • 16

  • 17

  • 18

  • 19

  • 20

  • 21

  • 22

  • 23

  • 24

  • 25

  • 1

  • 2

  • 3

  • 4

  • 5

  • 6

  • 7

  • 8

  • 9

  • 10

  • 11

  • 12

  • 13

  • 14

  • 15

  • 16

  • 17

  • 18

  • 19

  • 20

  • 21

  • 22

  • 23

  • 24

  • 25

3.設(shè)置為阻塞方式:
阻塞就是干不完不準(zhǔn)回來!
非阻塞就是你先干,我現(xiàn)看看有其他事沒有,完了告訴我一聲!
sock默認(rèn)為阻塞模式,下面的代碼可對sock設(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之后,但是感覺這樣沒什么效果。
4:在發(fā)送方進(jìn)行數(shù)據(jù)發(fā)送時判斷發(fā)送是否成功,如果不成功重發(fā);
5:要求接收方收到數(shù)據(jù)后給發(fā)送方回應(yīng),發(fā)送方只在收到回應(yīng)后才發(fā)送下一條數(shù)據(jù)。

五、 參考資料,特此感謝,如有侵權(quán),立刪! 

1.關(guān)于setsockopt:https://blog.csdn.net/youxiazzz12/article/details/25634143
2.socket循環(huán)接收:https://blog.csdn.net/what951006/article/details/75114563
3.https://blog.csdn.net/u010270148/article/details/53605339
4.https://blog.csdn.net/zorelemn/article/details/52566397
6.https://blog.csdn.net/u012801153/article/details/79363575
7.C++ Socket send recv 循環(huán)發(fā)送和接收 阻塞與緩沖區(qū):
https://blog.csdn.net/u012801153/article/details/79363575
8.從 Linux 源碼看 socket 的阻塞和非阻塞
http://blog./113858/
9.Linux 編程之 Socket
http://blog./107743/?utm_source=blog.&utm_medium=relatedPosts
10.再次深入理解TCP網(wǎng)絡(luò)編程中的send和recv
https://www.cnblogs.com/my_life/articles/5363527.html

    本站是提供個人知識管理的網(wǎng)絡(luò)存儲空間,所有內(nèi)容均由用戶發(fā)布,不代表本站觀點(diǎn)。請注意甄別內(nèi)容中的聯(lián)系方式、誘導(dǎo)購買等信息,謹(jǐn)防詐騙。如發(fā)現(xiàn)有害或侵權(quán)內(nèi)容,請點(diǎn)擊一鍵舉報。
    轉(zhuǎn)藏 分享 獻(xiàn)花(0

    0條評論

    發(fā)表

    請遵守用戶 評論公約

    類似文章 更多