Class DelimiterBasedFrameDecoder
java.lang.Object
io.netty.channel.ChannelHandlerAdapter
io.netty.channel.ChannelInboundHandlerAdapter
io.netty.handler.codec.ByteToMessageDecoder
io.netty.handler.codec.DelimiterBasedFrameDecoder
- All Implemented Interfaces:
ChannelHandler, ChannelInboundHandler
A decoder that splits the received
ByteBufs by one or more
delimiters. It is particularly useful for decoding the frames which ends
with a delimiter such as NUL or
newline characters.
Predefined delimiters
Delimiters defines frequently used delimiters for convenience' sake.
Specifying more than one delimiter
DelimiterBasedFrameDecoder allows you to specify more than one
delimiter. If more than one delimiter is found in the buffer, it chooses
the delimiter which produces the shortest frame. For example, if you have
the following data in the buffer:
+--------------+ | ABC\nDEF\r\n | +--------------+a
DelimiterBasedFrameDecoder(Delimiters.lineDelimiter())
will choose '\n' as the first delimiter and produce two frames:
+-----+-----+ | ABC | DEF | +-----+-----+rather than incorrectly choosing
'\r\n' as the first delimiter:
+----------+ | ABC\nDEF | +----------+
-
Nested Class Summary
Nested classes/interfaces inherited from class ByteToMessageDecoder
ByteToMessageDecoder.CumulatorNested classes/interfaces inherited from interface ChannelHandler
ChannelHandler.Sharable -
Field Summary
Fields inherited from class ByteToMessageDecoder
COMPOSITE_CUMULATOR, MERGE_CUMULATOR -
Constructor Summary
ConstructorsConstructorDescriptionDelimiterBasedFrameDecoder(int maxFrameLength, boolean stripDelimiter, boolean failFast, ByteBuf delimiter) Creates a new instance.DelimiterBasedFrameDecoder(int maxFrameLength, boolean stripDelimiter, boolean failFast, ByteBuf... delimiters) Creates a new instance.DelimiterBasedFrameDecoder(int maxFrameLength, boolean stripDelimiter, ByteBuf delimiter) Creates a new instance.DelimiterBasedFrameDecoder(int maxFrameLength, boolean stripDelimiter, ByteBuf... delimiters) Creates a new instance.DelimiterBasedFrameDecoder(int maxFrameLength, ByteBuf delimiter) Creates a new instance.DelimiterBasedFrameDecoder(int maxFrameLength, ByteBuf... delimiters) Creates a new instance. -
Method Summary
Methods inherited from class ByteToMessageDecoder
actualReadableBytes, callDecode, channelInactive, channelRead, channelReadComplete, decodeLast, discardSomeReadBytes, handlerRemoved, handlerRemoved0, internalBuffer, isSingleDecode, setCumulator, setDiscardAfterReads, setSingleDecode, userEventTriggeredMethods inherited from class ChannelInboundHandlerAdapter
channelActive, channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaughtMethods inherited from class ChannelHandlerAdapter
ensureNotSharable, handlerAdded, isSharableMethods inherited from class Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface ChannelHandler
handlerAdded
-
Constructor Details
-
DelimiterBasedFrameDecoder
Creates a new instance.- Parameters:
maxFrameLength- the maximum length of the decoded frame. ATooLongFrameExceptionis thrown if the length of the frame exceeds this value.delimiter- the delimiter
-
DelimiterBasedFrameDecoder
Creates a new instance.- Parameters:
maxFrameLength- the maximum length of the decoded frame. ATooLongFrameExceptionis thrown if the length of the frame exceeds this value.stripDelimiter- whether the decoded frame should strip out the delimiter or notdelimiter- the delimiter
-
DelimiterBasedFrameDecoder
public DelimiterBasedFrameDecoder(int maxFrameLength, boolean stripDelimiter, boolean failFast, ByteBuf delimiter) Creates a new instance.- Parameters:
maxFrameLength- the maximum length of the decoded frame. ATooLongFrameExceptionis thrown if the length of the frame exceeds this value.stripDelimiter- whether the decoded frame should strip out the delimiter or notfailFast- If true, aTooLongFrameExceptionis thrown as soon as the decoder notices the length of the frame will exceed maxFrameLength regardless of whether the entire frame has been read. If false, aTooLongFrameExceptionis thrown after the entire frame that exceeds maxFrameLength has been read.delimiter- the delimiter
-
DelimiterBasedFrameDecoder
Creates a new instance.- Parameters:
maxFrameLength- the maximum length of the decoded frame. ATooLongFrameExceptionis thrown if the length of the frame exceeds this value.delimiters- the delimiters
-
DelimiterBasedFrameDecoder
public DelimiterBasedFrameDecoder(int maxFrameLength, boolean stripDelimiter, ByteBuf... delimiters) Creates a new instance.- Parameters:
maxFrameLength- the maximum length of the decoded frame. ATooLongFrameExceptionis thrown if the length of the frame exceeds this value.stripDelimiter- whether the decoded frame should strip out the delimiter or notdelimiters- the delimiters
-
DelimiterBasedFrameDecoder
public DelimiterBasedFrameDecoder(int maxFrameLength, boolean stripDelimiter, boolean failFast, ByteBuf... delimiters) Creates a new instance.- Parameters:
maxFrameLength- the maximum length of the decoded frame. ATooLongFrameExceptionis thrown if the length of the frame exceeds this value.stripDelimiter- whether the decoded frame should strip out the delimiter or notfailFast- If true, aTooLongFrameExceptionis thrown as soon as the decoder notices the length of the frame will exceed maxFrameLength regardless of whether the entire frame has been read. If false, aTooLongFrameExceptionis thrown after the entire frame that exceeds maxFrameLength has been read.delimiters- the delimiters
-
-
Method Details
-
decode
protected final void decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) throws 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:
Exception- is thrown if an error occurs
-
decode
Create a frame out of theByteBufand return it.- Parameters:
ctx- theChannelHandlerContextwhich thisByteToMessageDecoderbelongs tobuffer- theByteBuffrom which to read data- Returns:
- frame the
ByteBufwhich represent the frame ornullif no frame could be created. - Throws:
Exception
-