分享一个自己在用的apache mina的解码器decoder源码

import org.apache.mina.core.buffer.IoBuffer;
import org.apache.mina.core.session.IoSession;
import org.apache.mina.filter.codec.CumulativeProtocolDecoder;
import org.apache.mina.filter.codec.ProtocolDecoderOutput;

/**
* 序号 A B C D E
* 参数名 帧头 包长 数据包内容 CRC 校验 帧尾
* 类型 BYTE BYTE BYTE BYTE BYTE
* 字节数 2 2 N 2 2
* 标志符 0xAA 0xAA 1 7 2 0xEE 0xEE
*
*/
public class MsgServerDecoder extends CumulativeProtocolDecoder {

@Override
protected boolean doDecode(IoSession session, IoBuffer in,
ProtocolDecoderOutput out) throws Exception {

if(in.remaining() >= 4){
//缓冲区长度足够截取到协议中的包长度字节
//标记位置
in.mark();
//截取包头
byte[] msgHeader = new byte[2];
in.get(msgHeader);
//截取消息长度
byte[] msgLen = new byte[2];
in.get(msgLen);
int len = Integer.parseInt(((int)msgLen[1]&0xff)+""+((int)msgLen[0]&0xff));
if(in.remaining()<len+4){
//报文完整性不够
in.reset();
return false;
}else{
//解析报文
//TODO 此处即可根据协议将完整的报文解析成消息对象
out.write(msg);//msg即是解析完成的消息对象
return true;
}
}

return false;
}

}