mina通信库解决分包粘包时解包用CumulativeProtocolDecoder

https://www.cnblogs.com/tankaixiong/archive/2013/03/18/2965527.html

public class FrameDecoder extends CumulativeProtocolDecoder {@Overrideprotected boolean doDecode(IoSession ioSession, IoBuffer ioBuffer, ProtocolDecoderOutput protocolDecoderOutput) throws Exception {if (ioBuffer.remaining() >= 12) {ioBuffer.mark();byte[] heads = new byte[12];ioBuffer.get(heads);EBean eBean = new EBean();eBean.cmdCode = ByteArrayKt.getInt(heads, 0, false);eBean.ext = ByteArrayKt.getInt(heads, 4, false);eBean.bodyLength = ByteArrayKt.getInt(heads, 8, false);if (eBean.bodyLength > ioBuffer.remaining()) {//如果消息内容不够，则重置，相当于不读取sizeioBuffer.reset();return false;//接收新数据，以拼凑成完整数据} else {if(eBean.bodyLength>0) {byte[] bytes = new byte[eBean.bodyLength];ioBuffer.get(bytes, 0, eBean.bodyLength);if (16 != eBean.cmdCode) {Log.d("解码数据", "doDecode: bodyLength=" + eBean.bodyLength + " len=" + bytes.length);}String s = new String(bytes, 0, eBean.bodyLength);eBean.body = s;}if (16 != eBean.cmdCode) {Log.d("TAG", "doDecode: eBean = " + eBean.toStr());}protocolDecoderOutput.write(eBean);if (ioBuffer.remaining() > 0) {return true;}}}return false;}
}

和netty里自动分包扩展差不多