mina 的自定义编码和解码

Question

最近在用mina写一个通讯，需要将客户端发送的数据进行编码和解码处理。协议是这样的有包头+包数据，包头的长度是固定的，客户端发送的数据是十六进制的编码，现在的问题是怎么用mina写一个自定义的编码和解码器对客户端发送的十六进制的数据进行编码和解码处理。网上看了很多列子大概知道一些，貌似知道一点 ，编码这边是主要实现ProtocolEncoderAdapter类的encode方法 解码那边主要实现CumulativeProtocolDecoder类的doDecode方法，具体的还是有很多不熟悉（比如IoBuffer类）。求解答。

Answer 1

/**
     * decode package :
     *        lengthFieldLength:1，2 ，4(byte)
     *
     * Implement this method to consume the specified cumulative buffer and
     * decode its content into message(s).
     *
     * @param in the cumulative buffer
     * @return <tt>true</tt> if and only if there's more to decode in the buffer
     *         and you want to have <tt>doDecode</tt> method invoked again.
     *         Return <tt>false</tt> if remaining data is not enough to decode,
     *         then this method will be invoked again when more data is cumulated.
     * @throws Exception if cannot decode <tt>in</tt>.
     *
     * 数据包解析
     */
    @Override
    protected boolean doDecode(IoSession session, IoBuffer in, ProtocolDecoderOutput out) throws Exception {
        //not enough  data will be return false
        if (!(in.prefixedDataAvailable(MServerConfig.lengthFieldLength,maxObjectSize))){
            return false;
        }
        //now let's decode message to the  IoBuffer;
        // mark <= position <= limit <= capacity
        // if remaining data is not enough to decode （value:MServerConfig.lengthFieldLength=2）;
//        if (in.remaining()< MServerConfig.lengthFieldLength){
//            return false;
//        }
        int packLength=in.getUnsignedShort();//get pack length ,increments the position by two
        //the dataLength is not enough to decode
        if (in.remaining()<packLength){
            return false;
        }
        byte[]packMessage=new byte[packLength];
        in.get(packMessage);
        //warp byte array to IoBuffer ,add to the messageQueue
        out.write(IoBuffer.wrap(packMessage));
        out.flush(session.getFilterChain().getNextFilter("protocolCodecFilter"),session);//Flushes all messages to the NextFilter---->executors logic
        return true;  //decode ok
    }

大致做了下面的事情：1.检查数据是否够长（1，2，4）字节---->包长；2.获取长度（固定长度）；3.轮询读取数据，封装为Iobuffer;4.调用处理链中下一个处理逻辑；5.注意Iobuffer和java nio中的bytebuffer是一样的，只是封装上便于操作方便罢了，同时有些和bytebuffer不同，熟悉下api就可以上手的； 有问题留言！