Mina 2 编码解码协议 及 已经实现通信的完整代码

使用mina2通信的完整代码朋友们可以去http://download.csdn.net/detail/u013378306/8756861下载

下面只对编解码协议进行解释

package lhy.charest;

import java.nio.ByteOrder;
import java.nio.charset.Charset;


import lhy.client_domain.MsgPack;




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;












/**
 * @see 协议解码
 * @author lhy
 * @date 
 */
public class MsgProtocolDecoder extends CumulativeProtocolDecoder  {  
    private Charset charset=null;  
  
    public MsgProtocolDecoder() {  
        this(Charset.defaultCharset());  
    }  
    
    public MsgProtocolDecoder(Charset charset) {  
        this.charset = charset;  
    }
    


public void dispose(IoSession arg0) throws Exception {

}







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

ioBuffer.order(ByteOrder.LITTLE_ENDIAN); 
MsgPack mp = (MsgPack) session.getAttribute("nac-msg-pack"); // 从session对象中获取“xhs-upload”属性值 
if(null==mp){


if (ioBuffer.remaining() >= 8) {
//取消息体长度
int msgLength = ioBuffer.getInt(); 
int msgMethod = ioBuffer.getInt();
mp=new MsgPack();
mp.setMsgLength(msgLength);
mp.setMsgCode(msgMethod);
session.setAttribute("nac-msg-pack",mp);
return true;
}
return false;
}
//如果tcp缓冲区数据大于上次保存的的，解析消息体
if(ioBuffer.remaining()>=mp.getMsgLength()){
byte [] msgPack=new byte[mp.getMsgLength()];
ioBuffer.get(msgPack);
mp.setMsgPack(new String(msgPack,charset));
session.removeAttribute("nac-msg-pack");
out.write(mp);
return true;
}
return false;
}   

}

package lhy.charest;


import java.io.NotSerializableException;
import java.io.Serializable;
import java.nio.ByteOrder;
import java.nio.charset.Charset;


import lhy.client_domain.MsgPack;




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










/**
 * 自定义编码
 * @author Administrator
 *
 */
public class MsgProtocolEncoder extends ProtocolEncoderAdapter{
private Charset charset=null;


    public MsgProtocolEncoder(Charset charset) {
        this.charset = charset;     
    }     
    //在此处实现对MsgProtocolEncoder包的编码工作，并把它写入输出流中     
    public void encode(IoSession session, Object message, ProtocolEncoderOutput out) throws Exception { 
        if(message instanceof MsgPack){
        MsgPack mp = (MsgPack) message; 
        //第一个参数指定初始化容量，第
        //二个参数指定使用直接缓冲区还是JAVA 内存堆的缓存区，默认为false。
        IoBuffer buf = IoBuffer.allocate(mp.getMsgLength());
        buf.order(ByteOrder.LITTLE_ENDIAN);
        //这个方法设置IoBuffer 为自动扩展容量，也就是前面所说的长度可变，
             buf.setAutoExpand(true);    
             //设置消息内容的长度
             buf.putInt(mp.getMsgLength()); 
             //设置消息的功能函数
             buf.putInt(mp.getMsgCode());
             if (null != mp.getMsgPack()) {
            buf.put(mp.getMsgPack().getBytes(charset));
             }   
             buf.flip();     
             out.write(buf);  
             out.flush();
             buf.free();
        }
    }     
    public void dispose() throws Exception {     
    }
    


}