com.baidu.brpc.compress

Class SnappyCompress

java.lang.Object

com.baidu.brpc.compress.SnappyCompress

All Implemented Interfaces:

Compress

public class SnappyCompress
extends Object
implements Compress

Constructor Summary

Constructors

Constructor and Description
SnappyCompress()

Method Summary

Modifier and Type	Method and Description
io.netty.buffer.ByteBuf	compressInput(Object proto, RpcMethodInfo rpcMethodInfo) client端encode request并压缩
io.netty.buffer.ByteBuf	compressOutput(Object proto, RpcMethodInfo rpcMethodInfo) server序列化response并压缩
Object	uncompressInput(byte[] bytes, RpcMethodInfo rpcMethodInfo)
Object	uncompressInput(io.netty.buffer.ByteBuf byteBuf, RpcMethodInfo rpcMethodInfo) server端解压缩并decode request
Object	uncompressInput(DynamicCompositeByteBuf byteBuf, RpcMethodInfo rpcMethodInfo)
Object	uncompressOutput(byte[] bytes, RpcMethodInfo rpcMethodInfo)
Object	uncompressOutput(io.netty.buffer.ByteBuf byteBuf, RpcMethodInfo rpcMethodInfo) client端解压缩并反序列化response
Object	uncompressOutput(DynamicCompositeByteBuf byteBuf, RpcMethodInfo rpcMethodInfo)

Methods inherited from class java.lang.Object

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

Constructor Detail

SnappyCompress

public SnappyCompress()

Method Detail

compressInput

public io.netty.buffer.ByteBuf compressInput(Object proto,
                                             RpcMethodInfo rpcMethodInfo)
                                      throws IOException

Description copied from interface: Compress

client端encode request并压缩

Specified by:

compressInput in interface Compress

Parameters:

proto - request

rpcMethodInfo - rpc method信息

Returns:

序列化后buf

Throws:

IOException - 序列化失败

uncompressOutput

public Object uncompressOutput(io.netty.buffer.ByteBuf byteBuf,
                               RpcMethodInfo rpcMethodInfo)
                        throws IOException

Description copied from interface: Compress

client端解压缩并反序列化response

Specified by:

uncompressOutput in interface Compress

Parameters:

byteBuf - response buffer

rpcMethodInfo - rpc method信息

Returns:

response对象

Throws:

IOException - 反序列化失败

uncompressOutput

public Object uncompressOutput(byte[] bytes,
                               RpcMethodInfo rpcMethodInfo)
                        throws IOException

Specified by:

uncompressOutput in interface Compress

Throws:

IOException

uncompressOutput

public Object uncompressOutput(DynamicCompositeByteBuf byteBuf,
                               RpcMethodInfo rpcMethodInfo)
                        throws IOException

Specified by:

uncompressOutput in interface Compress

Throws:

IOException

uncompressInput

public Object uncompressInput(io.netty.buffer.ByteBuf byteBuf,
                              RpcMethodInfo rpcMethodInfo)
                       throws IOException

Description copied from interface: Compress

server端解压缩并decode request

Specified by:

uncompressInput in interface Compress

Parameters:

byteBuf - request buffer

rpcMethodInfo - rpc method信息

Returns:

请求对象

Throws:

IOException - 反序列化失败

uncompressInput

public Object uncompressInput(byte[] bytes,
                              RpcMethodInfo rpcMethodInfo)
                       throws IOException

Specified by:

uncompressInput in interface Compress

Throws:

IOException

uncompressInput

public Object uncompressInput(DynamicCompositeByteBuf byteBuf,
                              RpcMethodInfo rpcMethodInfo)
                       throws IOException

Specified by:

uncompressInput in interface Compress

Throws:

IOException

compressOutput

public io.netty.buffer.ByteBuf compressOutput(Object proto,
                                              RpcMethodInfo rpcMethodInfo)
                                       throws IOException

Description copied from interface: Compress

server序列化response并压缩

Specified by:

compressOutput in interface Compress

Parameters:

proto - response对象

rpcMethodInfo - rpc method信息

Returns:

序列化buffer

Throws:

IOException - 序列化异常