Package io.netty.handler.codec.xml
Class XmlFrameDecoder
- java.lang.Object
-
- io.netty.channel.ChannelHandlerAdapter
-
- io.netty.channel.ChannelInboundHandlerAdapter
-
- io.netty.handler.codec.ByteToMessageDecoder
-
- io.netty.handler.codec.xml.XmlFrameDecoder
-
- All Implemented Interfaces:
ChannelHandler,ChannelInboundHandler
public class XmlFrameDecoder extends ByteToMessageDecoder
A frame decoder for single separate XML based message streams. A couple examples will better help illustrate what this decoder actually does. Given an input array of bytes split over 3 frames like this:+-----+-----+-----------+ | <an | Xml | Element/> | +-----+-----+-----------+
this decoder would output a single frame:+-----------------+ | <anXmlElement/> | +-----------------+
Given an input array of bytes split over 5 frames like this:+-----+-----+-----------+-----+----------------------------------+ | <an | Xml | Element/> | <ro | ot><child>content</child></root> | +-----+-----+-----------+-----+----------------------------------+
this decoder would output two frames:+-----------------+-------------------------------------+ | <anXmlElement/> | <root><child>content</child></root> | +-----------------+-------------------------------------+
The byte stream is expected to be in UTF-8 character encoding or ASCII. The current implementation uses directbytetocharcast and then compares thatcharto a few low range ASCII characters like'<','>'or'/'. UTF-8 is not using low range [0..0x7F] byte values for multibyte codepoint representations therefore fully supported by this implementation. Please note that this decoder is not suitable for xml streaming protocols such as XMPP, where an initial xml element opens the stream and only gets closed at the end of the session, although this class could probably allow for such type of message flow with minor modifications.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description private static classXmlFrameDecoder.BangMarkupKindThe outcome of classifying a'<!'construct against the<!--and<![CDATA[start markers.-
Nested classes/interfaces inherited from class io.netty.handler.codec.ByteToMessageDecoder
ByteToMessageDecoder.Cumulator
-
Nested classes/interfaces inherited from interface io.netty.channel.ChannelHandler
ChannelHandler.Sharable
-
-
Field Summary
Fields Modifier and Type Field Description private booleanatLeastOneXmlElementFoundprivate static byte[]CDATA_START_SUFFIXprivate booleaninCDATASectionprivate booleaninClosingTagprivate booleaninCommentBlockprivate booleaninProcessingInstructionprivate intleadingWhiteSpaceCountprivate intlengthIndex, relative to the current reader index, of the byte right after the last'>'seen so far.private intmaxFrameLengthprivate longopenBracketsCountprivate booleanopeningBracketFoundprivate intscanOffsetIndex, relative to the current reader index, of the next byte that still needs to be scanned.-
Fields inherited from class io.netty.handler.codec.ByteToMessageDecoder
COMPOSITE_CUMULATOR, MERGE_CUMULATOR
-
-
Constructor Summary
Constructors Constructor Description XmlFrameDecoder(int maxFrameLength)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description private static XmlFrameDecoder.BangMarkupKindclassifyBangMarkup(ByteBuf in, int i, int bufferLength)Classifies the markup declaration starting atin.getByte(i) == '<'followed by'!', matching it incrementally against the<!--and<![CDATA[prefixes so a genuinely different declaration (e.g.protected voiddecode(ChannelHandlerContext ctx, ByteBuf in, java.util.List<java.lang.Object> out)Decode the from oneByteBufto an other.private static ByteBufextractFrame(ByteBuf buffer, int index, int length)private voidfail(long frameLength)private static voidfail(ChannelHandlerContext ctx)private static booleanisValidStartCharForXmlElement(byte b)Asks whether the given byte is a valid start char for an xml element name.private voidresetState()-
Methods inherited from class io.netty.handler.codec.ByteToMessageDecoder
actualReadableBytes, callDecode, channelInactive, channelRead, channelReadComplete, decodeLast, discardSomeReadBytes, handlerRemoved, handlerRemoved0, internalBuffer, isSingleDecode, setCumulator, setDiscardAfterReads, setSingleDecode, userEventTriggered
-
Methods inherited from class io.netty.channel.ChannelInboundHandlerAdapter
channelActive, channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaught
-
Methods inherited from class io.netty.channel.ChannelHandlerAdapter
ensureNotSharable, handlerAdded, isSharable
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface io.netty.channel.ChannelHandler
handlerAdded
-
-
-
-
Field Detail
-
maxFrameLength
private final int maxFrameLength
-
openingBracketFound
private boolean openingBracketFound
-
atLeastOneXmlElementFound
private boolean atLeastOneXmlElementFound
-
inCDATASection
private boolean inCDATASection
-
inCommentBlock
private boolean inCommentBlock
-
inProcessingInstruction
private boolean inProcessingInstruction
-
inClosingTag
private boolean inClosingTag
-
openBracketsCount
private long openBracketsCount
-
length
private int length
Index, relative to the current reader index, of the byte right after the last'>'seen so far. Netty's cumulation buffer may be compacted (rebasing both the reader index and the bytes) in between twodecode(ChannelHandlerContext, ByteBuf, List)invocations, which would silently invalidate an absolute buffer index stored across calls; storing this relative to the reader index keeps it valid across such compactions, just likescanOffset.
-
leadingWhiteSpaceCount
private int leadingWhiteSpaceCount
-
scanOffset
private int scanOffset
Index, relative to the current reader index, of the next byte that still needs to be scanned. This letsdecode(ChannelHandlerContext, ByteBuf, List)resume scanning where the previous invocation left off instead of rescanning the whole accumulated buffer every time, which would otherwise make a slowly trickled, never-balanced element run in quadratic time.
-
CDATA_START_SUFFIX
private static final byte[] CDATA_START_SUFFIX
-
-
Method Detail
-
decode
protected void decode(ChannelHandlerContext ctx, ByteBuf in, java.util.List<java.lang.Object> out) throws java.lang.Exception
Description copied from class:ByteToMessageDecoderDecode the from oneByteBufto an other. This method will be called till either the inputByteBufhas nothing to read when return from this method or till nothing was read from the inputByteBuf.- Specified by:
decodein classByteToMessageDecoder- Parameters:
ctx- theChannelHandlerContextwhich thisByteToMessageDecoderbelongs toin- theByteBuffrom which to read dataout- theListto which decoded messages should be added- Throws:
java.lang.Exception- is thrown if an error occurs
-
resetState
private void resetState()
-
fail
private void fail(long frameLength)
-
fail
private static void fail(ChannelHandlerContext ctx)
-
isValidStartCharForXmlElement
private static boolean isValidStartCharForXmlElement(byte b)
Asks whether the given byte is a valid start char for an xml element name. Please refer to the NameStartChar formal definition in the W3C XML spec for further info.- Parameters:
b- the input char- Returns:
- true if the char is a valid start char
-
classifyBangMarkup
private static XmlFrameDecoder.BangMarkupKind classifyBangMarkup(ByteBuf in, int i, int bufferLength)
Classifies the markup declaration starting atin.getByte(i) == '<'followed by'!', matching it incrementally against the<!--and<![CDATA[prefixes so a genuinely different declaration (e.g.<!DOCTYPE ...>or an unknown<!x>) is recognised as such immediately, without waiting for bytes that would only be needed to confirm a comment or CDATA start.
-
-