在Android 开发即时聊天工具 YQ ：（三） 实现登陆功能中已经实现了登陆功能，离能聊天又近了一步了 ：）

在实现聊天之前还有一个重要的东西，？没错，就是好友列表，没的好友你和谁聊呀，是吧，

嘿嘿，一切从简，早点实现基本的聊天目标的说，所以代码很懒(or 烂？)，为什么呢？看完就知道了，

在服务器端当登陆成功后，新开一个线程，用来服务器和该账号通信，这样服务器端就可以处理别的登陆请求了，

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

		        	int account=u.getAccount();

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

					if(b){

						System.out.println(MyData.getDate()+"'"+account+"' 上线了！");

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

						oos.writeObject(m);

						ServerConClientThread cct=new ServerConClientThread(s);//单开一个线程，让该线程与该客户端保持连接

						ManageServerConClient.addClientThread(u.getAccount(),cct);

						cct.start();//启动与该客户端通信的线程

					}else{

						m.setType(YQMessageType.FAIL);

						oos.writeObject(m);

					}

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

		        	//注册

		        }

public class ServerConClientThread extends Thread {

	Socket s;

	public ServerConClientThread(Socket s){

		this.s=s;

	}

	public void run() {

		while(true){

			ObjectInputStream ois = null;

			YQMessage m = null;

			try {

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

				m=(YQMessage) ois.readObject();

				//对从客户端取得的消息进行类型判断，做相应的处理

				if(m.getType().equals(YQMessageType.COM_MES)){//如果是普通消息包

					//取得接收人的通信线程

					ServerConClientThread scc=ManageServerConClient.getClientThread(m.getReceiver());

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

					//向接收人发送消息

					oos.writeObject(m);

				}else if(m.getType().equals(YQMessageType.GET_ONLINE_FRIENDS)){//如果是请求好友列表

					//操作数据库，这里返回的是所有的用户列表，先留着坑，以后填，增加好友

					//暂时将结果揉成string类型，以后可以改为json

					String res=new UserDao().getUser();

					//发送好友列表到客户端

					ServerConClientThread scc=ManageServerConClient.getClientThread(m.getSender());

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

					YQMessage ms=new YQMessage();

					ms.setType(YQMessageType.RET_ONLINE_FRIENDS);

					ms.setContent(res);

					oos.writeObject(ms);

				}

			} catch (Exception e) {

				e.printStackTrace();

				try {

					s.close();

					ois.close();

				} catch (IOException e1) {

					

				}

			}

		}

	}

}

在客户端中，与上面类似：

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

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

				ClientConServerThread ccst=new ClientConServerThread(context,s);

				//启动该通信线程

				ccst.start();

				//加入到管理类中

				ManageClientConServer.addClientConServerThread(((User)obj).getAccount(), ccst);

				b=true;

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

				b=false;

			}

将客户端连接服务器的线程为什么要加到ManageClientServer这个类中，就是方便随时可以得到ObjectOutputStream对象，以便想服务器发送数据，当然也可以写一个专门发送数据的线程。

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

				ObjectOutputStream oos = new ObjectOutputStream	(

						ManageClientConServer.getClientConServerThread(user.getAccount()).getS().getOutputStream());

				YQMessage m=new YQMessage();

				m.setType(YQMessageType.GET_ONLINE_FRIENDS);

				m.setSender(user.getAccount());

				oos.writeObject(m);

在得到好友列表后，显示到好友列表中就OK，listView 和adapter种种，就不详细说了，

完成后效果如图：

话说安卓模拟器永远是3G信号，永远在充电，，，，