在线观看www成人影院-在线观看www日本免费网站-在线观看www视频-在线观看操-欧美18在线-欧美1级

0
  • 聊天消息
  • 系統(tǒng)消息
  • 評論與回復(fù)
登錄后你可以
  • 下載海量資料
  • 學(xué)習(xí)在線課程
  • 觀看技術(shù)視頻
  • 寫文章/發(fā)帖/加入社區(qū)
會員中心
創(chuàng)作中心

完善資料讓更多小伙伴認(rèn)識你,還能領(lǐng)取20積分哦,立即完善>

3天內(nèi)不再提示

TCP粘包和拆包產(chǎn)生的原因

科技綠洲 ? 來源:Linux開發(fā)架構(gòu)之路 ? 作者:Linux開發(fā)架構(gòu)之路 ? 2023-11-10 14:07 ? 次閱讀

一、TCP粘包現(xiàn)象

what?

TCP是個“流”協(xié)議,即沒有邊界。由于這個特性以及實際的網(wǎng)絡(luò)情況,在進(jìn)行數(shù)據(jù)傳輸時假設(shè)我們連續(xù)調(diào)用send分別發(fā)送兩段數(shù)據(jù)data1和data2,在接收端有以下幾種代表性的情況:

  1. 先接收到data1,然后接收到data2。
  2. 先接收到data1的部分?jǐn)?shù)據(jù),然后接收到data1余下的部分以及data2的全部。
  3. 先接收到data1的全部數(shù)據(jù)和data2的部分?jǐn)?shù)據(jù),然后接收到data2余下的數(shù)據(jù)。
  4. 一次性接收到了data1和data2的全部數(shù)據(jù)。

其中,1是理想情況,也就是我們需要的。對于2,3,4的情況就是常說的“粘包”,就需要把接收到的數(shù)據(jù)進(jìn)行拆包,拆成一個個獨立的數(shù)據(jù)包,而為了拆包就必須在發(fā)送端進(jìn)行封包。

對于UDP來說不存在拆包問題,因為UDP是一個“數(shù)據(jù)包“協(xié)議,也就是兩段數(shù)據(jù)是有界限的,在接收端要么接收不到數(shù)據(jù)要么就是一段完整的數(shù)據(jù),不會少接收也不會多接收。

這里,筆者在發(fā)送端連續(xù)發(fā)送4096個字節(jié)的數(shù)據(jù),然后在接收端打印接收到的數(shù)據(jù)字節(jié)數(shù),可以很明顯的看到出現(xiàn)了粘包現(xiàn)象。

receive num=2648
------------------------
receive num=1448
------------------------
receive num=2648
------------------------
receive num=2896
------------------------
receive num=1200
------------------------
receive num=1448
------------------------
receive num=2648
------------------------
receive num=2896
------------------------
receive num=1200
------------------------
receive num=1448
------------------------

why?

為什么會出現(xiàn)粘包這種現(xiàn)象呢,以下幾點原因。

  1. 由Nagle算法造成的發(fā)送端粘包。Nagle算法是一種改善網(wǎng)絡(luò)傳輸效率的算法,但也可能造成困擾。簡單的說,當(dāng)提交一端數(shù)據(jù)給TCP時,TCP并不立刻發(fā)送此段數(shù)據(jù),而是等待一段時間,看看在等待期間是否還有要發(fā)送的數(shù)據(jù),若有則會一次吧多段數(shù)據(jù)發(fā)送出去。
  2. 接收端接收不及時造成的接收端粘包。TCP會把接收到的數(shù)據(jù)存在自己的緩沖區(qū)中,然后通知應(yīng)用層取數(shù)據(jù)。當(dāng)應(yīng)用層由于某些原因不能及時取出TCP的數(shù)據(jù),就會造成TCP緩沖區(qū)中存放多段數(shù)據(jù)。
  3. 這種原因是筆者根據(jù)實踐得出的,不知道對不對。若發(fā)送端發(fā)送很大的數(shù)據(jù)包,比如4096字節(jié),由于網(wǎng)卡和路由器中MTU的限制。MTU規(guī)定為1500字節(jié),那么每次數(shù)據(jù)包要低于1500字節(jié)(除去IP頭部等字節(jié)),否則網(wǎng)口以及網(wǎng)絡(luò)傳輸途徑中路由器等會自動對其進(jìn)行分包操作。造成接收端并不能一次接收到發(fā)送的字節(jié)數(shù)。

附:

