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| 构造器和说明 |
|---|
ByteArrayDecoder() |
| 限定符和类型 | 方法和说明 |
|---|---|
protected void |
decode(ChannelHandlerContext ctx,
ByteBuf msg,
java.util.List<java.lang.Object> out)
Decode from one message to an other.
|
acceptInboundMessage, channelReadchannelActive, channelInactive, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaught, userEventTriggeredensureNotSharable, handlerAdded, handlerRemoved, isSharableclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waithandlerAdded, handlerRemovedprotected void decode(ChannelHandlerContext ctx, ByteBuf msg, java.util.List<java.lang.Object> out) throws java.lang.Exception
MessageToMessageDecoderdecode 在类中 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 occurs