Android 开发即时聊天工具 YQ :(四) 获取好友列表
实现聊天之前还有一个重要的东西,?没错,就是好友列表,没的好友你和谁聊呀,是吧,
嘿嘿,一切从简,早点实现基本的聊天目标的说,所以代码很懒(or 烂?),为什么呢?看完就知道了,
在服务器端当登陆成功后,新开一个线程,用来服务器和该账号通信,这样服务器端就可以处理别的登陆请求了,
[java]
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")){
//注册
}
服务器和某个客户端通信的线程:
[java] ad 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) {
}
&nb
补充:移动开发 , Android ,