TCP粘包和拆包產(chǎn)生的原因

  1. 應(yīng)用程序?qū)懭霐?shù)據(jù)的字節(jié)大小大于套接字發(fā)送緩沖區(qū)的大小
  2. 進(jìn)行MSS大小的TCP分段。MSS是最大報文段長度的縮寫。MSS是TCP報文段中的數(shù)據(jù)字段的最大長度。數(shù)據(jù)字段加上TCP首部才等于整個的TCP報文段。所以MSS并不是TCP報文段的最大長度,而是:MSS=TCP報文段長度-TCP首部長度
  3. 以太網(wǎng)的payload大于MTU進(jìn)行IP分片。MTU指:一種通信協(xié)議的某一層上面所能通過的最大數(shù)據(jù)包大小。如果IP層有一個數(shù)據(jù)包要傳,而且數(shù)據(jù)的長度比鏈路層的MTU大,那么IP層就會進(jìn)行分片,把數(shù)據(jù)包分成若干片,讓每一片都不超過MTU。注意,IP分片可以發(fā)生在原始發(fā)送端主機(jī)上,也可以發(fā)生在中間路由器上。

二、封包和解包

How?

最初解決“粘包”的問題,采用在兩次send之間調(diào)用sleep休眠小一段時間來解決,缺點是顯而易見的:傳輸效率大大降低,而且也并不可靠。

對數(shù)據(jù)包進(jìn)行封包和解包就能解決這個問題:

封包就是給一段數(shù)據(jù)加上包頭,這樣一來數(shù)據(jù)包就分為包頭和包體兩部分內(nèi)容了(可加上包尾)。包頭其實是一個大小固定的結(jié)構(gòu)體,其中有個結(jié)構(gòu)體成員變量表示包體的長度,這是個很重要的變量,其他的結(jié)構(gòu)體成員可根據(jù)需要自己定義。根據(jù)固定的包頭長度以及包頭中含有的包體長度變量值就能正確的拆分出一個完整的數(shù)據(jù)包。

利用底層的緩沖區(qū)來進(jìn)行拆包時,由于TCP也維護(hù)了一個緩沖區(qū),所以可以利用TCP的緩沖區(qū)來拆包,也就是循環(huán)不停地接收包頭給出的數(shù)據(jù),直到收夠為止,這就是一個完整的TCP包。
三、代碼示例

為了解決“粘包”問題,大家通常會在所發(fā)送的內(nèi)容前,加上發(fā)送內(nèi)容的長度,所以對方會先收到4Byte,解析獲得接下來所需要接收的長度,再進(jìn)行收包。

當(dāng)然這個代碼中還有一些待改進(jìn)的地方:我們并不能保證接收到的4Byte數(shù)據(jù)正好表示的是數(shù)據(jù)的實際長度,改進(jìn)辦法是在包頭這個結(jié)構(gòu)體變量里添加表示數(shù)據(jù)頭的標(biāo)志。

發(fā)送端:

#include < stdio.h >
#include < stdlib.h >
#include < string.h >
#include < unistd.h >
#include < sys/types.h >
#include < sys/socket.h >
#include < netinet/in.h >
#include < arpa/inet.h >
#include < errno.h >
/*
客戶端給服務(wù)端發(fā)送一個字符串,由于雙方都不知道這個字符串有多長,因此發(fā)送數(shù)據(jù)前的前面4個字節(jié)表示字符串的大小
數(shù)據(jù)格式:4字節(jié)(存儲字符串實際長度) + 字符串內(nèi)容
*/
/*
該函數(shù)能夠發(fā)送指定長度的數(shù)據(jù)。一次發(fā)送不完,可以接著發(fā)送,直到發(fā)送完指定長度為止
*/
int MySend( int iSock, char * pchBuf, size_t tLen){
        int iThisSend;
        unsigned int iSended=0;//has send bytes
        if(tLen == 0)
               return(0);
        while(iSended< tLen){
              do{
                     iThisSend = send(iSock, pchBuf, tLen-iSended, 0);//this time  
              } while((iThisSend< 0) && (errno==EINTR));
               if(iThisSend < 0){
                      return(iSended);
              }
              iSended += iThisSend;
              pchBuf += iThisSend;
       }
        return(tLen);
}

#define DEFAULT_PORT 6666

