前面socket基本通信完了，登陆界面也已经完成，下面就是重点了，实现登陆功能

服务器和客户端的代码当然不肯能用那个控制台的那个了，所以全部得重写，不过原理都一样，代码也差不多，都有注释，一看就明白。

先是登陆的Activity：

public class LoginActivity extends Activity {

	protected void onCreate(Bundle savedInstanceState) {

		super.onCreate(savedInstanceState);

	    setContentView(R.layout.activity_login);

	    Button btnLogin=(Button) findViewById(R.id.btn_login);

	    btnLogin.setOnClickListener(new OnClickListener(){

			public void onClick(View arg0) {

				int account=Integer.parseInt(((EditText) findViewById(R.id.et_account)).getText().toString());

			    String password=((EditText) findViewById(R.id.et_password)).getText().toString();

			    login(account, password);

			}

	    }); 

	}

	

	void login(int a, String p){

		User user=new User();

		user.setAccount(a);

		user.setPassword(p);

		user.setOperation("login");

		boolean b=new YQConServer().sendLoginInfo(user);

		//登陆成功

		if(b){

			try {

				//发送一个要求返回在线好友的请求的Message

				//---

			} catch (IOException e) {

				e.printStackTrace();

			}

			//转到主界面，

			Intent i=new Intent(this, MainActivity.class);

			startActivity(i);

		}else {

			Toast.makeText(this, "登陆失败！不告诉你为什么，", Toast.LENGTH_SHORT).show();

		}

	}

}

将登陆的信息封装到user中，user的operation用来判断该user包的类型，交由YQClient来发送到服务器。

客户端：

public class YQClient{

	public Socket s;

	

	public boolean sendLoginInfo(Object obj){

		boolean b=false;

		try {

			s=new Socket();

			try{

				s.connect(new InetSocketAddress("10.0.2.2",5469),2000);

			}catch(SocketTimeoutException e){

				//连接服务器超时

				return false;

			}

			ObjectOutputStream oos=new ObjectOutputStream(s.getOutputStream());

			oos.writeObject(obj);

			ObjectInputStream ois=new ObjectInputStream(s.getInputStream());

			YQMessage ms=(YQMessage)ois.readObject();

			if(ms.getType().equals(YQMessageType.SUCCESS)){

				//创建一个该账号和服务器保持连接的线程

				//---

				b=true;

			}else if(ms.getType().equals(YQMessageType.FAIL)){

				b=false;

			}

		} catch (IOException e) {

			e.printStackTrace();

		} catch (ClassNotFoundException e) {

			e.printStackTrace();

		}

		return b;

	}

}

在登陆成功后，将会新开一个线程和服务器保持连接，该线程将用来通信，

要捕获SocketTimeoutException异常，否则连接 不到服务器，app会无响应，这里设置2s服务器无响应，则连接服务器超时。

最后在看服务器端：

public class YQServer {

	public YQServer(){

		ServerSocket ss = null;

		try {

			ss=new ServerSocket(5469);

			System.out.println("服务器已启动，正在监听5469端口...");

			while(true){

				Socket s=ss.accept();

				//接受客户端发来的信息

				ObjectInputStream ois=new ObjectInputStream(s.getInputStream());

				User u=(User) ois.readObject();

				YQMessage m=new YQMessage();

				ObjectOutputStream oos=new ObjectOutputStream(s.getOutputStream());

				

		        if(u.getOperation().equals("login")){ //登录

		        	int account=u.getAccount();

		        	boolean b=new UserDao().login(account, u.getPassword());//连接数据库验证用户

					if(b){

						System.out.println("["+account+"] 上线了！");

						m.setType(YQMessageType.SUCCESS);//返回一个成功登陆的信息包

						oos.writeObject(m);

						//单开一个线程，让该线程与该客户端保持连接

						//---

					}else{

						m.setType(YQMessageType.FAIL);

						oos.writeObject(m);

					}

		        }else if(u.getOperation().equals("register")){

		        	//注册

		        }

			}

		} catch (Exception e) {

			e.printStackTrace();

		}	

	}

}