• <ins id="pjuwb"></ins>
    <blockquote id="pjuwb"><pre id="pjuwb"></pre></blockquote>
    <noscript id="pjuwb"></noscript>
          <sup id="pjuwb"><pre id="pjuwb"></pre></sup>
            <dd id="pjuwb"></dd>
            <abbr id="pjuwb"></abbr>

            A Za, A Za, Fighting...

            堅(jiān)信:勤能補(bǔ)拙

            2011知識(shí)點(diǎn)-TCP 區(qū)分消息邊界[zz]

             在socket網(wǎng)絡(luò)程序中,TCP和UDP分別是面向連接和非面向連接的。因此TCP的socket編程,收發(fā)兩端(客戶端和服務(wù)器端)都要有一一成對(duì)的socket,因此,發(fā)送端為了將多個(gè)發(fā)往接收端的包,更有效的發(fā)到對(duì)方,使用了優(yōu)化方法(Nagle算法),將多次間隔較小且數(shù)據(jù)量小的數(shù)據(jù),合并成一個(gè)大的數(shù)據(jù)塊,然后進(jìn)行封包。這樣,接收端,就難于分辨出來(lái)了,必須提供科學(xué)的拆包機(jī)制。
                   對(duì)于UDP,不會(huì)使用塊的合并優(yōu)化算法,這樣,實(shí)際上目前認(rèn)為,是由于UDP支持的是一對(duì)多的模式,所以接收端的skbuff(套接字緩沖區(qū))采用了鏈?zhǔn)浇Y(jié)構(gòu)來(lái)記錄每一個(gè)到達(dá)的UDP包,在每個(gè)UDP包中就有了消息頭(消息來(lái)源地址,端口等信息),這樣,對(duì)于接收端來(lái)說(shuō),就容易進(jìn)行區(qū)分處理了

            保護(hù)消息邊界和流

            那么什么是保護(hù)消息邊界和流呢?

                   保護(hù)消息邊界,就是指?jìng)鬏攨f(xié)議把數(shù)據(jù)當(dāng)作一條獨(dú)立的消息在網(wǎng)上 
            傳輸,接收端只能接收獨(dú)立的消息.也就是說(shuō)存在保護(hù)消息邊界,接收 
            端一次只能接收發(fā)送端發(fā)出的一個(gè)數(shù)據(jù)包. 
                   而面向流則是指無(wú)保護(hù)消息保護(hù)邊界的,如果發(fā)送端連續(xù)發(fā)送數(shù)據(jù), 
            接收端有可能在一次接收動(dòng)作中,會(huì)接收兩個(gè)或者更多的數(shù)據(jù)包.

                   我們舉個(gè)例子來(lái)說(shuō),例如,我們連續(xù)發(fā)送三個(gè)數(shù)據(jù)包,大小分別是2k, 
            4k , 8k,這三個(gè)數(shù)據(jù)包,都已經(jīng)到達(dá)了接收端的網(wǎng)絡(luò)堆棧中,如果使 
            UDP協(xié)議,不管我們使用多大的接收緩沖區(qū)去接收數(shù)據(jù),我們必須有 
            三次接收動(dòng)作,才能夠把所有的數(shù)據(jù)包接收完.而使用TCP協(xié)議,我們 
            只要把接收的緩沖區(qū)大小設(shè)置在14k以上,我們就能夠一次把所有的 
            數(shù)據(jù)包接收下來(lái).只需要有一次接收動(dòng)作.

                   這就是因?yàn)?strong style="line-height: 22px; color: black; background-color: #ffff66; ">UDP協(xié)議的保護(hù)消息邊界使得每一個(gè)消息都是獨(dú)立的.而 
            流傳輸,卻把數(shù)據(jù)當(dāng)作一串?dāng)?shù)據(jù)流,他不認(rèn)為數(shù)據(jù)是一個(gè)一個(gè)的消息.

                  所以有很多人在使用tcp協(xié)議通訊的時(shí)候,并不清楚tcp是基于流的 
            傳輸,當(dāng)連續(xù)發(fā)送數(shù)據(jù)的時(shí)候,他們時(shí)常會(huì)認(rèn)識(shí)tcp會(huì)丟包.其實(shí)不然, 
            因?yàn)楫?dāng)他們使用的緩沖區(qū)足夠大時(shí),他們有可能會(huì)一次接收到兩個(gè)甚 
            至更多的數(shù)據(jù)包,而很多人往往會(huì)忽視這一點(diǎn),只解析檢查了第一個(gè) 
            數(shù)據(jù)包,而已經(jīng)接收的其他數(shù)據(jù)包卻被忽略了.所以大家如果要作這 
            類(lèi)的網(wǎng)絡(luò)編程的時(shí)候,必須要注意這一點(diǎn).

            結(jié)論:
                 根據(jù)以上所說(shuō),可以這樣理解,TCP為了保證可靠傳輸,盡量減少額外
            開(kāi)銷(xiāo)(每次發(fā)包都要驗(yàn)證),因此采用了流式傳輸,面向流的傳輸,
            相對(duì)于面向消息的傳輸,可以減少發(fā)送包的數(shù)量。從而減少了額外開(kāi)
            銷(xiāo)。但是,對(duì)于數(shù)據(jù)傳輸頻繁的程序來(lái)講,使用TCP可能會(huì)容易粘包。
            當(dāng)然,對(duì)接收端的程序來(lái)講,如果機(jī)器負(fù)荷很重,也會(huì)在接收緩沖里
            粘包。這樣,就需要接收端額外拆包,增加了工作量。因此,這個(gè)特
            別適合的是數(shù)據(jù)要求可靠傳輸,但是不需要太頻繁傳輸?shù)膱?chǎng)合(
            兩次操作間隔100ms,具體是由TCP等待發(fā)送間隔決定的,取決于內(nèi)核
            中的socket的寫(xiě)法)

            而UDP,由于面向的是消息傳輸,它把所有接收到的消息都掛接到緩沖
            區(qū)的接受隊(duì)列中,因此,它對(duì)于數(shù)據(jù)的提取分離就更加方便,但是,
            它沒(méi)有粘包機(jī)制,因此,當(dāng)發(fā)送數(shù)據(jù)量較小的時(shí)候,就會(huì)發(fā)生數(shù)據(jù)包
            有效載荷較小的情況,也會(huì)增加多次發(fā)送的系統(tǒng)發(fā)送開(kāi)銷(xiāo)(系統(tǒng)調(diào)用,
            寫(xiě)硬件等)和接收開(kāi)銷(xiāo)。因此,應(yīng)該最好設(shè)置一個(gè)比較合適的數(shù)據(jù)包
            的包長(zhǎng),來(lái)進(jìn)行UDP數(shù)據(jù)的發(fā)送。(UDP最大載荷為1472,因此最好能
            每次傳輸接近這個(gè)數(shù)的數(shù)據(jù)量,這特別適合于視頻,音頻等大塊數(shù)據(jù)
            的發(fā)送,同時(shí),通過(guò)減少握手來(lái)保證流媒體的實(shí)時(shí)性)

            來(lái)自: http://hi.baidu.com/chongerfeia/blog/item/b1e572f631dd7e28bd310965.html

            TCP無(wú)保護(hù)消息邊界的解決
             針對(duì)這個(gè)問(wèn)題,一般有3種解決方案:

                  (1)發(fā)送固定長(zhǎng)度的消息

                  (2)把消息的尺寸與消息一塊發(fā)送

                  (3)使用特殊標(biāo)記來(lái)區(qū)分消息間隔

                 

            下面我們主要分析下前兩種方法:

            1、發(fā)送固定長(zhǎng)度的消息 
            這種方法的好處是他非常容易,而且只要指定好消息的長(zhǎng)度,沒(méi)有遺漏未未發(fā)的數(shù)據(jù),我們重寫(xiě)了一個(gè)SendMessage方法。代碼如下:

              private static int SendMessage(Socket s, byte[] msg)

                    { 
                        int offset = 0; 
                        int size = msg.Length; 
                        int dataleft = size;

                        while (dataleft > 0) 
                        {

                            int sent = s.Send(msg, offset, SocketFlags.None); 
                            offset += sent; 
                            dataleft -= sent;

                        }

                        return offset; 
                    }

            簡(jiǎn)要分析一下這個(gè)函數(shù):形參s是進(jìn)行通信的套接字,msg即待發(fā)送的字節(jié)數(shù)組。該方法使用while循環(huán)檢查是否還有數(shù)據(jù)未發(fā)送,尤其當(dāng)發(fā)送一個(gè)很龐大的數(shù)據(jù)包,在不能一次性發(fā)完的情況下作用比較明顯。特別的,用sent來(lái)記錄實(shí)際發(fā)送的數(shù)據(jù)量,和recv是異曲同工的作用,最后返回發(fā)送的實(shí)際數(shù)據(jù)總數(shù)。

               有sentMessage函數(shù)后,還要根據(jù)指定的消息長(zhǎng)度來(lái)設(shè)計(jì)一個(gè)新的Recive方法。代碼如下:

              private byte[] ReciveMessage(Socket s, int size) 
                    {

                        int offset = 0; 
                        int recv; 
                        int dataleft = size; 
                        byte[] msg = new byte[size];


                        while (dataleft > 0)

                        {

                            //接收消息 
                            recv = s.Receive(msg, offset, dataleft, 0); 
                            if (recv == 0)

                            {

                                break;

                            } 
                            offset += recv; 
                            dataleft -= recv;

                        }

                        return msg;

                    }

            以上這種做法比較適合于消息長(zhǎng)度不是很長(zhǎng)的情況。

            2、消息長(zhǎng)度與消息一同發(fā)送

            我們可以這樣做:通過(guò)使用消息的整形數(shù)值來(lái)表示消息的實(shí)際大小,所以要把整形數(shù)轉(zhuǎn)換為字節(jié)類(lèi)型。下面是發(fā)送變長(zhǎng)消息的SendMessage方法。具體代碼如下:

              private static int SendMessage(Socket s, byte[] msg) 
                    {

                        int offset = 0; 
                        int sent; 
                        int size = msg.Length; 
                        int dataleft = size; 
                        byte[] msgsize = new byte[2];

                        //將消息尺寸從整形轉(zhuǎn)換成可以發(fā)送的字節(jié)型 
                        msgsize = BitConverter.GetBytes(size);


                        //發(fā)送消息的長(zhǎng)度信息 
                        sent = s.Send(size);

                        while (dataleft > 0)

                        {

                            sent = s.Send(msg, offset, dataleft, SocketFlags.None);

                            //設(shè)置偏移量

                            offset += sent; 
                            dataleft -= sent;

                        }

                        return offset;

                    }


            下面是接收變長(zhǎng)消息的ReciveVarMessage方法。代碼如下:

            private byte[] ReciveVarMessage(Socket s) 
                    {


                        int offset = 0; 
                        int recv; 
                        byte[] msgsize = new byte[2];


                        //將字節(jié)數(shù)組的消息長(zhǎng)度信息轉(zhuǎn)換為整形 
                        int size = BitConverter.ToInt16(msgsize); 
                        int dataleft = size; 
                        byte[] msg = new byte[size];


                        //接收2個(gè)字節(jié)大小的長(zhǎng)度信息 
                        recv = s.Receive(msgsize, 0, 2, 0); 
                        while (dataleft > 0) 
                        {

                            //接收數(shù)據(jù) 
                            recv = s.Receive(msg, offset, dataleft, 0); 
                            if (recv == 0) 
                            { 
                                break; 
                            } 
                            offset += recv; 
                            dataleft -= recv;

                        }

                        return msg;

                    }

            posted on 2011-09-01 18:36 simplyzhao 閱讀(653) 評(píng)論(0)  編輯 收藏 引用 所屬分類(lèi): R_找工復(fù)習(xí)2011

            導(dǎo)航

            <2010年8月>
            25262728293031
            1234567
            891011121314
            15161718192021
            22232425262728
            2930311234

            統(tǒng)計(jì)

            常用鏈接

            留言簿(1)

            隨筆分類(lèi)

            隨筆檔案

            搜索

            最新評(píng)論

            閱讀排行榜

            評(píng)論排行榜

            九九精品久久久久久噜噜| 亚洲AV成人无码久久精品老人| 韩国免费A级毛片久久| 97超级碰碰碰久久久久| 九九热久久免费视频| 久久99热这里只频精品6| 国产精品免费福利久久| 99久久国产亚洲高清观看2024| 中文字幕精品久久久久人妻| 无码人妻久久一区二区三区免费| 国产一久久香蕉国产线看观看 | 久久久精品国产sm调教网站 | 欧美国产精品久久高清| 亚洲精品乱码久久久久久久久久久久| 精品久久久久久国产| 亚洲午夜福利精品久久| 久久91精品国产91久久麻豆| 色欲综合久久躁天天躁| 一级做a爰片久久毛片16| 亚洲中文字幕久久精品无码喷水 | 99久久免费国产精品热| 欧美麻豆久久久久久中文| 国产精品久久久亚洲| 亚洲精品美女久久久久99| 久久久久亚洲精品无码网址| 久久精品国产亚洲沈樵| 久久久久人妻一区精品色| 伊人久久大香线蕉无码麻豆| 精品久久久久久久久久中文字幕| 精品一区二区久久久久久久网站| 一本久久a久久精品亚洲| 久久亚洲熟女cc98cm| 伊人色综合九久久天天蜜桃| 久久精品国产亚洲AV不卡| 国产精品一区二区久久精品无码 | 久久综合亚洲色HEZYO国产| 亚洲欧美日韩精品久久| 国产午夜免费高清久久影院| 亚洲中文字幕久久精品无码APP | 99久久免费国产精品特黄| 香蕉aa三级久久毛片|