当前位置:操作系统 > 安卓/Android >>

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 ,
CopyRight © 2022 站长资源库 编程知识问答 zzzyk.com All Rights Reserved
部分文章来自网络,