public class ByteArrayDecoder extends MessageToMessageDecoder<ByteBuf>
ByteBuf into an array of bytes.
A typical setup for TCP/IP would be:
and then you can use an array of bytes instead of aChannelPipelinepipeline = ...; // Decoders pipeline.addLast("frameDecoder", newLengthFieldBasedFrameDecoder(1048576, 0, 4, 0, 4)); pipeline.addLast("bytesDecoder", newByteArrayDecoder()); // Encoder pipeline.addLast("frameEncoder", newLengthFieldPrepender(4)); pipeline.addLast("bytesEncoder", newByteArrayEncoder());
ByteBuf
as a message:
void channelRead(ChannelHandlerContext ctx, byte[] bytes) {
...
}
ChannelHandler.Sharable | Constructor and Description |
|---|
ByteArrayDecoder () |
| Modifier and Type | Method and Description |
|---|---|
protected void |
decode (ChannelHandlerContext ctx,
ByteBuf msg,
java.util.List<java.lang.Object> out)
Decode from one message to an other.
|
acceptInboundMessage, channelRead channelActive, channelInactive, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaught, userEventTriggered ensureNotSharable, handlerAdded, handlerRemoved, isSharable clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waithandlerAdded, handlerRemoved public ByteArrayDecoder()
protected void decode(ChannelHandlerContext ctx, ByteBuf msg, java.util.List<java.lang.Object> out) throws java.lang.Exception
MessageToMessageDecoder decode in class MessageToMessageDecoder<ByteBuf>ctx - the ChannelHandlerContext which this MessageToMessageDecoder belongs tomsg - the message to decode to an other oneout - the List to which decoded messages should be addedjava.lang.Exception - is thrown if an error occursCopyright © 2008–2018 The Netty Project. All rights reserved.