java聊天系統代碼doc(編輯修改稿)
2025-06-11 23:10 本頁面
【文章內容簡介】 traints(3, 93, 395, 123))。 (sysexit, new XYConstraints(336, 255, 1, 1))。 (link, new XYConstraints(270, 255, 1, 1))。 (jTextField2, new XYConstraints(12, 228, 314, 23))。 (jTextField1, new XYConstraints(13, 255, 247, 22))。 (jLabel4,new PaneConstraints(jLabel5, jLabel5, ))。 (jLabel6,new PaneConstraints(jLabel4, jLabel5, ))。 (jLabel5,new PaneConstraints(jLabel6, jLabel5, ))。 (jLabel1,new PaneConstraints(jLabel2, jLabel2, , ))。 (jLabel3,new PaneConstraints(jLabel3, jLabel2, , ))。 (jLabel2,new PaneConstraints(jLabel1, jLabel2, ))。 } //Overridden so we can exit when window is closed protected void processWindowEvent(WindowEvent e){ (e)。 if(()==){ sendClients(new StringBuffer(QUIT:+SERVER))。 closeAll()。 (0)。 } }//client類是ServerFrame類的內部類 class Client extends Thread{ String name。//用來存儲客戶的連接姓名 String ip。//用來存儲客戶的IP地址 DataInputStream dis。//用來實現接受從客戶端發(fā)送來的數據流 DataOutputStream dos。//用來實現從客戶端發(fā)送信息的打印流 Socket socket。 //構造方法 public Client(Socket s){ socket = s。 try { /*存儲特定客戶socket的輸入流,接收s客戶發(fā)送到服務器端的信息*/ dis = new DataInputStream(())。 /*存儲特定客戶客戶socket的輸出流,發(fā)送服務器給s客戶的信息*/ dos = new DataOutputStream(())。 //讀取接收到的信息 String info = ()。 //讀取用:分開的字符段 StringTokenizer stinfo = new StringTokenizer(info,:)。 String head = ()。//度曲第一個分段字符串 if (()){ name = ()。//讀取客戶名稱 } if (()){ ip = ()。//讀取IP地址 } } catch (IOException ex) { (系統消息: 發(fā)生錯誤:+ex)。 } } //send方法是client類的方法，用于向客戶端發(fā)送消息 public void send(String msg){ try { (())。//用打印流發(fā)送消息 ()。 }catch (IOException ex){ ()。//輸出異常錯誤信息 } } //線程類client的run方法不斷接收和處理對應用戶發(fā)送來的消息 public void run(){ while (true){ String line = null。 try { line = ()。//讀取客戶端發(fā)送的數據流 }catch (IOException e){ (系統消息: 發(fā)生錯誤:+e)。 disconnect(this)。 notifyRoom()。 return。 } if(line == null){ disconnect(this)。 notifyRoom()。 return。 } StringTokenizer st = new StringTokenizer(line,:)。 String keyword = ()。//存儲關鍵字，判斷消息類型 String broadcast = ()。//存儲消息是屬于廣播還是屬于私自,廣播則記錄目標用戶名 if((MSG)){ //MSG代表聊天信息 StringBuffer message = new StringBuffer(MSG:)。//在服務器端建立一個緩沖區(qū)，用于發(fā)送信息 (broadcast+:)。 ((s))。 if((BROAD)){ sendClients(message)。 } else { sendtoClient(message,broadcast)。 } } else if((QUIT)){ //QUIT 代表退出信息 ()。 disconnect(this)。 for (int i = 0。i ()。i++){ Client listdata1 = (Client)(i)。 (+ + + 已經連接,i)。 } notifyRoom()。 ()。 } } } } //sendClients是ServerFrame的方法，用于發(fā)送信息到所有用戶 public synchronized void sendClients(StringBuffer msg){ for(int i = 0。i ()。 i++){ Client c = (Client)(i)。 (())。 } } //sendtoClient是ServerFrame的方法，用于將信息發(fā)送到特定的單個用戶 public void sendtoClient(StringBuffer msg, String name){ for (int i = 0。 i ()。 i++){ Client c = (Client)(i)。 if((name)){ (())。 break。 } } } //disconnec是ServerFrame的方法,與單個用戶斷開連接 public void disconnect(Client c){ try{ (系統消息: ++ 斷開連接!\n)。 (c)。//從clients數組中刪除客戶 sendClients(new StringBuffer(
公司管理相關推薦
鄂ICP備17016276號-1