簡介

在json之前，xml是最常用的數(shù)據(jù)傳輸格式，雖然xml的冗余數(shù)據(jù)有點(diǎn)多，但是xml的結(jié)構(gòu)簡單清晰，至今仍然運(yùn)用在程序中的不同地方，對于netty來說自然也提供了對于xml數(shù)據(jù)的支持。

netty對xml的支持表現(xiàn)在兩個(gè)方面，第一個(gè)方面是將編碼過后的多個(gè)xml數(shù)據(jù)進(jìn)行frame拆分，每個(gè)frame包含一個(gè)完整的xml。另一方面是將分割好的frame進(jìn)行xml的語義解析。

進(jìn)行frame拆分可以使用XmlFrameDecoder,進(jìn)行xml文件內(nèi)容的解析則可以使用XmlDecoder，接下來我們會(huì)詳細(xì)講解兩個(gè)decoder實(shí)現(xiàn)和使用。

XmlFrameDecoder

因?yàn)槲覀兪盏降氖菙?shù)據(jù)流，所以不確定收到的數(shù)據(jù)到底是什么樣的，一個(gè)正常的xml數(shù)據(jù)可能會(huì)被拆分成多個(gè)數(shù)據(jù)frame。

如下所示:

+-------+-----+--------------+
   | <this | IsA | XMLElement/> |
   +-------+-----+--------------+

這是一個(gè)正常的xml數(shù)據(jù)，但是被拆分成為了三個(gè)frame，所以我們需要將其合并成為一個(gè)frame如下：

 +-----------------+
   | <thisIsAXMLElement/> |
   +-----------------+

還有可能不同的xml數(shù)據(jù)被分拆在多個(gè)frame中的情況,如下所示：

+-----+-----+-----------+-----+----------------------------------+
   | <an | Xml | Element/> | <ro | ot><child>content</child></root> |
   +-----+-----+-----------+-----+----------------------------------+

上面的數(shù)據(jù)需要拆分成為兩個(gè)frame：

+-----------------+-------------------------------------+
   | <anXmlElement/> | <root><child>content</child></root> |
   +-----------------+-------------------------------------+

拆分的邏輯很簡單，主要是通過判斷xml的分隔符的位置來判斷xml是否開始或者結(jié)束。xml中的分隔符有三個(gè)，分別是’<', ‘>’ 和 ‘/’。

在decode方法中只需要判斷這三個(gè)分隔符即可。

另外還有一些額外的判斷邏輯，比如是否是有效的xml開始字符：

 private static boolean isValidStartCharForXmlElement(final byte b) {
        return b >= 'a' && b <= 'z' || b >= 'A' && b <= 'Z' || b == ':' || b == '_';
    }

是否是注釋:

  private static boolean isCommentBlockStart(final ByteBuf in, final int i) {
        return i < in.writerIndex() - 3
                && in.getByte(i + 2) == '-'
                && in.getByte(i + 3) == '-';
    }

是否是CDATA數(shù)據(jù)：

 private static boolean isCDATABlockStart(final ByteBuf in, final int i) {
        return i < in.writerIndex() - 8
                && in.getByte(i + 2) == '['
                && in.getByte(i + 3) == 'C'
                && in.getByte(i + 4) == 'D'
                && in.getByte(i + 5) == 'A'
                && in.getByte(i + 6) == 'T'
                && in.getByte(i + 7) == 'A'
                && in.getByte(i + 8) == '[';

通過使用這些方法判斷好xml數(shù)據(jù)的起始位置之后，就可以調(diào)用extractFrame方法將要使用的ByteBuf從原始數(shù)據(jù)中拷貝出來，最后放到out中去：

final ByteBuf frame =
                    extractFrame(in, readerIndex + leadingWhiteSpaceCount, xmlElementLength - leadingWhiteSpaceCount);
            in.skipBytes(xmlElementLength);
            out.add(frame);

XmlDecoder

將xml數(shù)據(jù)拆分成為一個(gè)個(gè)frame之后，接下來就是對xml中具體數(shù)據(jù)的解析了。

netty提供了一個(gè)xml數(shù)據(jù)解析的方法叫做XmlDecoder,主要用來對已經(jīng)是一個(gè)單獨(dú)的xml數(shù)據(jù)的frame進(jìn)行實(shí)質(zhì)內(nèi)容的解析，它的定義如下：

public class XmlDecoder extends ByteToMessageDecoder 

XmlDecoder根據(jù)讀取到的xml內(nèi)容，將xml的部分拆分為XmlElementStart,XmlAttribute,XmlNamespace,XmlElementEnd,XmlProcessingInstruction,XmlCharacters,XmlComment,XmlSpace,XmlDocumentStart,XmlEntityReference,XmlDTD和XmlCdata。

這些數(shù)據(jù)基本上覆蓋了xml中所有可能出現(xiàn)的元素。

所有的這些元素都是定義在io.netty.handler.codec.xml包中的。

但是XmlDecoder對xml的讀取解析則是借用了第三方xml工具包：fasterxml。

XmlDecoder使用了fasterxml中的AsyncXMLStreamReader和AsyncByteArrayFeeder用來進(jìn)行xml數(shù)據(jù)的解析。

這兩個(gè)屬性的定義如下：

 private static final AsyncXMLInputFactory XML_INPUT_FACTORY = new InputFactoryImpl();
    private final AsyncXMLStreamReader<AsyncByteArrayFeeder> streamReader;
    private final AsyncByteArrayFeeder streamFeeder;
            this.streamReader = XML_INPUT_FACTORY.createAsyncForByteArray();
        this.streamFeeder = (AsyncByteArrayFeeder)this.streamReader.getInputFeeder();

decode的邏輯是通過判斷xml element的類型來分別進(jìn)行不同數(shù)據(jù)的讀取,最后將讀取到的數(shù)據(jù)封裝成上面我們提到的各種xml對象，最后將xml對象添加到out list中返回。

總結(jié)

我們可以借助XmlFrameDecoder和XmlDecoder來實(shí)現(xiàn)非常方便的xml數(shù)據(jù)解析，netty已經(jīng)為我們造好輪子了，我們就不需要再自行發(fā)明了。

到此這篇關(guān)于netty中常用的xml編碼解碼器的文章就介紹到這了,更多相關(guān)netty解碼器內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

最新評論