int main( int argc, char * argv[]){
    int connfd = 0;
    int cLen = 0;
    struct sockaddr_in client;
    if(argc < 2){
        printf(" Uasge: clientent [server IP address]n");
        return -1;
    }
    client.sin_family = AF_INET;
    client.sin_port = htons(DEFAULT_PORT);
    client.sin_addr.s_addr = inet_addr(argv[1]);
    connfd = socket(AF_INET, SOCK_STREAM, 0);
    if(connfd < 0){
        printf("socket() failure!n" );
        return -1;
    }

    if(connect(connfd, (struct sockaddr*)&client, sizeof(client)) < 0){
        printf("connect() failure!n" );
        return -1;
    }
	//
    ssize_t writeLen;
    char *sendMsg = "0123456789";
    int tLen=strlen(sendMsg);
    printf("tLen:%dn" ,tLen);
    int iLen=0;
    char * pBuff= new char [100];
    *(int*)(pBuff+iLen)= htonl(tLen);
    iLen+=sizeof( int);
    memcpy(pBuff+iLen,sendMsg,tLen);
    iLen+=tLen;
    writeLen= MySend(connfd, pBuff, iLen);
    if (writeLen < 0) {
       printf("write failedn" );
       close(connfd);
       return 0;
    }
    else{
       printf("write sucess, writelen :%d, sendMsg:%sn",writeLen,sendMsg);
    }
    close(connfd);
    return 0;
}

服務(wù)器端:

#include < sys/types.h >
#include < sys/socket.h >
#include < netinet/in.h >
#include < arpa/inet.h >
#include < unistd.h >
#include < stdio.h >
#include < stdlib.h >
#include < strings.h >
#include < sys/wait.h >
#include < string.h >
#include < errno.h >

/*
該函數(shù)能夠接受指定長度(字節(jié))的數(shù)據(jù)。循環(huán)接收,直到接受完指定數(shù)量為止。
*/
int MyRecv( int iSock, char * pchBuf, size_t tCount){
        size_t tBytesRead=0;
        int iThisRead;
        while(tBytesRead < tCount){
              do{
                     iThisRead = read(iSock, pchBuf, tCount-tBytesRead);
              } while((iThisRead< 0) && (errno==EINTR));
              if(iThisRead < 0){
                      return(iThisRead);
              }else if (iThisRead == 0)
                      return(tBytesRead);
              tBytesRead += iThisRead;
              pchBuf += iThisRead;
       }
}

#define DEFAULT_PORT 6666
int main( int argc, char ** argv){
    int sockfd,acceptfd; /* 監(jiān)聽socket: sock_fd,數(shù)據(jù)傳輸socket: acceptfd */
    struct sockaddr_in my_addr; /* 本機(jī)地址信息 */
    struct sockaddr_in their_addr; /* 客戶地址信息 */
    unsigned int sin_size, myport=6666, lisnum=10;
    if ((sockfd = socket(AF_INET , SOCK_STREAM, 0)) == -1) {
       perror("socket" );
       return -1;
    }

    printf("socket ok n");
    my_addr.sin_family=AF_INET;
    my_addr.sin_port=htons(DEFAULT_PORT);
    my_addr.sin_addr.s_addr = INADDR_ANY;
    bzero(&(my_addr.sin_zero), 0);

    if (bind(sockfd, (struct sockaddr *)&my_addr, sizeof(struct sockaddr )) == -1) {
        perror("bind" );
        return -2;
    }

    printf("bind ok n");
    if (listen(sockfd, lisnum) == -1) {
        perror("listen" );
        return -3;
    }
    printf("listen ok n");
    char recvMsg[10];
    sin_size = sizeof(my_addr);
    acceptfd = accept(sockfd,(struct sockaddr *)&my_addr,&sin_size);
    if (acceptfd < 0) {
       close(sockfd);
       printf("accept failedn" );
       return -4;
    }

    ssize_t readLen = MyRecv(acceptfd, recvMsg, sizeof( int));
    if (readLen < 0) {
       printf("read failedn" );
       return -1;
    }

    int len=( int)ntohl(*( int*)recvMsg);
    printf("len:%dn",len);
    readLen = MyRecv(acceptfd, recvMsg, len);
    if (readLen < 0) {
       printf("read failedn" );
       return -1;
    }
    recvMsg[len]='?';//接收到的數(shù)據(jù)并沒有結(jié)束符'?',因此需要加上結(jié)束符'?
    printf("recvMsg:%sn" ,recvMsg);
    close(acceptfd);
    return 0;
  }

Makefile:

all:tcpServer tcpClient
tcpServer:tcpServer.o
	gcc -g -o tcpServer tcpServer.o
tcpClient:tcpClient.o
	gcc -g -o tcpClient tcpClient.o
tcpServer.o:tcpServer.c
	gcc -g -c tcpServer.c
tcpClient.o:tcpClient.c
	gcc -g -c tcpClient.c
clean:all
	rm all

運行截圖:

圖片

四、總結(jié)思考

這篇文章一個非常核心的代碼就是readn和writen函數(shù),說白了, 就一直讀, 讀到指定的字節(jié)數(shù)為止。其實, 在recv函數(shù)中, 最后參數(shù)如果是MSG_WAITALL, 那么就可以用recv函數(shù)一行代碼, 替代上述所有代碼。

