網頁版在線聊天java Socket實現

本文為大家分享了一個滿足在線網頁交流需求的實例，由於java Socket實現的網頁版在線聊天功能，供大家參考，具體內容如下

實現步驟：
1、使用awt組件和socket實現簡單的單客戶端向服務端持續發送消息；
2、結合線程，實現多客戶端連接服務端發送消息；
3、實現服務端轉發客戶端消息至所有客戶端，同時在客戶端顯示；
4、把awt組件生成的窗口界面改成前端jsp或者html展示的界面，java socket實現的客戶端改為前端技術實現。

這里首先實現第一步的簡單功能，難點在於：
1、沒有用過awt組件，沒有用過java相關的監聽事件；
2、長時間沒有使用socket進行客戶端和服務端的交互，並且沒有真正進行過cs結構的開發。

實現功能的代碼：
在線聊天客戶端：
1、生成圖形窗口界面輪廓
2、為輪廓添加關閉事件
3、在輪廓中加入輸入區域和內容展示區域
4、為輸入區域添加回車事件
5、建立服務端連接並發送數據

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、在輪廓中加入輸入區域和內容展示區域4、為輸入區域添加回車事件* 5、建立服務端連接並發送數據* * @author tuzongxun123 * */ public class ChatClient extends Frame { // 用戶輸入區域private TextField tfTxt = new TextField(); // 內容展示區域private TextArea tarea = new TextArea(); private Socket socket = null; // 數據輸出流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(); // 監聽圖形界面窗口的關閉事件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(); } } /** * 向服務端發送消息* * @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(); } } /** * 圖形窗口輸入區域監聽回車事件* * @author tuzongxun123 * */ private class TFLister implements ActionListener { @Override public void actionPerformed(ActionEvent e) { String text = tfTxt.getText().trim(); tarea.setText(text); tfTxt.setText(""); // 回車後發送數據到服務器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組件簡單實現在線聊天功能服務端可以實現一個客戶端連接後不斷向服務端發送消息* 但不支持多個客戶端同時連接，原因在於代碼中獲得客戶端連接後會一直循環監聽客戶端輸入，造成阻塞* 以至於服務端無法二次監聽另外的客戶端，如要實現，需要使用異步或者多線程* * @author tuzongxun123 * */ public class ChatServer { public static void main(String[] args) { // 是否成功啟動服務端boolean isStart = false; // 服務端socket ServerSocket ss = null; // 客戶端socket Socket socket = null; // 服務端讀取客戶端數據輸入流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; // 啟動監聽socket = ss.accept(); System.out.println("one client connect"); isConnect = true; while (isConnect) { // 獲取客戶端輸入流dataInputStream = new DataInputStream( socket.getInputStream()); // 讀取客戶端傳遞的數據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(); } } } }

繼續，在單客戶端連接的基礎上，這裡第二步需要實現多客戶端的連接，也就需要使用到線程。每當有一個新的客戶端連接上來，服務端便需要新啟動一個線程進行處理，從而解決之前的循環讀取中造成阻塞的問題。

寫線程通常有兩種方法，集成Thread或者實現runnable接口，原則上是能實現runnable的情況下就不繼承，因為實現接口的方式更加靈活。

客戶端代碼相較之前沒有變化，變得是服務端，因此這里便只貼出服務端代碼：

java使用socket和awt組件以及多線程簡單實現在線聊天功能服務端：

實現多個客戶端連接後不斷向服務端發送消息， 相對於第一個版本，重點在於使用了多線程。服務端還未實現轉發功能，客戶端圖形窗口中只能看到自己輸入的信息，不能看到其他客戶端發送的消息。

 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; import java.net.SocketException; /** * * * @author tuzongxun123 * */ public class ChatServer { public static void main(String[] args) { new ChatServer().start(); } // 是否成功啟動服務端private boolean isStart = false; // 服務端socket private ServerSocket ss = null; // 客戶端socket private Socket socket = null; public void start() { try { // 啟動服務器ss = new ServerSocket(8888); } catch (BindException e) { System.out.println("端口已在使用中"); // 關閉程序System.exit(0); } catch (Exception e) { e.printStackTrace(); } try { isStart = true; while (isStart) { // 啟動監聽socket = ss.accept(); System.out.println("one client connect"); // 啟動客戶端線程Client client = new Client(socket); new Thread(client).start(); } } catch (Exception e) { e.printStackTrace(); } finally { // 關閉服務try { ss.close(); } catch (IOException e) { e.printStackTrace(); } } } /** * 客戶端線程* * @author tuzongxun123 * */ class Client implements Runnable { // 客戶端socket private Socket socket = null; // 客戶端輸入流private DataInputStream dataInputStream = null; private boolean isConnect = false; public Client(Socket socket) { this.socket = socket; try { isConnect = true; // 獲取客戶端輸入流dataInputStream = new DataInputStream(socket.getInputStream()); } catch (IOException e) { e.printStackTrace(); } } @Override public void run() { isConnect = true; try { while (isConnect) { // 讀取客戶端傳遞的數據String message = dataInputStream.readUTF(); System.out.println("客戶端說：" + message); } } catch (EOFException e) { System.out.println("client closed!"); } catch (SocketException e) { System.out.println("Client is Closed!!!!"); } catch (Exception e) { e.printStackTrace(); } finally { // 關閉相關資源try { dataInputStream.close(); socket.close(); } catch (IOException e) { e.printStackTrace(); } } } } }

上面主要介紹了利用線程使服務端實現了能夠接收多客戶端請求的功能，這里便需要客戶端接收多客戶端消息的同時還能把消息轉發到每個連接的客戶端，並且客戶端要能在內容顯示區域顯示出來，從而實現簡單的在線群聊。

在實現客戶端轉發，無非就是增加輸出流；而之前客戶端都只發不收，這裡也需要更改客戶端達到循環接收服務端消息的目的，因此也需要實現多線程。

在實現這個功能的時候，偶然想起隨機生成驗證碼的功能，於是也靈機一動隨機給每個客戶端生成一個名字，從而在輸出的時候看起來更加像是群聊，不僅有消息輸出，還能看到是誰。

實現這些功能之後，基本上就可以幾個人同時在線群聊了，因為代碼中有main方法，因此可以把服務端和客戶端都打成可執行jar包，可參考我的另一篇博文：使用eclipse創建java程序可執行jar包

之後在桌面雙擊相應的jar文件啟動服務端和客戶端即可，不需要再依賴eclipse運行。

修改後的客戶端代碼如下：

 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.DataInputStream; import java.io.DataOutputStream; import java.io.IOException; import java.net.Socket; import java.net.UnknownHostException; import java.util.Random; /** * 在線聊天客戶端步驟： *1、生成圖形窗口界面輪廓*2、為輪廓添加關閉事件*3、在輪廓中加入輸入區域和內容展示區域*4、為輸入區域添加回車事件* 5、建立服務端連接並發送數據* * @author tuzongxun123 * */ public class ChatClient extends Frame { /** * */ private static final long serialVersionUID = 1L; // 用戶輸入區域private TextField tfTxt = new TextField(); // 內容展示區域private TextArea tarea = new TextArea(); private Socket socket = null; // 數據輸出流private DataOutputStream dataOutputStream = null; // 數據輸入流private DataInputStream dataInputStream = null; private boolean isConnect = false; Thread tReceive = new Thread(new ReceiveThread()); String name = ""; public static void main(String[] args) { ChatClient chatClient = new ChatClient(); chatClient.createName(); 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); // 根據窗口裡面的佈局及組件的preferedSize來確定frame的最佳大小pack(); // 監聽圖形界面窗口的關閉事件this.addWindowListener(new WindowAdapter() { @Override public void windowClosing(WindowEvent e) { System.exit(0); disConnect(); } }); tfTxt.addActionListener(new TFLister()); // 設置窗口可見setVisible(true); connect(); // 啟動接受消息的線程tReceive.start(); } /** * 連接服務器* * @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()); dataInputStream = new DataInputStream(socket.getInputStream()); System.out.println("連上服務端"); isConnect = true; } catch (UnknownHostException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } } // 生成隨機的客戶端名字public void createName() { String[] str1 = { "a", "b", "c", "d", "e", "f", "g", "h", "i", "j", "k", "l", "m", "n", "o", "p", "q", "r", "s", "t", "u", "v", "w", "x", "y", "z", "1", "2", "3", "4", "5", "6", "7", "8", "9", "0", "A", "B", "C", "D", "E", "F", "G", "H", "I", "J", "K", "L", "M", "N", "O", "P", "Q", "R", "S", "T", "U", "V", "W", "X", "Y", "Z" }; Random ran = new Random(); for (int i = 0; i < 6; i++) { // long num = Math.round(Math.random() * (str1.length - 0) + 0); // int n = (int) num; int n = ran.nextInt(str1.length); if (n < str1.length) { String str = str1[n]; name = name + str; System.out.println(name); } else { i--; continue; } } this.setTitle(name); } /** * 關閉客戶端資源* * @author：tuzongxun * @Title: disConnect * @param * @return void * @date May 18, 2016 9:57:46 AM * @throws */ public void disConnect() { try { isConnect = false; // 停止線程tReceive.join(); } catch (InterruptedException e) { e.printStackTrace(); } finally { try { if (dataOutputStream != null) { dataOutputStream.close(); } if (socket != null) { socket.close(); socket = null; } } catch (IOException e) { e.printStackTrace(); } } } /** * 向服務端發送消息* * @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(name + ":" + text); dataOutputStream.flush(); } catch (IOException e1) { e1.printStackTrace(); } } /** * 圖形窗口輸入區域監聽回車事件* * @author tuzongxun123 * */ private class TFLister implements ActionListener { @Override public void actionPerformed(ActionEvent e) { String text = tfTxt.getText().trim(); // 清空輸入區域信息tfTxt.setText(""); // 回車後發送數據到服務器sendMessage(text); } } private class ReceiveThread implements Runnable { @Override public void run() { try { while (isConnect) { String message = dataInputStream.readUTF(); System.out.println(message); String txt = tarea.getText(); if (txt != null && !"".equals(txt.trim())) { message = tarea.getText() + "/n" + message; } tarea.setText(message); } } catch (IOException e) { e.printStackTrace(); } } } }

修改後的服務端代碼如下：

 package chat.chat; import java.io.DataInputStream; import java.io.DataOutputStream; import java.io.EOFException; import java.io.IOException; import java.net.BindException; import java.net.ServerSocket; import java.net.Socket; import java.net.SocketException; import java.util.ArrayList; import java.util.List; /** * java使用socket和awt組件以及多線程簡單實現在線聊天功能服務端： * 實現服務端把接收到的客戶端信息轉發到所有連接的客戶端，並且讓客戶端讀取到這些信息並顯示在內容顯示區域中。 * * @author tuzongxun123 * */ public class ChatServer { public static void main(String[] args) { new ChatServer().start(); } // 是否成功啟動服務端private boolean isStart = false; // 服務端socket private ServerSocket ss = null; // 客戶端socket private Socket socket = null; // 保存客戶端集合List<Client> clients = new ArrayList<Client>(); public void start() { try { // 啟動服務器ss = new ServerSocket(8888); } catch (BindException e) { System.out.println("端口已在使用中"); // 關閉程序System.exit(0); } catch (Exception e) { e.printStackTrace(); } try { isStart = true; while (isStart) { // 啟動監聽socket = ss.accept(); System.out.println("one client connect"); // 啟動客戶端線程Client client = new Client(socket); new Thread(client).start(); clients.add(client); } } catch (Exception e) { e.printStackTrace(); } finally { // 關閉服務try { ss.close(); } catch (IOException e) { e.printStackTrace(); } } } /** * 客戶端線程* * @author tuzongxun123 * */ private class Client implements Runnable { // 客戶端socket private Socket socket = null; // 客戶端輸入流private DataInputStream dataInputStream = null; // 客戶端輸出流private DataOutputStream dataOutputStream = null; private boolean isConnect = false; public Client(Socket socket) { this.socket = socket; try { isConnect = true; // 獲取客戶端輸入流dataInputStream = new DataInputStream(socket.getInputStream()); // 獲取客戶端輸出流dataOutputStream = new DataOutputStream( socket.getOutputStream()); } catch (IOException e) { e.printStackTrace(); } } /** * 向客戶端群發（轉發）數據* * @author：tuzongxun * @Title: sendMessageToClients * @param @param message * @return void * @date May 18, 2016 11:28:10 AM * @throws */ public void sendMessageToClients(String message) { try { dataOutputStream.writeUTF(message); } catch (SocketException e) { } catch (IOException e) { e.printStackTrace(); } } @Override public void run() { isConnect = true; Client c = null; try { while (isConnect) { // 讀取客戶端傳遞的數據String message = dataInputStream.readUTF(); System.out.println("客戶端說：" + message); for (int i = 0; i < clients.size(); i++) { c = clients.get(i); c.sendMessageToClients(message); } } } catch (EOFException e) { System.out.println("client closed!"); } catch (SocketException e) { if (c != null) { clients.remove(c); } System.out.println("Client is Closed!!!!"); } catch (Exception e) { e.printStackTrace(); } finally { // 關閉相關資源try { if (dataInputStream != null) { dataInputStream.close(); } if (socket != null) { socket.close(); socket = null; } } catch (IOException e) { e.printStackTrace(); } } } } }

就先為大家介紹到這裡，之後如果有新的內容再為大家進行更新。

關於網頁在線聊天功能的實現大，大家還可以參考一下幾篇文章進行學習：

java實現一個簡單TCPSocket聊天室功能分享

以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家可以繼續關注武林網的更多精彩內容。