io.netty.handler.codec.compression

类 Lz4FrameDecoder

java.lang.Object

io.netty.channel.ChannelHandlerAdapter

io.netty.channel.ChannelInboundHandlerAdapter

io.netty.handler.codec.ByteToMessageDecoder

io.netty.handler.codec.compression.Lz4FrameDecoder

所有已实现的接口:

ChannelHandler, ChannelInboundHandler

public class Lz4FrameDecoder
extends ByteToMessageDecoder

Uncompresses a ByteBuf encoded with the LZ4 format. See original LZ4 Github project and LZ4 block format for full description. Since the original LZ4 block format does not contains size of compressed block and size of original data this encoder uses format like LZ4 Java library written by Adrien Grand and approved by Yann Collet (author of original LZ4 library). * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * Magic * Token * Compressed * Decompressed * Checksum * + * LZ4 compressed * * * * length * length * * * block * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * *

嵌套类概要

从类继承的嵌套类/接口 io.netty.handler.codec.ByteToMessageDecoder

ByteToMessageDecoder.Cumulator

从接口继承的嵌套类/接口 io.netty.channel.ChannelHandler

ChannelHandler.Sharable

字段概要

从类继承的字段 io.netty.handler.codec.ByteToMessageDecoder

COMPOSITE_CUMULATOR, MERGE_CUMULATOR

构造器概要

构造器

构造器和说明
Lz4FrameDecoder() Creates the fastest LZ4 decoder.
Lz4FrameDecoder(boolean validateChecksums) Creates a LZ4 decoder with fastest decoder instance available on your machine.
Lz4FrameDecoder(LZ4Factory factory, boolean validateChecksums) Creates a new LZ4 decoder with customizable implementation.
Lz4FrameDecoder(LZ4Factory factory, java.util.zip.Checksum checksum) Creates a new customizable LZ4 decoder.

方法概要

限定符和类型	方法和说明
protected void	decode(ChannelHandlerContext ctx, ByteBuf in, java.util.List<java.lang.Object> out) Decode the from one ByteBuf to an other.
boolean	isClosed() Returns true if and only if the end of the compressed stream has been reached.

从类继承的方法 io.netty.handler.codec.ByteToMessageDecoder

actualReadableBytes, callDecode, channelInactive, channelRead, channelReadComplete, decodeLast, discardSomeReadBytes, handlerRemoved, handlerRemoved0, internalBuffer, isSingleDecode, setCumulator, setDiscardAfterReads, setSingleDecode, userEventTriggered

从类继承的方法 io.netty.channel.ChannelInboundHandlerAdapter

channelActive, channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaught

从类继承的方法 io.netty.channel.ChannelHandlerAdapter

ensureNotSharable, handlerAdded, isSharable

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

从接口继承的方法 io.netty.channel.ChannelHandler

handlerAdded

构造器详细资料

Lz4FrameDecoder

public Lz4FrameDecoder()

Creates the fastest LZ4 decoder. 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 Lz4FrameDecoder(boolean) constructor with the argument set to true.

Lz4FrameDecoder

public Lz4FrameDecoder(boolean validateChecksums)

Creates a LZ4 decoder with fastest decoder instance available on your machine.

参数:

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 thrown

Lz4FrameDecoder

public Lz4FrameDecoder(LZ4Factory factory,
                       boolean validateChecksums)

Creates a new LZ4 decoder with customizable implementation.

参数:

factory - user customizable LZ4Factory instance which may be JNI bindings to the original C implementation, a pure Java implementation or a Java implementation that uses the Unsafe

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 thrown. In this case encoder will use xxhash hashing for Java, based on Yann Collet's work available at Github.

Lz4FrameDecoder

public Lz4FrameDecoder(LZ4Factory factory,
                       java.util.zip.Checksum checksum)

Creates a new customizable LZ4 decoder.

参数:

factory - user customizable LZ4Factory instance which may be JNI bindings to the original C implementation, a pure Java implementation or a Java implementation that uses the Unsafe

checksum - the Checksum instance to use to check data for integrity. You may set null if you do not want to validate checksum of each block

方法详细资料

decode

protected void decode(ChannelHandlerContext ctx,
                      ByteBuf in,
                      java.util.List<java.lang.Object> out)
               throws java.lang.Exception

从类复制的说明: ByteToMessageDecoder

Decode the from one 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 to

in - the ByteBuf from which to read data

out - the List to which decoded messages should be added

抛出:

java.lang.Exception - is thrown if an error occurs

isClosed

public boolean isClosed()

Returns true if and only if the end of the compressed stream has been reached.