locinfomgrmessagerecognizer.java

中国移动定位引擎的客户端

package ffcs.lbp.common;

import java.nio.ByteBuffer;

import net.gleamynode.netty2.MessageParseException;
import ffcs.lbp.LbpMessage;
import ffcs.lbp.le.message.LeMessage;
import ffcs.lbp.le.message.Link;
import ffcs.lbp.le.message.LinkRsp;
import ffcs.lbp.le.message.Login;
import ffcs.lbp.le.message.LoginRsp;


/**
* <p>Title: LBP项目</p>
* <p>Description:
*  协议封装类，把字节流封装成相应的Message包
* </p>
* <p>Copyright: 2008 福建福富软件技术股份有限公司 </p>
* <p>Company: 福建福富软件技术股份有限公司</p>
* @author chenxin
* @version $Rev:1.0 
*/
public abstract class LocInfoMgrMessageRecognizer extends AbstractMessageRecognizer {
    
	/**
	 * 根据消息ID得到指定的消息
	 * @param commandID
	 * @return
	 * @throws MessageParseException
	 */
	public abstract LbpMessage getMsgInstance(int commandID)throws MessageParseException;
	
	/**
     * 把数据包（字节）封装成相应的Message对象
     * @param 数据包BUF
     * @return Message　消息对象
     * @throws MessageParseException 数据包解析出送，抛出该异常
     */
	public LbpMessage LbpMessageRecognize(ByteBuffer buf) throws MessageParseException {
		
		if (buf.remaining() < 4) {
			return null;
		}
		int length = buf.getInt();
		
		if(length<LeMessage.HEADER_LENGTH || length>LeMessage.MAX_PACKAGE_SIZE){
        	throw new MessageParseException("错误的消息包长度:" + length + " \r\nsocket　buff内容为："+LbpMessage.byte2hexString(buf));
        }
		
		if (buf.remaining() < (length - 4)) {
			return null;
		}
		
		int CommandId = buf.getInt();
	
		switch (CommandId) {
		case LeMessage.Login : 
			return new  Login();
		case LeMessage.LoginRsp : 
			return new  LoginRsp() ;
		case LeMessage.Link : 
			return new  Link();
		case LeMessage.LinkRsp : 
			return new  LinkRsp();
	
		default:
			return getMsgInstance(CommandId);
//			先临时返回个LinkRsp，以后追踪做好后，要改成返回追踪包
//			return new  LinkRsp();
		}
	}
}