在Netty中发送字节数组

我正在使用LengthFieldBasedFrameDecoder发送和接收功能，byte[]但是客户端java.nio.channels.ClosedChannelException在写入后会出错。

这是管道工厂；

@Override
public ChannelPipeline getPipeline() throws Exception {

    String charSet = EvamProperties.charSet.get();
    ChannelPipeline pipeline = Channels.pipeline();

    pipeline.addLast("framer", new LengthFieldBasedFrameDecoder(1000000,0,4,0,4));//16KB
    pipeline.addLast("decoder", new OneToOneDecoder() {
        @Override
        protected Object decode(ChannelHandlerContext channelHandlerContext, Channel channel, Object o) throws Exception {

            if (!(o instanceof ChannelBuffer)) {
                return o;
            }

            ChannelBuffer buffer = (ChannelBuffer) o;

            int length = buffer.readInt();
            byte[] bytes = new byte[length];
            buffer.readBytes(bytes);

            return bytes;
        }
    });
    pipeline.addLast("encoder", new OneToOneEncoder() {
        @Override
        protected Object encode(ChannelHandlerContext channelHandlerContext, Channel channel, Object o) throws Exception {

            if(!(o instanceof byte[])) {
                return o;
            }

            ChannelBuffer buffer = ChannelBuffers.dynamicBuffer();
            buffer.writeInt(((byte[]) o).length);
            buffer.writeBytes((byte[])o);

            return buffer;
        }
    });
    pipeline.addLast("handler", new RawEventServerHandler());
    return pipeline;

}

客户以这种方式编写；

channel.write(eventStr.getBytes());

在此代码中，出于调试目的，要发送的数据是String，但我不能使用StringDecoder。

请问LenghtFieldBasedDecoder是正确的发送和接收方法byte[]，如果没有，我该怎么办？

编辑：

我发现实际上关闭了该通道的另一个线程java.nio.channels.ClosedChannelException已解决，但是我仍然渴望学习此类工作的最佳实践。