最近做了一個項目，其中有一個在線網頁交流的需求，好久沒寫代碼了，手都生疏了，于是先寫demo練練手，分享到武林網平臺，以此做個記錄，方便自己和大家使用。
先給大家說下實現(xiàn)步驟分這樣幾大步：
1、使用awt組件和socket實現(xiàn)簡單的單客戶端向服務端持續(xù)發(fā)送消息；
2、結合線程，實現(xiàn)多客戶端連接服務端發(fā)送消息；
3、實現(xiàn)服務端轉發(fā)客戶端消息至所有客戶端，同時在客戶端顯示；
4、把awt組件生成的窗口界面改成前端jsp或者html展示的界面，java socket實現(xiàn)的客戶端改為前端技術實現(xiàn)。
這里首先實現(xiàn)第一步的簡單功能，難點在于：
1、沒有用過awt組件，沒有用過java相關的監(jiān)聽事件；
2、長時間沒有使用socket進行客戶端和服務端的交互，并且沒有真正進行過cs結構的開發(fā)。
實現(xiàn)功能的代碼如下：
客戶端：
package chat.chat; import java.awt.BorderLayout; import java.awt.Frame; import java.awt.TextArea; import java.awt.TextField; import java.awt.event.ActionEvent; import java.awt.event.ActionListener; import java.awt.event.WindowAdapter; import java.awt.event.WindowEvent; import java.io.DataOutputStream; import java.io.IOException; import java.net.Socket; import java.net.UnknownHostException; /** * 在線聊天客戶端 1、生成圖形窗口界面輪廓 2、為輪廓添加關閉事件 3、在輪廓中加入輸入?yún)^(qū)域和內容展示區(qū)域 4、為輸入?yún)^(qū)域添加回車事件 * 5、建立服務端連接并發(fā)送數(shù)據(jù) * * @author tuzongxun123 * */ public class ChatClient extends Frame { // 用戶輸入?yún)^(qū)域 private TextField tfTxt = new TextField(); // 內容展示區(qū)域 private TextArea tarea = new TextArea(); private Socket socket = null; // 數(shù)據(jù)輸出流 private DataOutputStream dataOutputStream = null; public static void main(String[] args) { new ChatClient().launcFrame(); } /** * 建立一個簡單的圖形化窗口 * * @author：tuzongxun * @Title: launcFrame * @param * @return void * @date May 18, 2016 9:57:00 AM * @throws */ public void launcFrame() { setLocation(300, 200); this.setSize(200, 400); add(tfTxt, BorderLayout.SOUTH); add(tarea, BorderLayout.NORTH); pack(); // 監(jiān)聽圖形界面窗口的關閉事件 this.addWindowListener(new WindowAdapter() { @Override public void windowClosing(WindowEvent e) { System.exit(0); disConnect(); } }); tfTxt.addActionListener(new TFLister()); setVisible(true); connect(); } /** * 連接服務器 * * @author：tuzongxun * @Title: connect * @param * @return void * @date May 18, 2016 9:56:49 AM * @throws */ public void connect() { try { // 新建服務端連接 socket = new Socket("127.0.0.1", 8888); // 獲取客戶端輸出流 dataOutputStream = new DataOutputStream(socket.getOutputStream()); System.out.println("連上服務端"); } catch (UnknownHostException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } } /** * 關閉客戶端資源 * * @author：tuzongxun * @Title: disConnect * @param * @return void * @date May 18, 2016 9:57:46 AM * @throws */ public void disConnect() { try { dataOutputStream.close(); socket.close(); } catch (IOException e) { e.printStackTrace(); } } /** * 向服務端發(fā)送消息 * * @author：tuzongxun * @Title: sendMessage * @param @param text * @return void * @date May 18, 2016 9:57:56 AM * @throws */ private void sendMessage(String text) { try { dataOutputStream.writeUTF(text); dataOutputStream.flush(); } catch (IOException e1) { e1.printStackTrace(); } } /** * 圖形窗口輸入?yún)^(qū)域監(jiān)聽回車事件 * * @author tuzongxun123 * */ private class TFLister implements ActionListener { @Override public void actionPerformed(ActionEvent e) { String text = tfTxt.getText().trim(); tarea.setText(text); tfTxt.setText(""); // 回車后發(fā)送數(shù)據(jù)到服務器 sendMessage(text); } } } 服務端：
package chat.chat; import java.io.DataInputStream; import java.io.EOFException; import java.io.IOException; import java.net.BindException; import java.net.ServerSocket; import java.net.Socket; /** * java使用socket和awt組件簡單實現(xiàn)在線聊天功能服務端 可以實現(xiàn)一個客戶端連接后不斷向服務端發(fā)送消息 * 但不支持多個客戶端同時連接，原因在于代碼中獲得客戶端連接后會一直循環(huán)監(jiān)聽客戶端輸入，造成阻塞 * 以至于服務端無法二次監(jiān)聽另外的客戶端，如要實現(xiàn)，需要使用異步或者多線程 * * @author tuzongxun123 * */ public class ChatServer { public static void main(String[] args) { // 是否成功啟動服務端 boolean isStart = false; // 服務端socket ServerSocket ss = null; // 客戶端socket Socket socket = null; // 服務端讀取客戶端數(shù)據(jù)輸入流 DataInputStream dataInputStream = null; try { // 啟動服務器 ss = new ServerSocket(8888); } catch (BindException e) { System.out.println("端口已在使用中"); // 關閉程序 System.exit(0); } catch (Exception e) { e.printStackTrace(); } try { isStart = true; while (isStart) { boolean isConnect = false; // 啟動監(jiān)聽 socket = ss.accept(); System.out.println("one client connect"); isConnect = true; while (isConnect) { // 獲取客戶端輸入流 dataInputStream = new DataInputStream( socket.getInputStream()); // 讀取客戶端傳遞的數(shù)據(jù) String message = dataInputStream.readUTF(); System.out.println("客戶端說：" + message); } } } catch (EOFException e) { System.out.println("client closed!"); } catch (Exception e) { e.printStackTrace(); } finally { // 關閉相關資源 try { dataInputStream.close(); socket.close(); } catch (IOException e) { e.printStackTrace(); } } } } 以上所述是小編給大家介紹的Java Socket實現(xiàn)一個簡易在線聊天功能（一）的相關知識，希望對大家有所幫助，如果大家有任何疑問請給我留言，小編會及時回復大家的。在此也非常感謝大家對武林網網站的支持！
新聞熱點
疑難解答
