public class SnappyFramedDecoder extends ByteToMessageDecoder
ByteBuf
encoded with the Snappy framing format.
See http://code.google.com/p/snappy/source/browse/trunk/framing_format.txt
Note that by default, validation of the checksum header in each chunk is
DISABLED for performance improvements. If performance is less of an issue,
or if you would prefer the safety that checksum validation brings, please
use the SnappyFramedDecoder(boolean)
constructor with the argument
set to true
.ByteToMessageDecoder.Cumulator
ChannelHandler.Sharable
COMPOSITE_CUMULATOR, MERGE_CUMULATOR
构造器和说明 |
---|
SnappyFramedDecoder()
Creates a new snappy-framed decoder with validation of checksums
turned OFF.
|
SnappyFramedDecoder(boolean validateChecksums)
Creates a new snappy-framed decoder with validation of checksums
as specified.
|
限定符和类型 | 方法和说明 |
---|---|
protected void |
decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out)
Decode the from one
ByteBuf to an other. |
actualReadableBytes, callDecode, channelInactive, channelRead, channelReadComplete, decodeLast, discardSomeReadBytes, handlerRemoved, handlerRemoved0, internalBuffer, isSingleDecode, setCumulator, setDiscardAfterReads, setSingleDecode, userEventTriggered
channelActive, channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaught
ensureNotSharable, handlerAdded, isSharable
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
handlerAdded
public SnappyFramedDecoder()
SnappyFramedDecoder(boolean)
constructor.public SnappyFramedDecoder(boolean validateChecksums)
validateChecksums
- If true, the checksum field will be validated against the actual
uncompressed data, and if the checksums do not match, a suitable
DecompressionException
will be thrownprotected void decode(ChannelHandlerContext ctx, ByteBuf in, java.util.List<java.lang.Object> out) throws java.lang.Exception
ByteToMessageDecoder
ByteBuf
to an other. This method will be called till either the input
ByteBuf
has nothing to read when return from this method or till nothing was read from the input
ByteBuf
.decode
在类中 ByteToMessageDecoder
ctx
- the ChannelHandlerContext
which this ByteToMessageDecoder
belongs toin
- the ByteBuf
from which to read dataout
- the List
to which decoded messages should be addedjava.lang.Exception
- is thrown if an error occurs