施用Mina框架开发 QQ Android 客户端（3） 登陆功能的实现

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

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

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

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

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();						}					}				}			});	 }}

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);			}		}	}