locprefixmessagerecognizer.java

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

package ffcs.lbp.le;

import java.nio.ByteBuffer;

import net.gleamynode.netty2.MessageParseException;
import ffcs.lbp.common.AbstractMessageRecognizer;
import ffcs.lbp.le.message.*;
import ffcs.lbp.LbpMessage;

/**
* <p>Title: 小区推送LBP项目</p>
* <p>Description:
*  协议封装类，把字节流封装成相应的Message包
* </p>
* <p>Copyright: 2007 福建福富软件技术股份有限公司 </p>
* <p>Company: 福建福富软件技术股份有限公司</p>
* @author chenxin
* @version $Rev:1.0 $Date: 2007-07-28
*/
public class LocPrefixMessageRecognizer extends AbstractMessageRecognizer {
	/**
     * 把数据包（字节）封装成相应的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);
        }
		
		if (buf.remaining() < (length - 4)) {
			return null;
		}
		int commandId = buf.getInt();
	    if(!LeMessage.checkCommandID(commandId)){
	    	throw new MessageParseException("command_id invalid:0x"+Integer.toHexString(commandId));
	    }

		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();	
        case     LeMessage.GetUserLoc	:
        	return new GetUserLoc();
        case     LeMessage.GetUserLocRsp	:
        	return new GetUserLocRsp();
        case     LeMessage.AddLocUser	:
        	return new AddLocUser();
        case     LeMessage.AddLocUserRsp	:
        	return new AddLocUserRsp();
        case     LeMessage.DelLocUser	:
        	return new DelLocUser();
        case     LeMessage.DelLocUserRsp	:
        	return new DelLocUserRsp();
        case     LeMessage.UserTrig		:
        	return new UserTrig();
        case     LeMessage.UserTrigRsp	:
        	return new UserTrigRsp();
        case     LeMessage.CycLoc		:
        	return new CycLoc();
        case     LeMessage.CycLocRsp	:
        	return new CycLocRsp();
        case      LeMessage.LocReport  :
        	return new LocReport();
        case    LeMessage.StopCycLoc	:
        	return new StopCycLoc();
        case    LeMessage.StopCycLocRsp:
        	return new StopCycLocRsp();	
        case     LeMessage.TriArea		:
        	return new TriArea();
        case     LeMessage.TriAreaRsp	:
        	return new TriAreaRsp();
        case     LeMessage.TriAreaReport  :
        	return new TriAreaReport();
        case     LeMessage.TriAreaStop	:
        	return new TriAreaStop();
        case     LeMessage.TriAreaStopRsp	:
        	return new TriAreaStopRsp();
        case     LeMessage.Dstan          :
        	return new Dstan();
        case     LeMessage.DstanRsp      :
        	return new DstanRsp();	
        case     LeMessage.DstanReport	:
        	return new DstanReport();
//        case     LeMessage.RunTest		:
//        	return new RunTest();
//        case     LeMessage.Fllow	:
//        	return new Fllow();
		default:
			throw new MessageParseException("unknow command_id :0x"+Integer.toHexString(commandId));
		}
	}
}