loginthread.java

JAVA解析MSNP15协议

package jm.framework.msn.service;

import jm.framework.msn.SystemManager;
import jm.framework.msn.action.C2SMessageI;
import jm.framework.msn.msg.LoginMessage;
import jm.framework.msn.msg.group.MsgGroupFactory;
import jm.util.JMRpcThread;

/**
 * 登录验证的线程 梦界家园MSNP15
 * 
 * @author ISHome
 * @since 0.5.0.1
 * @version 0.1
 */
public class LoginThread extends JMRpcThread {
	private SystemManager systemManager = SystemManager.getInstance();
	private MsgGroupFactory messageGroup = systemManager.getMessageGroup();
	private LoginMessage inMsg = new LoginMessage();
	public LoginThread(Runnable r) {
		super(r);
	}
	
	/**
	 * 运行线程
	 */
	public void run() {
		try {
			String command = "jm.framework.msn.protocol.in.In" + inMsg.getHeaderCommand();
			C2SMessageI c2SMessage = (C2SMessageI) Class.forName(command).newInstance();
			LoginMessage outMsg = (LoginMessage) c2SMessage.outVoker(inMsg);
			if (outMsg != null) {
				 messageGroup.addLoginMessage(outMsg);
			}
		} catch (Exception ex) {
			ex.printStackTrace();
		} 
		this.interrupt();
	}
//	public LoginMessage getInMsg() {
//    	return inMsg;
//    }
	public void setInMsg(LoginMessage inMsg) {
    	this.inMsg = inMsg;
    }
}