本文實例為大家分享了java群聊功能，供大家參考，具體內容如下
Java 對TCP協議的支持：
--> java.net包中定義了兩個類ServerSocket 和Socket ，分別用來實現雙向連接的server 端和client 端。
--> Client 類定義客戶端
package com.dragon.java.tcpchat;import java.io.IOException;import java.net.Socket;import java.net.UnknownHostException;/** * 客戶端* * @author Auser * */public class Client { public static void main(String args[]) throws UnknownHostException, IOException { Socket client = new Socket("192.168.1.188", 10000); // 穿件發送信息的線程new ClientSend(client).start(); // 創建接收信息的線程new ClientReceive(client).start(); // 因為要實現聊天功能，而不是只發送一次信息，所以輸出流和客戶端都不能關閉。 // client.shutdownOutput(); // client.close(); }}--> ClientSend 類定義客戶端向服務端發送信息的線程
package com.dragon.java.tcpchat;import java.io.IOException;import java.io.PrintStream;import java.net.Socket;import java.util.Scanner;/** * 客戶端向服務端發送信息的線程* * @author Auser * */public class ClientSend extends Thread { private Scanner scanner; private Socket socket; public ClientSend(Socket socket) { this.socket = socket; } @Override public void run() { scanner = new Scanner(System.in); try { PrintStream ps = new PrintStream(socket.getOutputStream()); String line = ""; // 阻塞式發送信息while ((line = scanner.nextLine()) != null) { ps.println(line); } } catch (IOException e) { e.printStackTrace(); } }}--> ClientReceive 類定義客戶端接收服務端信息的線程
package com.dragon.java.tcpchat;import java.io.BufferedReader;import java.io.InputStreamReader;import java.net.Socket;/** * 客戶端接收信息的線程* * @author Auser * */public class ClientReceive extends Thread { private Socket socket; public ClientReceive(Socket socket) { this.socket = socket; } @Override public void run() { try { BufferedReader br = new BufferedReader(new InputStreamReader( socket.getInputStream())); // 按行接收信息String line = ""; while ((line = br.readLine()) != null) { System.out.println(line); } } catch (Exception e) { e.printStackTrace(); } }}--> Server 類定義服務端
package com.dragon.java.tcpchat;import java.io.IOException;import java.net.ServerSocket;import java.net.Socket;import java.util.ArrayList;import java.util.List;/** * 服務器* * @author Auser * */public class Server { public static void main(String[] args) throws IOException, InterruptedException { List<Socket> list = new ArrayList<>(); // 創建服務器端的套接字ServerSocket server = new ServerSocket(10000); while (true) { // 接收客戶端的阻塞方法Socket socket = server.accept(); // 設計到多個線程可能會對集合進行增刪的操作，要進行同步的處理synchronized (list) { list.add(socket); } // 啟動一個新的線程去處理這個客戶端的交流new HandleSocket(socket, list).start(); } // 因為不知道客戶端什麼時候發送信息，所以服務端要一直開啟不能關閉。 }}--> HandleSocket 類對連接到服務端的客戶端進行操作(上下線通知、屏蔽拉黑、將信息發送到每個客戶端等...)
package com.dragon.java.tcpchat;import java.io.BufferedReader;import java.io.IOException;import java.io.InputStreamReader;import java.io.PrintStream;import java.net.InetAddress;import java.net.Socket;import java.util.List;/** * 處理每個(單個)連接到服務器的客戶端的線程* * @author Auser * */public class HandleSocket extends Thread { private Socket socket; private List<Socket> list; /** * 構造方法* * @param socket * 當前連接的客戶端* @param list * 存儲已連接客戶端的集合*/ public HandleSocket(Socket socket, List<Socket> list) { this.socket = socket; this.list = list; } /** * 線程run方法*/ @Override public void run() { InetAddress address = socket.getInetAddress(); // 獲取連接到服務器的這的客戶端的地址String ip = address.getHostAddress(); System.out.println(ip + "上線了！"); if (ip.equals("192.168.1.117")) { synchronized (list) { sendToAll(ip + "由於違規操作，已被拉入黑名單！"); list.remove(socket); } return; } try { BufferedReader br = new BufferedReader(new InputStreamReader( socket.getInputStream(), "gbk")); String line = ""; while ((line = br.readLine()) != null) { String msg = ip + ":" + line; System.out.println(msg); // 輸出到服務器端的控制台// 把這個客戶端說的話，發給其他所有的客戶端sendToAll(msg); } } catch (IOException e) { // e.printStackTrace(); System.out.println(ip + "下線了！ "); synchronized (list) { list.remove(socket); } } } /** * 把信息發送給所有的客戶端，去除當前socket * * @param msg * 發送的信息*/ private void sendToAll(String msg) { synchronized (list) { for (Socket s : list) { if (s != socket) { try { PrintStream ps = new PrintStream(s.getOutputStream()); ps.println(); } catch (IOException e) { e.printStackTrace(); } } } } }} --> 注意：因為要實現客戶端連接到服務端，即客戶端要先找到服務端，所以服務端要先開啟，再開啟服務端...
以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持武林網。