在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信号，永远在充电，，，，