mina粘包、多包和少包的解决方法

使用过mina的同学应该都遇到到过，在解码时少包、多包的问题，查阅了很多资料还是迷迷糊糊的，经过不懈努力，终于解决了。原来解决方法是那样的简单。废话少说，请看列子。
 
  另外建了一个交流群：19702042，大家可以在线交流

  问题：我发送的是xml字符串数据，在发送数据后，接收方在解码的时候可能接到1条，也可能是多条，还可能是半条或一条半，解决方法就是使用CumulativeProtocolDecoder
   首先，在编码的时候要把前4位设成标志位，标志消息内容的长度。里面的重点是doDecode的返回值，一定要继承CumulativeProtocolDecoder 哦。

清看decode的写法：

public class AsResponseDecoder extends CumulativeProtocolDecoder {   
    private static Logger LOG = LoggerFactory.getLogger(AsResponseDecoder.class);   
    private final Charset charset;   
       
    public AsResponseDecoder(Charset charset){   
        this.charset = charset;   
    }   
       
  
    /**  
     * 这个方法的返回值是重点：  
     * 1、当内容刚好时，返回false，告知父类接收下一批内容  
     * 2、内容不够时需要下一批发过来的内容，此时返回false，这样父类  
 
CumulativeProtocolDecoder  
     *    会将内容放进IoSession中，等下次来数据后就自动拼装再交给本类的doDecode  
     * 3、当内容多时，返回true，因为需要再将本批数据进行读取，父类会将剩余的数据再次推送本  
 
类的doDecode  
     */  
    public boolean doDecode(IoSession session, IoBuffer in,   
            ProtocolDecoderOutput out) throws Exception {   
           
        CharsetDecoder cd = charset.newDecoder();   
        if(in.remaining() > 0){//有数据时，读取4字节判断消息长度   
            byte [] sizeBytes = new byte[4];   
            in.mark();//标记当前位置，以便reset   
            in.get(sizeBytes);//读取前4字节   
                        //NumberUtil是自己写的一个int转byte[]的一个工具类   
            int size = NumberUtil.byteArrayToInt(sizeBytes);   
            //如果消息内容的长度不够则直接返回true   
            if(size > in.remaining()){//如果消息内容不够，则重置，相当于不读取size   
                in.reset();   
                return false;//接收新数据，以拼凑成完整数据   
            } else{   
                byte[] bytes = new byte[size];    
                in.get(bytes, 0, size);   
                String xmlStr = new String(bytes,"UTF-8");   
                System.out.println("------------"+xmlStr);   
                if(null != xmlStr && xmlStr.length() > 0){   
                    AsResponse resCmd = new AsResponse();   
                    AsXmlPacker.parse(resCmd, xmlStr);   
                    if(resCmd != null){   
                        out.write(resCmd);   
                    }   
                }   
                if(in.remaining() > 0){//如果读取内容后还粘了包，就让父类再给俺   
  
一次，进行下一次解析   
                    return true;   
                }   
            }   
        }   
        return false;//处理成功，让父类进行接收下个包   
    }   
 }  

下面附上Encode类

public class AsResponseEncoder extends ProtocolEncoderAdapter {   
    private final Charset charset;   
       
    public AsResponseEncoder(Charset charset){   
        this.charset = charset;   
    }   
       
    public void encode(IoSession session, Object message,   
        ProtocolEncoderOutput out) throws Exception {   
        CharsetEncoder ce = charset.newEncoder();   
        IoBuffer buffer = IoBuffer.allocate(100).setAutoExpand(true);   
           
        AsResponse respCmd = (AsResponse) message;   
           
        String xml = AsXmlPacker.pack(respCmd);//将对象转成xml   
        byte[] bytes = xml.getBytes();   
        byte[] sizeBytes = NumberUtil.intToByteArray(bytes.length);   
           
        buffer.put(sizeBytes);//将前4位设置成数据体的字节长度   
        buffer.put(bytes);//消息内容   
        buffer.flip();   
        out.write(buffer);   
    }   
}  

Mark	上次position的快照
Position	当前读写索引未知
Limit	缓冲区限制
Capacity	缓冲区能力
Offset	偏移量

说明：
Position(Mark)<=limit<=capacity
当position==limit时就没有字节可读写了
每次get或put都将增加position
重置mark就是设置mark=-1


方法：

Limit(int)	如果position>limit, position = limit,如果mark>limit, 重置mark
Mark()	取当前的position的快照标记mark
Reset()	恢复position到先前标记的mark
Clear()	limit=capacity , position=0,重置mark,但是不清空数据，为了从头开始put做准备，其实就是清空数据，因为你put就覆盖了原来的数据
Rewind()	position=0,重置mark,一系列写操作后，为了从头开始get做准备，和clear()有用途上的区别，他大部分是用来从头开始读取，而clear是大部分用来重头开始填充，就是清理的意思
Flip()	limit=position , position=0,重置mask，为了将buf写出做好准备，一般是结束buf操作，将buf写入输出流时调用，这个必须要调用，否则极有可能position!=limit，导致position后面没有数据，每次写入数据到输出流时，必须确保position=limit。
Remaining()	返回limit-position,返回缓冲器中的剩余字节
Wrap(byte[])	组装到新的buffer，capacity=limit=byte[].length，position=0 重置mark
Slice()	分割缓冲器，将remaining的空间形成一个新的buffer，新的position=0，limit=capacity=remaining，重置mark，和主缓冲区内容共享，其它都独立
Duplicate()	复制缓冲区，内容共享，其它都独立
asReadOnlyBuffer()	和duplicate一样，只是不可写
Compact()	将position和limit之间的字节移到最前面，position=limit-position，这就是这里的压缩的意思，一般是结束buf操作，将buf写入输出流时调用
Position(int)	position=newPosition,如果position<mark,重置mark
Remaining()	返回position和limit之间的字节数

	JDK ByteBuffer	Mina IoBuffer
动态扩展capacity	否	是
支持String读写	否	是
线程安全	否	否
可主动释放缓冲区占用内存	否	是

评论

1 楼 zfms 2012-05-30  

NumberUtil.byteArrayToInt  这个方法能否提供下源码，谢谢