Mina自定义编解码

Mina初了自己定义的字符编码外，用户还可以根据自己的协议自定义编解码。由于mina是基于IoFilter，也就是通过IoFilter拦截和过滤IO中的各种信息。因此对于编码而言，也就是我们把信息通过mina进行传递前，必须要根据相关的传输协议对我们传输的信息进行编码，编码后会把编码的信息通过mina进行传递。可以把编码理解为mina进行数据传输前IoFilter的最后一项处理。对于解码来说，是mina得到数据后的首次处理。即IoFilter后的首次数据处理。

自定义编码在mina中的引用代码一般如下：

DefaultIoFilterChainBuilder filterChain = connector.getFilterChain();

ProtocolCodecFilter filter = new ProtocolCodecFilter(new TianhuiEncoder(), new TianhuiCumulativeHandler());

filterChain.addLast("codec", filter);

1.自定义编码

自定义编码类 TianhuiEncoder.java 需要继承 ProtocolEncoderAdapter.java ，覆盖ProtocolEncoderAdapter.java类的encode(IoSession session,Object obj,ProtocolEncoderOuput o)方法。主要实现步骤是：

A． 把对象obj根据协议转换为byte[] rst数组。

B． 通过ProtocolEncoderOuput把byte输出出去。即：o.write(IoBuffer.wrap(rst));

实例编码：

编码的协议如下：

现在编码“定位申请”。

从协议上看，定位申请一共有22byte。$dwsq为5byte，长度1byte，用户地址为3byte，信息内容为12byte，校验和为1byte。因此需要：

byte[] rst = new byte[22];

主要的编码方法如下：

public byte[] encode(){

byte[] rst = new byte[22];

TianHuiMessageUtil.setHeader(rst, getType(), userid, (long) 22);

rst[10]=4;//信息类别

TianHuiMessageUtil.genCheckNum(rst);

return rst;

}

其中sentHeader方法如下：

public static void setHeader(byte[] rst, TH_MSGTYPE thMsgType, long userid, long length) {

rst[0] = (byte) 36;//$字符

ByteUtils.setBytes(rst, TH_MSGTYPE.getType(thMsgType).getBytes(), 1);//DWSQ字符

ByteUtils.setLong(length, rst, 5, 2);//根据协议，代表的为长度，从第5位开始，共2byte。

ByteUtils.setLong(userid, rst, 7, 3);//和上面一样，用户地址，从第七位开始，共3byte。

}

其中setBytes方法如下：

public static void setBytes(byte[] dst, byte[] src, int start) {

if (src == null || src.length == 0){ return;}

for (int i = 0, n = src.length; i < n; i++){

dst[start + i] = src[i];

}

}

其中setLong方法如下：

public static void setLong(long value, byte[] data, int index, int length) {

for (int i = length - 1; i >= 0; i--, value = value >> 8){

data[index + i] = (byte) (value & 0xFF);

}

}

其中genCheckNum方法是计算校验和进行添加。方法如下：

public static void genCheckNum(byte[] data) {

byte tmp = 36;

for (int i = 1, n = data.length - 1; i < n; i++)

tmp ^= data[i];

data[data.length - 1] = tmp;

}

2.自定义解码

自定义解码类为TianhuiCumulativeHandler.java，此类继承mina的CumulativeProtocolDecoder.java类，覆盖boolean doDecode(IoSession session, IoBuffer in, ProtocolDecoderOutput out)方法。主要的实现是根据协议对信息进行验证。对验证通过返回true，验证失败舍弃信息。

实例编码：

解码协议：

方法doDecode的主要实现如下所示：

@Override

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

{

return  handle(session, in, out);

}

其中handle是主要的实现方法， 主要实现如下：

public boolean handle(IoSession session, IoBuffer in, ProtocolDecoderOutput out) throws Exception{

int start = in.position();

LOGGER.info("recv:" + in.getHexDump());

while (in.hasRemaining())

{

byte first = in.get();

if (first == (byte) 36 && in.remaining() > 7)

{

int messageStart = in.position();

byte[] header = new byte[6];

in.get(header);

int msgLength = (int) ByteUtils.getValue(header, 4, 2);

if (in.remaining() >= msgLength - 7 && msgLength < 500)

{

in.position(start);

byte[] bs = new byte[msgLength];

in.get(bs);

if (check(bs))

{

out.write(bs);

return in.remaining() > 0;

}

else in.position(messageStart);

}

else in.position(messageStart);

}

}

in.position(start);

return false;

}

public boolean check(byte[] data) {

if (data.length < 2){

return false;

}

byte tmp = 36;

for (int i = 1, n = data.length - 1; i < n; i++)

tmp ^= data[i];

return data[data.length - 1] == tmp;

}

对于解码来说，主要的作用是解析成所要的对象。如下所示，把byte[] rst根据协议解析为位置定位对象。

public AbsThMessage build(byte[] raw){

userId = ByteUtils.getValue(raw, 7, 3);

dstUserId = ByteUtils.getValue(raw, 11, 3);

JDateTime tmptime = new JDateTime();

tmptime.setHour(raw[14]);

tmptime.setMinute(raw[15]);

tmptime.setSecond(raw[16]);

time=tmptime.convertToDate();

lati=raw[18]+raw[19]/60.0+raw[20]/3600.0+raw[21]/36000.0;

longi=raw[22]+raw[23]/60.0+raw[24]/3600.0+raw[25]/36000.0;

h=(((raw[26]>>6)==0)?1:-1)+((63&raw[26])<<8)+raw[27];

return this;

}

其中getValue方法如下：

public static long getValue(byte[] data, int index, int length) {

long result = 0;

for (int i = 0; i < length; i++)

{

result = result << 8;

result += (data[index + i] & 0xFF);

}

return result;

}

3.对于mina编解码来说，总的就是根据协议，在信息发送之前进行编码，在信息接收到后进行验证，解码。