【正文】 } } 。 } public String getPasswd() { return passwd。 public String getUserId() { return userId。 public class User implements { private String userId。//表明登錄失敗 String message_m_mes=3。 public class MessageType { String message_succeed=1。 } public void setMesType(String mesType) { = mesType。 } public void setSendTime(String sendTime) { = sendTime。 } public void setCon(String con) { = con。 } public void setSender(String sender) { = sender。 } public void setHmSize(int hmSize) { = hmSize。 private String sendTime。 湖北大學知行學院本科畢業(yè)論文（設計） 29 private String sender。 public class Message implements { private String mesType。 } //可以通過 userId取得該線程 public static ClientConServerThread getClientConServerThread(String uid) { return (ClientConServerThread)(uid)。 public class ManageClientConServerThread{ private static HashMap hm=new HashMapString, ClientConServerThread()。 } } （ 12） ManageClientConServerThread 類的源代碼： package 。 //加入 public static void addChat(String uid,Chat Chat) { (uid, Chat)。 import .*。 } } } } （ 11） ManageChat 類的源代碼： package 。 //把從服務器獲得消息，顯示到該顯示的聊天界面 (m)。) { Object key=()。 for(Iterator iter=(Iterator)().iterator()。 } public void run() { while(true) { //不停的讀取從服務器發(fā)來的消息 try{ ObjectInputStream ois=new ObjectInputStream(())。 } 湖北大學知行學院本科畢業(yè)論文（設計） 27 public void setS(Socket s) { = s。 public class ClientConServerThread extends Thread { private Socket s。 import .*。 import .*。 } } （ 10） ClientConServerThread 類的源代碼： package 。 import .*。 // TODO: handle exception }finally{ } return b。 湖北大學知行學院本科畢業(yè)論文（設計） 26 //關閉 Scoket ()。 b=true。 ()。 Message ms=(Message)()。 (o)。 s=new Socket(,9999)。 //發(fā)送第一次請求 public boolean sendLoginInfoToServer(Object o) { boolean b=false。 import .*。 import .*。 import .*。 } 湖北大學知行學院本科畢業(yè)論文（設計） 25 //得到客戶端通信線程 public static SerConClientThread getClientThread(String uid) { return (SerConClientThread)(uid)。 public class ManageClientThread { public static HashMap hm=new HashMapString,SerConClientThread()。 } } } } （ 7） ManageClientThread 類的源代碼： package 。 (m)。 SerConClientThread scct=(SerConClientThread)(key)。((or) iter).hasNext()。 //Thread tSend。 //該線程接受客戶端的信息 try{ ObjectInputStream ois=new ObjectInputStream(())。 public SerConClientThread(Socket s) { 湖北大學知行學院本科畢業(yè)論文（設計） 24 //把服務器與該客戶端的連接賦給 s； =s。 import .*。 //import 。 import .*。 // TODO: handle exception }finally{ } } } （ 6） SerConClientThread 類的源代碼： /* * 工能：服務器與某個客戶端的通信線程 */ package 。 //關閉 Socket ()。 }else{ (2)。 湖北大學知行學院本科畢業(yè)論文（設計） 23 ((), scct)。 (m)。 ObjectOutputStream oos=new ObjectOutputStream(())。 (服務器接收到用戶 id:+()+ 密碼 :+())。 ObjectInputStream ois=new ObjectInputStream(())。 ServerSocket ss=new ServerSocket(9999)。 import .*。 import .*。 } } （ 5） Server 類得源代碼： package 。 } public void actionPerformed(ActionEvent e) { // TODO Autogenerated method stub if(()==jb1) { 湖北大學知行學院本科畢業(yè)論文（設計） 22 new Server()。 ()。 (jpl)。 (jb1)。 jb2=new JButton(關閉服務器 )。 jb1=new JButton(啟動服務器 )。 public static void main(String[] args) { ServerFrame sf=new ServerFrame()。 public class ServerFrame extends JFrame implements ActionListener{ JPanel jpl。 import .*。 import .*。 }catch(Exception ex){ ()。 //發(fā)送信息到服務器 try{ ObjectOutputStream oos=new ObjectOutputStream((ownerId).getS().getOutputStream())。 (new Date().toString())。 } Override public void actionPerformed(ActionEvent e) { // TODO Autogenerated method stub if(()==jb) { //如果用戶點擊了發(fā)送按鈕 Message m=new Message()。 } //寫一個方法，讓它顯示消息 public void showMessage(Message m) { String info=()+ 說 :+()+\r\n。 (500, 400)。 (jpl,South)。 (jb)。 jpl=new JPanel()。 jb=new JButton(發(fā)送 )。 湖北大學知行學院本科畢業(yè)論文（設計） 20 jta=new JTextArea()。 String ownerId。 JButton jb。 } JTextArea jta。 import .*。 import .*。 import .*。 import .*。 } } } （ 3）聊天界面的源代碼： package 。 } catch (SQLException e1) { // TODO Autogenerated catch block ()。 }finally{ //關閉 try { ()。 }else { //把填寫的內容寫入數據庫 } } } catch (SQLException e1) { // TODO Autogenerated catch block ()。 if((())) { (this,用戶名已存在，請重新注冊 ！ )。 while(()) { String userId=(1)。 } catch (SQLException e1) { // TODO Autogenerated catch block ()。 } catch (SQLException e1) { // TODO Autogenerated catch block ()。 if(()==jb1) { try { //加載驅動 ()。 } Override public void actio