netty多线程通信一次传输较大数据遇到的问题

Question

您好，刚入门netty，想请教大神们几个问题，对于只有一个线程一次传输过大的数据，通过这个方法解决了：传输时头4个字节保存数据大小，后面保存内容，接收时如果发现读取的数据长度不够，则累积到下一次读取，最后得到的message则为需要的数据。部分代码如下：
发送消息：
public static void sendMsg(ChannelHandlerContext ctx,byte[] bytes){
ByteBuf buf = ctx.alloc().buffer();
buf.writeInt(bytes.length);
buf.writeBytes(bytes);
ctx.writeAndFlush(buf);
}
接收消息：
public class Decoder extends ByteToMessageDecoder {
@Override
protected void decode(ChannelHandlerContext ctx, ByteBuf buf, List out) throws Exception {
if (buf.readableBytes()<buf.getInt(buf.readerIndex())){
return;
}
out.add(buf.readBytes(buf.readableBytes()));
}
}
现在我有个情景是，在传输数据时是多线程的，同一个时间会多次调用ctx.writeAndFlush方法发送数据（多线程使用的是同一个ctx对象），每次发送的数据也是比较大的数据，在接收的时候，是否会出现数据混乱的情况（一次传输数据过大，会多次调用decode方法，多线程环境下是否会出现问题？），我开50个线程测试时发现if (buf.readableBytes()<buf.getInt(buf.readerIndex()))这句代码报数组越位的异常，请问有什么好的解决办法吗，感谢！

Answer 1

参考：

http://yx200404.iteye.com/blog/1337245