mian 粘包问题

            里面的重点是doDecode的返回值
这个方法的返回值是重点：
     * 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 = MinaUtil.byteArrayToInt(sizeBytes); 
            //如果消息内容的长度不够则直接返回true 
            if(size > in.remaining()){//如果消息内容不够，则重置，相当于不读取size 
                in.reset(); 
                return false;//接收新数据，以拼凑成完整数据 
            } else{ 
                byte[] bytes = new byte[size];  
                in.get(bytes, 0, size); 
                String content = new String(bytes,"UTF-8"); 
                System.out.println("------------"+content); 
                if(null != content && content.length() > 0){ 
                    //AsResponse resCmd = new AsResponse(); 
                    //AsXmlPacker.parse(resCmd, xmlStr);
                //if(resCmd != null){ 
                    //    out.write(resCmd); 
                    //}
                //转发
                byte[] data = content.getBytes();
    IoBuffer buffer = MinaUtil.byteToIoBuffer(data, data.length);
    out.write(buffer);
                } 
                if(in.remaining() > 0){//如果读取内容后还粘了包，就让父类再给俺  一次，进行下一次解析 
                    return true; 
                } 
            } 
        } 
        return false;//处理成功，让父类进行接收下个包 
    }

评论

2 楼 teasp 2013-07-10  

Mina的教程里面有。

1 楼 asialee 2013-07-09  

楼主写的不错，mina和netty的作者是同一个，我写过一个netty的，http://asialee.iteye.com/blog/1776306