【文章內(nèi)容簡介】 erformed(ActionEvent arg0) { new jp()。RectD rd = new RectD()。 GraphicsDevice gd = () .getDefaultScreenDevice()。 (rd)。 } })。 } public synchronized boolean closeConnection() { try { Java語言程序設(shè)計(jì)（報(bào)告） 19 sendMessage(CLOSE)。// 發(fā)送斷開連接命令給服務(wù)器 ()。// 停止接受消息線程 // 釋放資源 if (reader != null) { ()。 } if (writer != null) { ()。 } if (socket != null) { ()。 } isConnected = false。 return true。 } catch (IOException e1) { ()。 isConnected = true。 return false。 } } public void sendMessage(String message) { (message)。 ()。 } public void send() { if (!isConnected) { Java語言程序設(shè)計(jì)（報(bào)告） 20 (null, 還沒有連接服務(wù)器，無法發(fā)送消息！ , 錯誤 , )。 return。 } String message = ().trim()。 if (message == null || ()) { (null, 消息不能為空！ , 錯誤 , )。 return。 } sendMessage(getTitle() + @ + ALL + @ + message)。 (null)。 } public static void main(String args[]){ new khd()。 } class MessageThread extends Thread { private BufferedReader reader。 private JTextArea textArea。 // 接收消息線程的構(gòu)造方法 public MessageThread(BufferedReader reader, JTextArea textArea) { = reader。 Java語言程序設(shè)計(jì)（報(bào)告） 21 = textArea。 } // 被動的關(guān)閉連接 public synchronized void closeCon() throws Exception { // 清空用戶列表 // ()。 // 被動的關(guān)閉連接釋放資源 if (reader != null) { ()。 } if (writer != null) { ()。 } if (socket != null) { ()。 } isConnected = false。// 修改狀態(tài)為斷開 } public void run() { String message = 。 while (true) { try { message = ()。 StringTokenizer stringTokenizer = new Java語言程序設(shè)計(jì)（報(bào)告） 22 StringTokenizer( message, /@)。 String mand = ()。// 命令 if ((CLOSE))// 服務(wù)器已關(guān)閉命令 { (服務(wù)器已關(guān)閉 !\n)。 closeCon()。// 被動的關(guān)閉連接 return。// 結(jié)束線程 } else if ((ADD)) {// 有用戶上線更新在線列表 String username = 。 String userIp = 。 if ((username = ()) != null amp。amp。 (userIp = ()) != null) { User user = new User(username, userIp)。 (username, user)。 //(username)。 } } else if ((DELETE)) {// 有用戶下線更新在線列表 String username = ()。 Java語言程序設(shè)計(jì)（報(bào)告） 23 User user = (User) (username)。 (user)。 } else if ((USERLIST)) {// 加載在線用戶列表 int size = Integer .parseInt(en())。 String username = null。 String userIp = null。 for (int i = 0。 i size。 i++) { username = ()。 userIp = ()。 User user = new User(username, userIp)。 (username, user)。 //(username)。 } } else if ((MAX)) {// 人數(shù)已達(dá)上限 (() + () + \n)。 closeCon()。// 被動的關(guān)閉連接 Java語言程序設(shè)計(jì)（報(bào)告） 24 (null, 服務(wù)器緩沖區(qū)已滿！ , 錯誤 , )。 return。// 結(jié)束線程 } else {// 普通消息 (message + \n)。 } } catch (IOException e) { ()。 } catch (Exception e) { ()。 } } } } public boolean connectServer(int port, String hostIp, String name) { // 連接服務(wù)器 try { socket = new Socket(hostIp, port)。// 根據(jù)端口號和服務(wù)器 ip 建立連接 socket2=new Socket(hostIp,port)。 writer = new PrintWriter(())。 reader = new BufferedReader(new InputStreamReader(socket .getInputStream()))。 Java語言程序設(shè)計(jì)（報(bào)告） 25 // 發(fā)送客戶端用戶基本信息 (用戶名和 ip 地址 ) sendMessage(name + @ + ().toString())。 // 開啟接收消息的線程 messageThread = new MessageThread(reader, jt1)。 ()。 new wjsc(socket2).start()。 //new Input(socket2).start()。 isConnected = true。// 已經(jīng)連接上了 return true。 } catch (Excepti