【正文】 ,SerConClientThread()。 //想hm中添加一個客戶端通訊線程 public static void addClientThread (String uid,SerConClientThread ct) { (uid, ct)。 } //得到客戶端通信線程 public static SerConClientThread getClientThread(String uid) { return (SerConClientThread)(uid)。 }}（8）ClientConServer類的源代碼：package 。import .*。import .*。import .*。import .*。import .*。public class ClientConServer { public Socket s。 //發(fā)送第一次請求 public boolean sendLoginInfoToServer(Object o) { boolean b=false。 try { //(kk)。 s=new Socket(,9999)。 ObjectOutputStream oos=new ObjectOutputStream(())。 (o)。 ObjectInputStream ois=new ObjectInputStream(())。 Message ms=(Message)()。 //驗證用戶登錄 if(().equals(1)) { //登錄成功就創(chuàng)建一個該用戶與服務器連接通訊的線程 ClientConServerThread ccst=new ClientConServerThread(s)。 ()。 (((User)o).getUserId(), ccst)。 b=true。 }else{ b=false。 //關(guān)閉Scoket ()。 } } catch (Exception e) { ()。 // TODO: handle exception }finally{ } return b。 }}（9）ClientUser類的源代碼：package 。import .*。public class ClientUser { public boolean checkUser(User u) { return new ClientConServer().sendLoginInfoToServer (u)。 }}（10）ClientConServerThread類的源代碼：package 。import .*。import .*。import 。import .*。import 。public class ClientConServerThread extends Thread { private Socket s。 public Socket getS() { return s。 } public void setS(Socket s) { = s。 } //構(gòu)造函數(shù) public ClientConServerThread(Socket s) { =s。 } public void run() { while(true) { //不停的讀取從服務器發(fā)來的消息 try{ ObjectInputStream ois=new ObjectInputStream(())。 Message m=(Message)()。 for(Iterator iter=(Iterator)().iterator()。(() iter).hasNext()。) { Object key=()。 Chat chat=(Chat)(key)。 //把從服務器獲得消息，顯示到該顯示的聊天界面 (m)。 } }catch(Exception e){ ()。 } } } }（11）ManageChat類的源代碼：package 。import .*。import .*。public class ManageChat{ public static HashMap hmChat=new HashMapString,Chat()。 //加入 public static void addChat(String uid,Chat Chat) { (uid, Chat)。 } //取出 public static Chat getChat(String uid) { return (Chat)(uid)。 }}（12）ManageClientConServerThread類的源代碼：package 。import 。public class ManageClientConServerThread{ private static HashMap hm=new HashMapString, ClientConServerThread()。 //把創(chuàng)建好的ClientConServerThread放入到hm public static void addClientConServerThread(String uid,ClientConServerThread ccst) { (uid, ccst)。 } //可以通過userId取得該線程 public static ClientConServerThread getClientConServerThread(String uid) { return (ClientConServerThread)(uid)。 }}（13）Message類的源代碼：package 。public class Message implements { private String mesType。 private int hmSize。 private String sender。 private String con。 private String sendTime。 public int getHmSize() { return hmSize。 } public void setHmSize(int hmSize) { = hmSize。 } public String getSender() { return sender。 } public void setSender(String sender) { = sender。 } public String getCon() { return con。 } public void setCon(String con) { = con。 } public String getSendTime() { return sendTime。 } public void setSendTime(String sendTime) { = sendTime。 } public String getMesType() { return mesType。 } public void setMesType(String mesType) { = mesType。 }}（14）MessageType類的源代碼：package 。public class MessageType { String message_succeed=1。//表明是登陸成功 String message_login_fail=2。//表明登錄失敗 String message_m_mes=3。//普通信息包}（15）User類的源代碼：/** * 這是用戶信息類 */package 。public class User implements { private String userId。 private String passwd。 public String getUserId() { return userId。 } public void setUserId(String userId) { = userId。 } public String getPasswd() { return passwd。 } public void setPasswd(String passwd) { = passwd。 }