public class JZlibDecoder extends ZlibDecoder
ByteToMessageDecoder.Cumulator
ChannelHandler.Sharable
maxAllocation
COMPOSITE_CUMULATOR, MERGE_CUMULATOR
构造器和说明 |
---|
JZlibDecoder()
Creates a new instance with the default wrapper (
ZlibWrapper.ZLIB ). |
JZlibDecoder(byte[] dictionary)
Creates a new instance with the specified preset dictionary.
|
JZlibDecoder(byte[] dictionary,
int maxAllocation)
Creates a new instance with the specified preset dictionary and maximum buffer allocation.
|
JZlibDecoder(int maxAllocation)
Creates a new instance with the default wrapper (
ZlibWrapper.ZLIB )
and specified maximum buffer allocation. |
JZlibDecoder(ZlibWrapper wrapper)
Creates a new instance with the specified wrapper.
|
JZlibDecoder(ZlibWrapper wrapper,
int maxAllocation)
Creates a new instance with the specified wrapper and maximum buffer allocation.
|
限定符和类型 | 方法和说明 |
---|---|
protected void |
decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out)
Decode the from one
ByteBuf to an other. |
protected void |
decompressionBufferExhausted(ByteBuf buffer)
Called when the decompression buffer cannot be expanded further.
|
boolean |
isClosed()
Returns
true if and only if the end of the compressed stream
has been reached. |
prepareDecompressBuffer
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 JZlibDecoder()
ZlibWrapper.ZLIB
).DecompressionException
- if failed to initialize zlibpublic JZlibDecoder(int maxAllocation)
ZlibWrapper.ZLIB
)
and specified maximum buffer allocation.maxAllocation
- Maximum size of the decompression buffer. Must be >= 0.
If zero, maximum size is decided by the ByteBufAllocator
.DecompressionException
- if failed to initialize zlibpublic JZlibDecoder(ZlibWrapper wrapper)
DecompressionException
- if failed to initialize zlibpublic JZlibDecoder(ZlibWrapper wrapper, int maxAllocation)
maxAllocation
- Maximum size of the decompression buffer. Must be >= 0.
If zero, maximum size is decided by the ByteBufAllocator
.DecompressionException
- if failed to initialize zlibpublic JZlibDecoder(byte[] dictionary)
ZlibWrapper.ZLIB
because it is the only format that
supports the preset dictionary.DecompressionException
- if failed to initialize zlibpublic JZlibDecoder(byte[] dictionary, int maxAllocation)
ZlibWrapper.ZLIB
because it is the only format that
supports the preset dictionary.maxAllocation
- Maximum size of the decompression buffer. Must be >= 0.
If zero, maximum size is decided by the ByteBufAllocator
.DecompressionException
- if failed to initialize zlibpublic boolean isClosed()
true
if and only if the end of the compressed stream
has been reached.isClosed
在类中 ZlibDecoder
protected 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 occursprotected void decompressionBufferExhausted(ByteBuf buffer)
ZlibDecoder
DecompressionException
is thrown, such as log the
data that was decompressed so far.