io.netty.handler.codec.compression

类 Lz4FrameEncoder

java.lang.Object

io.netty.channel.ChannelHandlerAdapter

io.netty.channel.ChannelOutboundHandlerAdapter

io.netty.handler.codec.MessageToByteEncoder<ByteBuf>

io.netty.handler.codec.compression.Lz4FrameEncoder

所有已实现的接口:

ChannelHandler, ChannelOutboundHandler

public class Lz4FrameEncoder
extends MessageToByteEncoder<ByteBuf>

Compresses a ByteBuf using 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.channel.ChannelHandler

ChannelHandler.Sharable

构造器概要

构造器

构造器和说明
Lz4FrameEncoder() Creates the fastest LZ4 encoder with default block size (64 KB) and xxhash hashing for Java, based on Yann Collet's work available at Github.
Lz4FrameEncoder(boolean highCompressor) Creates a new LZ4 encoder with hight or fast compression, default block size (64 KB) and xxhash hashing for Java, based on Yann Collet's work available at Github.
Lz4FrameEncoder(LZ4Factory factory, boolean highCompressor, int blockSize, java.util.zip.Checksum checksum) Creates a new customizable LZ4 encoder.
Lz4FrameEncoder(LZ4Factory factory, boolean highCompressor, int blockSize, java.util.zip.Checksum checksum, int maxEncodeSize) Creates a new customizable LZ4 encoder.

方法概要

限定符和类型	方法和说明
protected ByteBuf	allocateBuffer(ChannelHandlerContext ctx, ByteBuf msg, boolean preferDirect) Allocate a ByteBuf which will be used as argument of #encode(ChannelHandlerContext, I, ByteBuf).
ChannelFuture	close() Close this Lz4FrameEncoder and so finish the encoding.
void	close(ChannelHandlerContext ctx, ChannelPromise promise) Calls ChannelOutboundInvoker.close(ChannelPromise) to forward to the next ChannelOutboundHandler in the ChannelPipeline.
ChannelFuture	close(ChannelPromise promise) Close this Lz4FrameEncoder and so finish the encoding.
protected void	encode(ChannelHandlerContext ctx, ByteBuf in, ByteBuf out) Encode a message into a ByteBuf.
void	flush(ChannelHandlerContext ctx) Calls ChannelHandlerContext.flush() to forward to the next ChannelOutboundHandler in the ChannelPipeline.
void	handlerAdded(ChannelHandlerContext ctx) Do nothing by default, sub-classes may override this method.
void	handlerRemoved(ChannelHandlerContext ctx) Do nothing by default, sub-classes may override this method.
boolean	isClosed() Returns true if and only if the compressed stream has been finished.

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

acceptOutboundMessage, isPreferDirect, write

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

bind, connect, deregister, disconnect, read

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

ensureNotSharable, exceptionCaught, isSharable

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

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

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

exceptionCaught

构造器详细资料

Lz4FrameEncoder

public Lz4FrameEncoder()

Creates the fastest LZ4 encoder with default block size (64 KB) and xxhash hashing for Java, based on Yann Collet's work available at Github.

Lz4FrameEncoder

public Lz4FrameEncoder(boolean highCompressor)

Creates a new LZ4 encoder with hight or fast compression, default block size (64 KB) and xxhash hashing for Java, based on Yann Collet's work available at Github.

参数:

highCompressor - if true codec will use compressor which requires more memory and is slower but compresses more efficiently

Lz4FrameEncoder

public Lz4FrameEncoder(LZ4Factory factory,
                       boolean highCompressor,
                       int blockSize,
                       java.util.zip.Checksum checksum)

Creates a new customizable LZ4 encoder.

参数:

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

highCompressor - if true codec will use compressor which requires more memory and is slower but compresses more efficiently

blockSize - the maximum number of bytes to try to compress at once, must be >= 64 and <= 32 M

checksum - the Checksum instance to use to check data for integrity

Lz4FrameEncoder

