Mina通信粘包处理

使用过Mina做Socket长链接的同学应该都遇到到过，在解码时少包、多包的问题！

1.文本内容发送端需要等缓冲区满才发送出去，造成粘包
2.接收方不及时接收缓冲区的包，造成多个包接收

解决方法就是使用CumulativeProtocolDecoder 解码器，确保在编码的时候要把前4位设成标志位，标志消息内容的长度。
数据包编码和解码一定要单独实现:
编码器 class RequestEncoder implements ProtocolEncoder
解码器 class RequestDecoder extends CumulativeProtocolDecoder

 public class RequestDecoder extends CumulativeProtocolDecoder {

    private String TAG = this.getClass().getName();

    /**
     * 返回值的解释： 
     * 1、false, 继续接收下一批数据，有两种情形，如缓冲区数据刚刚就是一个完整消息，或不够一条消息时。
     * 如果不够一条消息，那么会将下一批数据和剩余消息进行合并
     * 2、true, 当缓冲区的消息多于一条消息时，剩余消息会再会推送至doDecode
     */
    protected boolean doDecode(IoSession session, IoBuffer in,
            ProtocolDecoderOutput out) throws Exception {

        if (in.remaining() < 4) {
            in.reset();
            return false;//继续接收数据，以待数据完整
        }
        
        in.mark();// 标记当前位置，以便reset
        int size = in.getInt();// 读取4字节判断消息长度

        if (in.remaining() < size) {// 如果消息内容不够，则重置，相当于不读取size
            in.reset();
            return false;// 接收新数据，以拼凑成完整数据
        } else {
            decodePacket(session, in, out, size);
        }

        if (in.remaining() > 0) {
            in.mark();
            return true;// 如果读取内容后还粘了包，就让父类再给俺 一次，进行下一次解析
        } else {
            return false;
        }
    }

    private void decodePacket(IoSession session, IoBuffer in,
            ProtocolDecoderOutput out, int size) {
        try {
            byte[] sizeBytes = new byte[size];
            in.get(sizeBytes);
            ResponseData data = ResponseData.parseFrom(sizeBytes);

            Response response = new Response(data.getResId(),
                    data.getResCode(), data.getResData().toByteArray());
            response.setSession(session);
            response.setCallBack(data.getCallback());

            Log.d(TAG, " >> " + response);
            out.write(response);

        } catch (Exception e) {
            Log.d(TAG, "RequestEncoder encode:" + e);
        }
    }
}

---

public class RequestEncoder implements ProtocolEncoder {
    
    private String TAG = this.getClass().getName();
    
    @Override
    public void encode(IoSession session, Object message, ProtocolEncoderOutput out) throws Exception {
        Request request = (Request) message;
        Log.d(TAG, " << " + request);
        RequestData.Builder builder = RequestData.newBuilder();
        if(request.getByteData() != null) {
            builder.setByteData(ByteString.copyFrom(request.getByteData()));
        }
        builder.setReqData(request.getRequestData().toString());
        builder.setReqId(request.getCommandId());
        if (request.getCallBack() != null) {
            builder.setCallback(request.getCallBack());
        }
        byte[] data = builder.build().toByteArray();
        int dataLength = data.length;//int是4个字节32位
        IoBuffer buffer = IoBuffer.allocate(4 + dataLength, false);//数据包长度信息+原始数据大小
        buffer.putInt(dataLength);//先写入int大小的长度信息
        buffer.put(data);//再写入要发送的请求数据
        buffer.flip();
        out.write(buffer);
        buffer.free();
    }
    @Override
    public void dispose(IoSession session) throws Exception {
        
    }
}