大家可以對比下代碼:

ssize_t readn(int fd, void *buf, int n)
{
	size_t nleft = n;   // left的意思是“剩下”, 而非“左邊”
	char *bufptr = buf;
	ssize_t nread;
	while(nleft > 0)
	{
		if((nread = read(fd, bufptr, n)) < 0)
		{
			if(errno == EINTR) 	// 遇到中斷
			{ 
				continue;   // 或者用 nread = 0;
			}
			else
			{
				return -1;  // 真正錯誤
			}
		}
		else if(nread == 0) // 對端關(guān)閉
		{
			break;
		}

		nleft -= nread;
		bufptr += nread;
	}

	return (n - nleft);
}


//一句話代碼(MSG_WAITALL),前提套接字是阻塞的
 while ((num = recv(connectfd, recvbuf+buf_pos, recv_size,MSG_WAITALL)) > 0) {
 }
聲明:本文內(nèi)容及配圖由入駐作者撰寫或者入駐合作網(wǎng)站授權(quán)轉(zhuǎn)載。文章觀點僅代表作者本人,不代表電子發(fā)燒友網(wǎng)立場。文章及其配圖僅供工程師學(xué)習(xí)之用,如有內(nèi)容侵權(quán)或者其他違規(guī)問題,請聯(lián)系本站處理。 舉報投訴
  • 數(shù)據(jù)傳輸
    +關(guān)注

    關(guān)注

    9

    文章

    2005

    瀏覽量

    65724
  • 緩沖
    +關(guān)注

    關(guān)注

    0

    文章

    53

    瀏覽量

    17987
  • TCP
    TCP
    +關(guān)注

    關(guān)注

    8

    文章

    1397

    瀏覽量

    80415
  • Data
    +關(guān)注

    關(guān)注

    0

    文章

    63

    瀏覽量

    38627
  • 字符串
    +關(guān)注

    關(guān)注

    1

    文章

    589

    瀏覽量

    21127