public Lz4FrameEncoder(LZ4Factory factory,
                       boolean highCompressor,
                       int blockSize,
                       java.util.zip.Checksum checksum,
                       int maxEncodeSize)

Creates a new customizable LZ4 encoder.

参数:

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

highCompressor - if true codec will use compressor which requires more memory and is slower but compresses more efficiently

blockSize - the maximum number of bytes to try to compress at once, must be >= 64 and <= 32 M

checksum - the Checksum instance to use to check data for integrity

maxEncodeSize - the maximum size for an encode (compressed) buffer

方法详细资料

allocateBuffer

protected ByteBuf allocateBuffer(ChannelHandlerContext ctx,
                                 ByteBuf msg,
                                 boolean preferDirect)

从类复制的说明: MessageToByteEncoder

Allocate a ByteBuf which will be used as argument of #encode(ChannelHandlerContext, I, ByteBuf). Sub-classes may override this method to return ByteBuf with a perfect matching initialCapacity.

覆盖:

allocateBuffer 在类中 MessageToByteEncoder<ByteBuf>

encode

protected void encode(ChannelHandlerContext ctx,
                      ByteBuf in,
                      ByteBuf out)
               throws java.lang.Exception

Encode a message into a ByteBuf. This method will be called for each written message that can be handled by this encoder. Encodes the input buffer into blockSize chunks in the output buffer. Data is only compressed and written once we hit the blockSize; else, it is copied into the backing buffer to await more data.

指定者:

encode 在类中 MessageToByteEncoder<ByteBuf>

参数:

ctx - the ChannelHandlerContext which this MessageToByteEncoder belongs to

in - the message to encode

out - the ByteBuf into which the encoded message will be written

抛出:

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

flush

public void flush(ChannelHandlerContext ctx)
           throws java.lang.Exception

从类复制的说明: ChannelOutboundHandlerAdapter

Calls ChannelHandlerContext.flush() to forward to the next ChannelOutboundHandler in the ChannelPipeline. Sub-classes may override this method to change behavior.

指定者:

flush 在接口中 ChannelOutboundHandler

覆盖:

flush 在类中 ChannelOutboundHandlerAdapter

参数:

ctx - the ChannelHandlerContext for which the flush operation is made

抛出:

java.lang.Exception - thrown if an error occurs

isClosed

public boolean isClosed()

Returns true if and only if the compressed stream has been finished.

close

public ChannelFuture close()

Close this Lz4FrameEncoder and so finish the encoding. The returned ChannelFuture will be notified once the operation completes.

close

public ChannelFuture close(ChannelPromise promise)

Close this Lz4FrameEncoder and so finish the encoding. The given ChannelFuture will be notified once the operation completes and will also be returned.

close

public void close(ChannelHandlerContext ctx,
                  ChannelPromise promise)
           throws java.lang.Exception

从类复制的说明: ChannelOutboundHandlerAdapter

Calls ChannelOutboundInvoker.close(ChannelPromise) to forward to the next ChannelOutboundHandler in the ChannelPipeline. Sub-classes may override this method to change behavior.

指定者:

close 在接口中 ChannelOutboundHandler

覆盖:

close 在类中 ChannelOutboundHandlerAdapter

参数:

ctx - the ChannelHandlerContext for which the close operation is made

promise - the ChannelPromise to notify once the operation completes

抛出:

java.lang.Exception - thrown if an error occurs

handlerAdded

public void handlerAdded(ChannelHandlerContext ctx)

从类复制的说明: ChannelHandlerAdapter

Do nothing by default, sub-classes may override this method.

指定者:

handlerAdded 在接口中 ChannelHandler

覆盖:

handlerAdded 在类中 ChannelHandlerAdapter

handlerRemoved

public void handlerRemoved(ChannelHandlerContext ctx)
                    throws java.lang.Exception

从类复制的说明: ChannelHandlerAdapter

Do nothing by default, sub-classes may override this method.

指定者:

handlerRemoved 在接口中 ChannelHandler

覆盖:

handlerRemoved 在类中 ChannelHandlerAdapter

抛出:

java.lang.Exception