msgdecoder.java

apache.mina网络开源框架的例子

package com.yidatone.sms.mina.mccenter.codec;

import org.apache.log4j.Logger;
import org.apache.mina.common.ByteBuffer;
import org.apache.mina.common.IoSession;
import org.apache.mina.filter.codec.ProtocolDecoderOutput;
import org.apache.mina.filter.codec.demux.MessageDecoder;
import org.apache.mina.filter.codec.demux.MessageDecoderResult;

public  class MsgDecoder implements MessageDecoder   //<-----------Common类------------>
{
	Logger logger=Logger.getLogger(getClass());
    public MessageDecoderResult decodable( IoSession session, ByteBuffer in )
    {
    	return MessageDecoderResult.OK;
    }

    public MessageDecoderResult decode( IoSession session, ByteBuffer in, ProtocolDecoderOutput out ) throws Exception
    {
    	byte[] content = new byte[in.limit()];
    	/*
    	InputStream xml = request.getInputStream();
    	String sXML = new String();

		while(sXML!=null)
		{
        	int i =xml.read();
        	char ch = (char)i;
        	if(i == -1)
            	break;
            sXML+=ch;
        }	 
    	*/
    	//logger.info("content.length=="+content.length);
    	in.get(content);
    	String rt = new String(content);
    	//logger.info("String rt.length=="+content.length);
    	//logger.info("msgDecoder__rt"+rt);
    	out.write(rt);
    	return MessageDecoderResult.OK; 
    } 
}