Netty游戏服务器之六服务端登录消息处理

public class LoginProtocol {
	
	/*
	 * Login_Area
	 * **/
	public static final int Area_LoginRequest = 0; // 登陆请求
	public static final int Area_LoginResponse = 1; //登录应答
	
	/*
	 * Login_Command
	 * **/
	public static final int Login_InvalidMessage = 0;//无效消息
	public static final int Login_InvalidUsername = 1;//无效用户名
	public static final int Login_InvalidPassword = 2;//密码错误
	
	public static final int Login_Succeed = 10;//登陆成功
}

public class LoginDispatch {
	private static LoginDispatch instance = new LoginDispatch();
	public static LoginDispatch getInstance()
	{
		return instance;
	}
	public void dispatch(ChannelHandlerContext ctx, SocketModel message)
	{
		switch (message.getArea()) {
		case LoginProtocol.Area_LoginRequest:
		        //处理登录的事务
			break;
		default:
			break;
		}
	}
	
}

public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception//当客户端发送数据到服务器会触发此函数
	{
		SocketModel message = (SocketModel) msg;
		switch (message.getType()) {
		case TypeProtocol.TYPE_LOGIN:
			LoginDispatch.getInstance().dispatch(ctx, message);//分派登录消息
			break;
		case TypeProtocol.TYPE_WIZARD:
			WizardDispatch.getInstance().dispatch(ctx, message);
			break;
		case TypeProtocol.TYPE_USER:
			UserDispatch.getInstance().dispatch(ctx, message);
			break;
		case TypeProtocol.TYPE_BATTLE:
			BattleDispatch.getInstance().dispatch(ctx, message);
		default:
			break;
		}

public class LoginDispatch {
	private static LoginDispatch instance = new LoginDispatch();
	public static LoginDispatch getInstance()
	{
		return instance;
	}
	public User user = null;
	public Wizard wizard = null;
	public void dispatch(ChannelHandlerContext ctx, SocketModel message)
	{
		switch (message.getArea()) {
		case LoginProtocol.Area_LoginRequest:
			LoginResponse(ctx,message);
	
			break;
		default:
			break;
		}
	}
	/*
	 * **检测用户登录是否密码错误，用户名不存在等，返回int对应的不同类型
	 */
	public int LoginCheck(ChannelHandlerContext ctx,SocketModel request)
	{
		List<String> message = request.getMessage();
		String username = message.get(0);
		String password = message.get(1);
		//System.out.println(username);
		//System.out.println(password);
		if (message.isEmpty())
		{
			return LoginProtocol.Login_InvalidMessage;
		}else{
			if (UserMySQL.getInstance().usernameExit(username))
			{
				user = UserMySQL.getInstance().userExit(username, password,ctx.channel());
				if (user != null){
		
					return LoginProtocol.Login_Succeed;
				}else{
					return LoginProtocol.Login_InvalidPassword;
				}
			}else{
				return LoginProtocol.Login_InvalidUsername;
			}
		}
		
	}
	public void LoginResponse(ChannelHandlerContext ctx,SocketModel request)
	{
		SocketModel response = new SocketModel();
		int command = LoginCheck(ctx, request);
		response.setType(TypeProtocol.TYPE_LOGIN);
		response.setArea(LoginProtocol.Area_LoginResponse);
		response.setCommand(command);
		response.setMessage(request.getMessage());
		ctx.writeAndFlush(response);
		if (command == LoginProtocol.Login_Succeed)
		{
			LoginUser(ctx,request);//如果成功就登陆用户,并开始新手向导
		}
	}
	/**
	 * 登陆用户，并开始新手向导
	 * @param ctx
	 */
	public void LoginUser(ChannelHandlerContext ctx,SocketModel socketModel)
	{
		user = UserMySQL.getInstance().initUser(User.getUserByChannel(ctx.channel()));
		user.setWizard(WizardMySQL.getInstance().initWizard(user.getUserID()));
		SocketModel message = new SocketModel();
		message.setType(TypeProtocol.TYPE_WIZARD);
		message.setArea(WizardProtocol.Wizard_Create_Request);
		message.setCommand(user.getWizard().getStepIndex());
		message.setMessage(null);
		ctx.writeAndFlush(message);
	}
}