欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

使用Mina框架开发 QQ Android 客户端(3) 登陆功能的实现

程序员文章站 2022-05-14 10:03:10
...

在博客中有登陆界面的文章http://blog.csdn.net/vestigge/article/details/8124674

就不在重复了,直接看登陆的代码,

用Mina传递字符串上节已经看过了,要实现传递对象,也非常简单,只需要修改一下过滤器:

chain.addLast("codec", new ProtocolCodecFilter(new ObjectSerializationCodecFactory()));

在Android客户端,登陆的Activity中:

public class LoginActivity extends Activity{
	private EditText accountEditText;
	private EditText passwordEditText;
	private CheckBox remeberCheckBox;
	
	 public void onCreate(Bundle savedInstanceState) {
	        super.onCreate(savedInstanceState);
	        requestWindowFeature(Window.FEATURE_NO_TITLE);
	        setContentView(R.layout.activity_login);
	        accountEditText=(EditText) findViewById(R.id.login_account);
			passwordEditText=(EditText) findViewById(R.id.login_password);
			remeberCheckBox=(CheckBox) findViewById(R.id.login_remember);
			
			findViewById(R.id.login_login).setOnClickListener(new OnClickListener(){
				public void onClick(View v) {
					if(accountEditText.getText().toString().equals("") || 
							passwordEditText.getText().toString().equals("")){
						Toast.makeText(LoginActivity.this, "账号或密码不能为空!", Toast.LENGTH_SHORT).show();
					}else{
						User user=new User();
						user.setAccount(Integer.parseInt(accountEditText.getText().toString()));
						user.setPassword(passwordEditText.getText().toString());
						user.setOperation(VQMessageType.LOGIN);
						boolean b=new VQClient().sendLoginInfo(user);
						//如果登录成功
						if(b){
							Toast.makeText(LoginActivity.this, "登陆成功!", Toast.LENGTH_SHORT).show();
							startActivity(new Intent(LoginActivity.this,MainActivity.class));
						}else{
							Toast.makeText(LoginActivity.this, "连接超时,登陆失败!", Toast.LENGTH_SHORT).show();
						}
					}
				}
			});
	 }
}

可以看到会调用VQClient这个类中的方法去发送登陆请求,VQClient的实现:

public class VQClient {
	private static int PORT=5469;
	public boolean sendLoginInfo(User u){
		boolean b=false;
		System.setProperty("java.net.preferIPv6Addresses", "false");//2.2会有ipv6的问题,
		SocketConnector connector = new NioSocketConnector();
		connector.setConnectTimeoutMillis(300000);
		DefaultIoFilterChainBuilder chain=connector.getFilterChain();
		chain.addLast("codec", new ProtocolCodecFilter(new ObjectSerializationCodecFactory()));
		SocketSessionConfig cfg = connector.getSessionConfig();
		cfg.setUseReadOperation(true); 
		IoSession session = connector.connect(new InetSocketAddress("10.0.2.2", PORT))  
	            .awaitUninterruptibly().getSession();
		//发送并等待完成
		session.write(u).awaitUninterruptibly();
		//接收
		ReadFuture readFuture = session.read();
		//接收超时
		if (readFuture.awaitUninterruptibly(30000,TimeUnit.SECONDS)) {  
            VQMessage message = (VQMessage) readFuture.getMessage();
            //如果是登陆成功的信息
            if(message.getType().equals(VQMessageType.SUCCESS)){
            	b= true;
            }
        } else {
        	b= false;
        } 
		//断开连接
		session.close(true);  
        session.getService().dispose(); 
        return b;
	}
}

然后服务器端变化不大,在收到登陆请求后,会查询数据库,返回一个信息,来表明登陆成功或者失败。

public void messageReceived(IoSession session, Object message)
			throws Exception {
		User user=(User) message;
		if(user.getOperation().equals(VQMessageType.LOGIN)){
			//操作数据库
			boolean b=new UserDao().login(user.getAccount(), user.getPassword());
			if(b){
				System.out.println(">> ["+user.getAccount()+"] 上线了");
				//告诉客户端登陆成功
				VQMessage m=new VQMessage();
				m.setType(VQMessageType.SUCCESS);
				session.write(m);
			}
		}
	}

最后附上测试效果:

使用Mina框架开发 QQ Android 客户端(3) 登陆功能的实现使用Mina框架开发 QQ Android 客户端(3) 登陆功能的实现