成人无码视频,亚洲精品久久久久av无码,午夜精品久久久久久毛片,亚洲 中文字幕 日韩 无码

資訊專欄INFORMATION COLUMN

數(shù)據(jù)幀及消息定界

bang590 / 760人閱讀

摘要:成幀解決接收端如何定位消息的首尾位置的問題。無論信息是編碼成文本多字節(jié)二進(jìn)制數(shù)或是兩者結(jié)合,應(yīng)用程序協(xié)議必須制定消息的接收者如何確定何時消息已完整接收。發(fā)送者先要確定消息的長度,將長度信息寫入一個整數(shù),作為消息的前綴。

framing

成幀(framing):解決接收端如何定位消息的首尾位置的問題。

無論信息是編碼成文本、多字節(jié)二進(jìn)制數(shù)、或是兩者結(jié)合,應(yīng)用程序協(xié)議必須制定消息的接收者如何確定何時消息已完整接收。

如果是采用DatagramPacket發(fā)送,則沒有問題,因為它有一個確定的長度告訴接收者,讓其知道消息的結(jié)束位置。

如果是通過TCP傳送,則比較復(fù)雜,因為TCP協(xié)議中沒有邊界的概念。

變長消息

如果一個消息中的所有字段都有固定的長度,同時每個消息又是由固定數(shù)量的字段組成的話,消息的長度就能夠確定,接收者就可以簡單地講消息長度對應(yīng)的字節(jié)數(shù)讀到一個byte[]緩存區(qū)中。
如果消息的長度是可變的,則我們無法事先知道需要讀取多少字節(jié)。

如果接收者試圖從套接字中讀取比消息本身更多的字節(jié),將可能發(fā)生以下兩種情況之一:
1)如果信道中沒有其他消息,接收者將阻塞等待,同時無法處理接收到的消息,如果發(fā)送者也在等待接收端的響應(yīng)信息,則會造成死鎖
2)如果信道中還有其他消息,則接收者會將后面消息的一部分甚至全部讀到第一條消息中去,這將產(chǎn)生一些協(xié)議錯誤。

消息結(jié)束標(biāo)識

主要有兩個技術(shù)使接收者能夠準(zhǔn)確地找到消息的結(jié)束位置:

1)基于定界符(Delimiter-based)

消息的結(jié)束由一個唯一的標(biāo)記指出,即發(fā)送者在傳輸完數(shù)據(jù)后顯式添加的一個特殊字符序列。這個特殊標(biāo)記不能在傳輸?shù)臄?shù)據(jù)中出現(xiàn)。特殊情況是,可以用在TCP連接上傳輸?shù)淖詈笠粋€消息上,發(fā)送完這個消息后,發(fā)送者就簡單地關(guān)閉發(fā)送端的TCP連接,接收者讀取完這條消息的最后一個字節(jié)后,將接收到熬一個流結(jié)束標(biāo)記,即read返回-1,該標(biāo)記指出已經(jīng)讀取到達(dá)了消息的末尾。
通常用在以文本方式編碼的消息中,定義一個特殊的字符或字符串來標(biāo)識消息的結(jié)束。

 public byte[] nextMsg() throws IOException {
        ByteArrayOutputStream messageBuffer = new ByteArrayOutputStream();
        int nextByte;
        // fetch bytes until find delimiter
        while ((nextByte = in.read()) != DELIMITER) {
            if (nextByte == -1) { // end of stream?
                if (messageBuffer.size() == 0) { // if no byte read
                    return null;
                } else { // if bytes followed by end of stream: framing error
                    throw new EOFException("Non-empty message without delimiter");
                }
            }
            messageBuffer.write(nextByte); // write byte to buffer
        }
        return messageBuffer.toByteArray();
    }
2)顯示長度(Explicit length)

在變長字段或消息前附加一個固定大小的字段,用來指定字段或消息中包含了多少字節(jié)。發(fā)送者先要確定消息的長度,將長度信息寫入一個整數(shù),作為消息的前綴。消息的長度上限定義了用來編碼消息長度所需要的字節(jié)數(shù),如果消息的長度小于256字節(jié),則需要1個字節(jié),如果消息的長度小于65536字節(jié),則需要2個字節(jié)。

public byte[] nextMsg() throws IOException {
        int length;
        try {
            length = in.readUnsignedShort(); // read 2 bytes
        } catch (EOFException e) { // no (or 1 byte) message
            return null;
        }
        // 0 <= length <= 65535
        byte[] msg = new byte[length];
        in.readFully(msg); // if exception, it"s a framing error.
        return msg;
    }

readFully方法將阻塞等待,直到給定的數(shù)組完全填滿。

文章版權(quán)歸作者所有,未經(jīng)允許請勿轉(zhuǎn)載,若此文章存在違規(guī)行為,您可以聯(lián)系管理員刪除。

轉(zhuǎn)載請注明本文地址:http://m.hztianpu.com/yun/65916.html

相關(guān)文章

  • 基于 Netty 的可插拔業(yè)務(wù)通信協(xié)議的實現(xiàn)「1」協(xié)議描述及基本消息對象設(shè)計

    摘要:基本消息對象的設(shè)計消息對象的設(shè)計主要由兩部分組成特定數(shù)據(jù)幀對應(yīng)的特定消息對象。該類包含上節(jié)數(shù)據(jù)幀主幀及子幀的所有公共信息,僅僅未包含子幀中的數(shù)據(jù)體信息,該需求由基本消息對象的子類實現(xiàn)。 開發(fā)工程中,有一個常見的需求:服務(wù)端程序和多個客戶端程序通過 TCP 協(xié)議進(jìn)行通信,通信雙方需通信的消息種類眾多,并且客戶端的數(shù)量可能有數(shù)萬個。為此,雙方需要約定盡可能豐富、靈活的數(shù)據(jù)幀「數(shù)據(jù)包」協(xié)議,...

    Barry_Ng 評論0 收藏0
  • PHP基礎(chǔ)系列之正則表達(dá)式(一)

    摘要:正則表達(dá)式作為一個匹配的模板,是由定界符,原子普通字符,例如有特殊功能的字符稱為元字符,例如等以及模式修正符等部分組成的文字模式。正則表達(dá)式中可以使用編碼。限定符限定符用來指定正則表達(dá)式的一個給定原子必須要出現(xiàn)多少次才能滿足匹配。 正則表達(dá)式的定義 正則表達(dá)式就是描述字符排列模式的一種自定義的語法規(guī)則。由于正則表達(dá)式本身具有一套非常完整的、可以編寫模式的語法體系,提供了一種靈活且直觀的...

    Anchorer 評論0 收藏0
  • 《Java編程思想》筆記13.字符串

    摘要:的構(gòu)造器經(jīng)過重載可以接受多種輸出目的地,不過最常用的還是和。組號為表示整個表達(dá)式,組號表示被第一對括號括起的組,依此類推。有多個重載的構(gòu)造器,可以接受和對象。 點擊進(jìn)入我的博客 字符串操作是計算機(jī)程序設(shè)計中最常見的行為 13.1 不可變String String底層是由char[]實現(xiàn)的,是不可變的??雌饋頃淖僑tring的方法,實際上都是創(chuàng)建了一個新的String對象,任何指向它...

    since1986 評論0 收藏0

發(fā)表評論

0條評論

閱讀需要支付1元查看
<