【導讀】題目基于JAVA的聊天室設(shè)計與實現(xiàn)。計算機與信息工程系計算機科學與技術(shù)專業(yè)。工作地點湖北大學知行學院

　　

【正文】 } public void run() { while(true) { (===============)。 //該線程接受客戶端的信息 try{ ObjectInputStream ois=new ObjectInputStream(())。 Message m=(Message)()。 //Thread tSend。 for(Iterator iter=(Iterator)().iterator()。((or) iter).hasNext()。) { //遍歷管理服務(wù)器連接客戶端的線程的 hashmap，獲得這些線程，并把消息發(fā)送出去 Object key=()。 SerConClientThread scct=(SerConClientThread)(key)。 ObjectOutputStream oos=new ObjectOutputStream(())。 (m)。 } }catch(Exception e){ ()。 } } } } （ 7） ManageClientThread 類的源代碼： package 。 import .*。 public class ManageClientThread { public static HashMap hm=new HashMapString,SerConClientThread()。 //想 hm中添加一個客戶端通訊線程 public static void addClientThread (String uid,SerConClientThread ct) { (uid, ct)。 } 湖北大學知行學院本科畢業(yè)論文（設(shè)計） 25 //得到客戶端通信線程 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)建一個該用戶與服務(wù)器連接通訊的線程 ClientConServerThread ccst=new ClientConServerThread(s)。 ()。 (((User)o).getUserId(), ccst)。 b=true。 }else{ b=false。 湖北大學知行學院本科畢業(yè)論文（設(shè)計） 26 //關(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。 } 湖北大學知行學院本科畢業(yè)論文（設(shè)計） 27 public void setS(Socket s) { = s。 } //構(gòu)造函數(shù) public ClientConServerThread(Socket s) { =s。 } public void run() { while(true) { //不停的讀取從服務(wù)器發(fā)來的消息 try{ ObjectInputStream ois=new ObjectInputStream(())。 Message m=(Message)()。 for(Iterator iter=(Iterator)().iterator()。(() iter).hasNext()。) { Object key=()。 Chat chat=(Chat)(key)。 //把從服務(wù)器獲得消息，顯示到該顯示的聊天界面 (m)。 } }catch(Exception e){ ()。 } } } } （ 11） ManageChat 類的源代碼： package 。 import .*。 import .*。 湖北大學知行學院本科畢業(yè)論文（設(shè)計） 28 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。 湖北大學知行學院本科畢業(yè)論文（設(shè)計） 29 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。 } } 湖北大學知行學院本科畢業(yè)論文（設(shè)計） 30 （ 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。 }