收藏 人收藏

    評論

    相關(guān)推薦
    熱點推薦

    lwip tcp原因

    使用lwip協(xié)議棧,作為客戶端應(yīng)答2幀數(shù)據(jù)時,會有問題,在tcp write 后調(diào)用tcp output沒有效果,設(shè)置 #define TF_NODELAY((u8_t)0x40U
    發(fā)表于 05-10 06:51

    tcp_client例程為何去掉發(fā)送后,一直接收就會容易出現(xiàn)數(shù)據(jù)呢?

    / portTICK_PERIOD_MS);} 代碼如下,當(dāng)我使用tcp_client例程,并且把發(fā)送數(shù)據(jù)注釋掉,再接收數(shù)據(jù)就很容易出現(xiàn)TCP數(shù)據(jù),求助 [22:43:18.32
    發(fā)表于 06-17 07:47

    10年的FLASH芯片是否可以使用

    公司無意進(jìn)到了2007年的一批未的FALSH芯片,(nor flash),部分焊接,發(fā)現(xiàn)芯片還可以用,但不知道這類y存放時間過長的FLASH芯片,使用會有哪些影響,請教相關(guān)人員
    發(fā)表于 06-02 22:52

    Labview TCP通信 數(shù)據(jù)分包和處理。

    Labview的TCP通信的讀函數(shù),會發(fā)生數(shù)據(jù)分包和嗎?應(yīng)該怎么處理TCP讀數(shù)據(jù),官方的例子沒有考慮。
    發(fā)表于 03-22 14:02

    Labview TCP通信問題

    labview的TCP通信的讀函數(shù),會發(fā)生數(shù)據(jù)分包和嗎?應(yīng)該怎么處理TCP讀數(shù)據(jù),官方的例子沒有考慮。
    發(fā)表于 03-22 14:07

    配置能便能的粘接劑

    配置能便能的粘接劑 當(dāng)遇到需要將某個元器件固定時,通常采用502膠或環(huán)氧
    發(fā)表于 09-09 15:18 ?818次閱讀

    電烙鐵不原因

    電烙鐵不原因 烙鐵或焊臺溫度過高,烙鐵頭表面涂布的錫快速燃燒,產(chǎn)生劇烈的氧化 使用不正確或是有缺陷的清潔方法 使
    發(fā)表于 02-27 12:09 ?5511次閱讀

    TCP到底是什么

    TCP是一種流式連接,對小包會進(jìn)行封包緩存發(fā)送,大包會出現(xiàn)分包發(fā)送。接收端就會發(fā)現(xiàn)接收到的數(shù)據(jù)和發(fā)送的數(shù)據(jù)的次數(shù)不一致。這個就是現(xiàn)象。
    的頭像 發(fā)表于 02-17 17:45 ?4217次閱讀

    tcp數(shù)據(jù)接口封裝的介紹

    TCP報文格式 TCP協(xié)議有著自己的數(shù)據(jù)格式,這里把TCP的數(shù)據(jù)稱為報文段(segment),TCP
    的頭像 發(fā)表于 03-22 09:39 ?3817次閱讀
    <b class='flag-5'>tcp</b>數(shù)據(jù)<b class='flag-5'>包</b>接口封裝的介紹

    Linux發(fā)送HTTP網(wǎng)絡(luò)圖像 sk_buff數(shù)據(jù)結(jié)構(gòu)解析

    如果你對Linux是如何實現(xiàn) 對用戶原始的網(wǎng)絡(luò)進(jìn)行協(xié)議頭封裝與解析,為什么會,期間網(wǎng)絡(luò)
    的頭像 發(fā)表于 05-10 12:14 ?2547次閱讀

    肥料粉料破包上料機(jī)械手應(yīng)用優(yōu)勢

    肥料粉料破包上料機(jī)械手其速度是人工速度的3-5倍左右,因為可以連續(xù)作業(yè),實際的速度可
    發(fā)表于 09-13 10:48 ?309次閱讀

    自動投料一體機(jī)特點與應(yīng)用流程

    投料一體機(jī)
    發(fā)表于 04-13 11:17 ?560次閱讀

    【推薦】TCP為何問題如何解決?

    我們在涉及TCP協(xié)議的應(yīng)用中,經(jīng)常會出現(xiàn)的問題。所謂,簡單地講,就是我有兩條消息,明明發(fā)送端的代碼是分兩次發(fā)送的,但是在接收端卻一次
    的頭像 發(fā)表于 09-23 10:00 ?1091次閱讀
    【推薦】<b class='flag-5'>TCP</b>為何<b class='flag-5'>粘</b><b class='flag-5'>包</b>?<b class='flag-5'>粘</b><b class='flag-5'>包</b>問題如何解決?

    tcp究竟會帶來多大的性能問題

    一個項目對接第三方接口數(shù)據(jù)。對方是TCP接口,發(fā)送數(shù)據(jù)頻率很高。平均2毫秒發(fā)送三四千個字節(jié)。由于TCP協(xié)議的
    的頭像 發(fā)表于 11-08 16:16 ?1742次閱讀
    <b class='flag-5'>tcp</b>丟<b class='flag-5'>包</b>究竟會帶來多大的性能問題

    如何解決tcp通信中的問題

    一、 問題概述 1、描述背景 采用TCP協(xié)議進(jìn)行網(wǎng)絡(luò)數(shù)據(jù)傳送的軟件設(shè)計中,普遍存在問題。這主要是由于現(xiàn)代操作系統(tǒng)的網(wǎng)絡(luò)傳輸機(jī)制所
    的頭像 發(fā)表于 11-11 11:40 ?2923次閱讀
    如何解決<b class='flag-5'>tcp</b>通信中的<b class='flag-5'>粘</b><b class='flag-5'>包</b>問題
    主站蜘蛛池模板: 狠狠干狠狠色 | 男人的天堂黄色 | 一级毛片真人免费观看 | 男人j进入女人免费视频 | 欧美激情一欧美吧 | 中文字幕一区二区三区在线播放 | 国内精品久久久久久久久野战 | 色天天天天综合男人的天堂 | 午夜操操 | 男女交性永久免费视频播放 | 天堂中文在线www | 毛片网站免费在线观看 | 69日本xxxxxxxxx18| 你懂的视频在线观看资源 | 午夜秒播| 亚洲黄色第一页 | 五月天毛片 | 久久精品男人影院 | 国产网站免费观看 | 成人黄色一级片 | 亚洲狠狠97婷婷综合久久久久 | 中文字幕在线二区 | 人人揉揉香蕉大青草 | 黄录像欧美片在线观看 | 波多野结衣在线一区 | 日本三级香港三级人妇网站 | 国产操视频 | 国产亚洲一区二区三区啪 | 九九re热| 国产高清视频在线免费观看 | 野外啪啪抽搐一进一出 | 中国一级特黄视频 | 69日本xxxxxxxxx29| 久久综合中文字幕 | 日韩1级片| 欧美大片国产在线永久播放 | 久久鬼| 欧美另类69| 你懂的在线免费视频 | 色视频色露露永久免费观看 | 国产精品欧美久久久久天天影视 |