在Android 開發(fā)即時(shí)聊天工具 YQ ：（三） 實(shí)現(xiàn)登陸功能中已經(jīng)實(shí)現(xiàn)了登陸功能，離能聊天又近了一步了 ：）

在實(shí)現(xiàn)聊天之前還有一個(gè)重要的東西，？沒錯(cuò)，就是好友列表，沒的好友你和誰聊呀，是吧，

嘿嘿，一切從簡，早點(diǎn)實(shí)現(xiàn)基本的聊天目標(biāo)的說，所以代碼很懶(or 爛？)，為什么呢？看完就知道了，

在服務(wù)器端當(dāng)?shù)顷懗晒?，新開一個(gè)線程，用來服務(wù)器和該賬號(hào)通信，這樣服務(wù)器端就可以處理別的登陸請(qǐng)求了，

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

		        	int account=u.getAccount();

		        	boolean b=new UserDao().login(account, u.getPassword());//連接數(shù)據(jù)庫驗(yàn)證用戶

					if(b){

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

						m.setType(YQMessageType.SUCCESS);//返回一個(gè)成功登陸的信息包

						oos.writeObject(m);

						ServerConClientThread cct=new ServerConClientThread(s);//單開一個(gè)線程，讓該線程與該客戶端保持連接

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

						cct.start();//啟動(dòng)與該客戶端通信的線程

					}else{

						m.setType(YQMessageType.FAIL);

						oos.writeObject(m);

					}

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

		        	//注冊(cè)

		        }

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

				//對(duì)從客戶端取得的消息進(jìn)行類型判斷，做相應(yīng)的處理

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

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

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

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

					//向接收人發(fā)送消息

					oos.writeObject(m);

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

					//操作數(shù)據(jù)庫，這里返回的是所有的用戶列表，先留著坑，以后填，增加好友

					//暫時(shí)將結(jié)果揉成string類型，以后可以改為json

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

					//發(fā)送好友列表到客戶端

					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)){

				//創(chuàng)建一個(gè)該賬號(hào)和服務(wù)器保持連接的線程

				ClientConServerThread ccst=new ClientConServerThread(context,s);

				//啟動(dòng)該通信線程

				ccst.start();

				//加入到管理類中

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

				b=true;

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

				b=false;

			}

將客戶端連接服務(wù)器的線程為什么要加到ManageClientServer這個(gè)類中，就是方便隨時(shí)可以得到ObjectOutputStream對(duì)象，以便想服務(wù)器發(fā)送數(shù)據(jù)，當(dāng)然也可以寫一個(gè)專門發(fā)送數(shù)據(jù)的線程。

//發(fā)送一個(gè)要求返回在線好友的請(qǐng)求的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種種，就不詳細(xì)說了，

完成后效果如圖：

話說安卓模擬器永遠(yuǎn)是3G信號(hào)，永遠(yuǎn)在充電，，，，