public class ObjectDecoder extends LengthFieldBasedFrameDecoder
ByteBuf
s into Java
objects.
Please note that the serialized form this decoder expects is not
compatible with the standard ObjectOutputStream
. Please use
ObjectEncoder
or ObjectEncoderOutputStream
to ensure the
interoperability with this decoder.
ByteToMessageDecoder.Cumulator
ChannelHandler.Sharable, ChannelHandler.Skip
COMPOSITE_CUMULATOR, MERGE_CUMULATOR
Constructor and Description |
---|
ObjectDecoder(ClassResolver classResolver)
Creates a new decoder whose maximum object size is
1048576
bytes. |
ObjectDecoder(int maxObjectSize,
ClassResolver classResolver)
Creates a new decoder with the specified maximum object size.
|
Modifier and Type | Method and Description |
---|---|
protected 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, handlerRemoved, handlerRemoved0, internalBuffer, isSingleDecode, setCumulator, setSingleDecode
bind, channelActive, channelRegistered, channelUnregistered, channelWritabilityChanged, close, connect, deregister, disconnect, exceptionCaught, flush, handlerAdded, isSharable, read, userEventTriggered, write
public ObjectDecoder(ClassResolver classResolver)
1048576
bytes. If the size of the received object is greater than
1048576
bytes, a StreamCorruptedException
will be
raised.classResolver
- the ClassResolver
to use for this decoderpublic ObjectDecoder(int maxObjectSize, ClassResolver classResolver)
maxObjectSize
- the maximum byte length of the serialized object.
if the length of the received object is greater
than this value, StreamCorruptedException
will be raised.classResolver
- the ClassResolver
which will load the class
of the serialized objectprotected Object decode(ChannelHandlerContext ctx, ByteBuf in) throws Exception
LengthFieldBasedFrameDecoder
ByteBuf
and return it.decode
in class 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.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.
extractFrame
in class LengthFieldBasedFrameDecoder
Copyright © 2008–2015 The Netty Project. All rights reserved.