public class MarshallingDecoder extends LengthFieldBasedFrameDecoder
MarshallingEncoder
.
A LengthFieldBasedFrameDecoder
which use an Unmarshaller
to read the Object out
of the ByteBuf
.ByteToMessageDecoder.Cumulator
ChannelHandler.Sharable
COMPOSITE_CUMULATOR, MERGE_CUMULATOR
构造器和说明 |
---|
MarshallingDecoder(UnmarshallerProvider provider)
Creates a new decoder whose maximum object size is
1048576
bytes. |
MarshallingDecoder(UnmarshallerProvider provider,
int maxObjectSize)
Creates a new decoder with the specified maximum object size.
|
限定符和类型 | 方法和说明 |
---|---|
protected java.lang.Object |
decode(ChannelHandlerContext ctx,
ByteBuf in)
Create a frame out of the
ByteBuf and return it. |
protected ByteBuf |
extractFrame(ChannelHandlerContext ctx,
ByteBuf buffer,
int index,
int length)
Extract the sub-region of the specified buffer.
|
decode, getUnadjustedFrameLength
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 MarshallingDecoder(UnmarshallerProvider provider)
1048576
bytes. If the size of the received object is greater than
1048576
bytes, a StreamCorruptedException
will be
raised.public MarshallingDecoder(UnmarshallerProvider provider, int maxObjectSize)
maxObjectSize
- the maximum byte length of the serialized object.
if the length of the received object is greater
than this value, TooLongFrameException
will be raised.protected java.lang.Object decode(ChannelHandlerContext ctx, ByteBuf in) throws java.lang.Exception
LengthFieldBasedFrameDecoder
ByteBuf
and return it.decode
在类中 LengthFieldBasedFrameDecoder
ctx
- the ChannelHandlerContext
which this ByteToMessageDecoder
belongs toin
- the ByteBuf
from which to read dataByteBuf
which represent the frame or null
if no frame could
be created.java.lang.Exception
protected ByteBuf extractFrame(ChannelHandlerContext ctx, ByteBuf buffer, int index, int length)
LengthFieldBasedFrameDecoder
If you are sure that the frame and its content are not accessed after
the current LengthFieldBasedFrameDecoder.decode(ChannelHandlerContext, ByteBuf)
call returns, you can even avoid memory copy by returning the sliced
sub-region (i.e. return buffer.slice(index, length)).
It's often useful when you convert the extracted frame into an object.
Refer to the source code of ObjectDecoder
to see how this method
is overridden to avoid memory copy.