分析：
聊天室需要多個客戶端和一個服務端。
服務端負責轉發(fā)消息。
客戶端可以發(fā)送消息、接收消息。

消息分類：群聊消息：發(fā)送除自己外所有人私聊消息：只發(fā)送@的人系統(tǒng)消息：根據(jù)情況分只發(fā)送個人和其他人 技術方面：客戶端和服務端收發(fā)消息，需要使用IO流，封裝一個IOUtils工具類用來釋放資源。客戶端需要同時收發(fā)消息，需要啟動發(fā)送和接收兩個消息，互不干擾服務端需要接收每個客戶端消息和對多個客戶端發(fā)送消息，每連接上一個客戶端需要啟動一個線程，讓后面進來的客戶端不需要等待前面的客戶端退出后才能建立連接。

……

還是上代碼吧。

基礎版：

搭建結構，實現(xiàn)多個客戶端和服務端連接，保證服務端能正常轉發(fā)消息。
我們約定:
當服務端在初始化、發(fā)送、接收時出現(xiàn)異常時分別輸出：
------1------
------2------
------3------

當客戶端，初始化發(fā)送線程、初始化接收線程、發(fā)送、接收異常時分別輸出： ======1===== ======2===== ======3===== ======4=====

1、IO工具類

package com.xzlf.chat;import java.io.Closeable; import java.io.IOException;/*** 工具類* @author xzlf**/ public class IOUtils {/*** 釋放資源* @param closeables*/public static void close(Closeable...closeables) {for (Closeable closeable : closeables) {if(null != closeable) {try {closeable.close();} catch (IOException e) {e.printStackTrace();}}}} }

2、服務端

package com.xzlf.chat;import java.io.DataInputStream; import java.io.DataOutputStream; import java.io.IOException; import java.net.ServerSocket; import java.net.Socket;/*** 聊天室：服務器* @author xzlf**/ public class TMultiChat {public static void main(String[] args) throws IOException {System.out.println("======server======");// 1、指定端口創(chuàng)建服務端ServerSocket server = new ServerSocket(8888);while(true) {// 2、每進來一個客戶端啟動一個線程Socket socket = server.accept();System.out.println("一個客戶端建立了連接");new Thread(new Channel(socket)).start();}}// 一個Channel 代表一個客戶端static class Channel implements Runnable{private Socket socket;private DataInputStream dis;private DataOutputStream dos;private boolean isRuning;public Channel(Socket socket) {this.socket = socket;this.isRuning = true;try {dis = new DataInputStream(socket.getInputStream());dos = new DataOutputStream(socket.getOutputStream());} catch (IOException e) {System.out.println("------1------");this.release();}}// 接收消息private String receive() {String msg = "";try {msg = dis.readUTF();} catch (IOException e) {System.out.println("------3------");this.release();}return msg;}// 發(fā)送消息private void send(String msg) {try {dos.writeUTF(msg);} catch (IOException e) {System.out.println("------2------");this.release();}}// 釋放資源private void release() {this.isRuning = false;IOUtils.close(dis, dos, socket);}@Overridepublic void run() {while(isRuning) {String msg = this.receive();if (!msg.equals("")) {this.send(msg);}}}} }

3、多線程封裝發(fā)送端

package com.xzlf.chat;import java.io.BufferedReader; import java.io.DataInputStream; import java.io.DataOutputStream; import java.io.IOException; import java.io.InputStreamReader; import java.io.ObjectInputStream.GetField; import java.net.Socket;/*** 利用多線程封裝發(fā)送端* * @author xzlf**/ public class Send implements Runnable{private Socket socket;private DataOutputStream dos;private BufferedReader console;private boolean isRuning;public Send(Socket socket) {this.socket = socket;this.isRuning = true;try {console = new BufferedReader(new InputStreamReader(System.in));dos = new DataOutputStream(socket.getOutputStream());} catch (IOException e) {System.out.println("======1=====");this.release();}}// 從控制臺獲取消息private String getStrFromConsole() {try {return console.readLine();} catch (IOException e) {e.printStackTrace();}return "";}// 發(fā)送消息public void send(String msg) {try {dos.writeUTF(msg);dos.flush();} catch (IOException e) {e.printStackTrace();System.out.println("======3=====");this.release();}}// 釋放資源private void release() {this.isRuning = false;IOUtils.close(dos, console, socket);}@Overridepublic void run() {while(isRuning) {String msg = getStrFromConsole();if (!msg.equals("")) {this.send(msg);}}}}

4、多線程封裝接收端

package com.xzlf.chat;import java.io.DataInputStream; import java.io.IOException; import java.net.Socket;/*** 使用多線程封裝接收端* @author xzlf**/ public class Receive implements Runnable {private Socket socket;private DataInputStream dis;private boolean isRuning;public Receive(Socket socket) {this.socket = socket;this.isRuning = true;try {dis = new DataInputStream(socket.getInputStream());} catch (IOException e) {System.out.println("======2=====");this.release();}}// 接收消息public String receive() {String msg = "";try {msg = dis.readUTF();} catch (IOException e) {System.out.println(e);System.out.println("======4=====");release();}return msg;}// 釋放資源private void release() {this.isRuning = false;IOUtils.close(dis, socket);}@Overridepublic void run() {while(isRuning) {String msg = receive();if(!msg.equals("")) {System.out.println(msg);}}} }

5、客戶端

package com.xzlf.chat;import java.io.IOException; import java.net.Socket; import java.net.UnknownHostException;/*** 聊天室：客戶端* @author xzlf**/ public class TMultiClient {public static void main(String[] args) throws UnknownHostException, IOException {System.out.println("======client======");// 1、指定ip + 端口 建立連接Socket socket = new Socket("localhost", 8888);// 2、客戶端收發(fā)消息new Thread(new Send(socket)).start();new Thread(new Receive(socket)).start();} }

運行服務端和客戶端：

先每個客戶端只能自己跟自己聊。

實現(xiàn)群聊：

1、加入容器（使用JUC包下的并發(fā)容器CopyOnWriteArrayList），并添加給其他用戶發(fā)送消息方法
添加容器：

public class Chat {private static CopyOnWriteArrayList<Channel> all = new CopyOnWriteArrayList<Channel>();public static void main(String[] args) throws IOException {System.out.println("======server======");// 1、指定端口創(chuàng)建服務端ServerSocket server = new ServerSocket(8888);while(true) {// 2、每進來一個客戶端啟動一個線程Socket socket = server.accept();Channel c = new Channel(socket);all.add(c);System.out.println("一個客戶端建立了連接");new Thread(c).start();}} 添加群發(fā)方法 // 群聊：發(fā)送消息給其他人private void sendOthers(String msg, boolean isSys) {for(Channel other : all) {if(other == this) {continue;}if (!isSys) {// 群聊消息other.send(this.name + "說：" + msg);}else {// 系統(tǒng)消息other.send(msg);}}}

2、在初始化發(fā)送端，寫入自己用戶名并在初始化就發(fā)送
客戶端啟動時，輸入用戶名

public class Client {public static void main(String[] args) throws UnknownHostException, IOException {System.out.println("======client======");BufferedReader br = new BufferedReader(new InputStreamReader(System.in));System.out.print("請輸入用戶名:");String name = br.readLine();// 1、指定ip + 端口 建立連接Socket socket = new Socket("localhost", 8888);// 2、客戶端收發(fā)消息new Thread(new Send(socket, name)).start();new Thread(new Receive(socket)).start();} } 發(fā)送線程初始化時立馬發(fā)送用戶名： public class Send implements Runnable{private Socket socket;private DataOutputStream dos;private BufferedReader console;private boolean isRuning;private String name;public Send(Socket socket, String name) {this.socket = socket;this.name = name;try {this.isRuning = true;console = new BufferedReader(new InputStreamReader(System.in));dos = new DataOutputStream(socket.getOutputStream());// 發(fā)送用戶名this.send(name);} catch (IOException e) {System.out.println("======1=====");this.release();}} 服務端的channel類中初始化時立馬接收用戶名并保存

3、服務端（靜態(tài)內(nèi)部類Channel類中）在初始化時立即獲取用戶名并給用戶發(fā)送歡迎信息同時給其他用戶發(fā)提示信息（系統(tǒng)消息）

static class Channel implements Runnable{private Socket socket;private DataInputStream dis;private DataOutputStream dos;private boolean isRuning;private String name;public Channel(Socket socket) {this.socket = socket;this.isRuning = true;try {dis = new DataInputStream(socket.getInputStream());dos = new DataOutputStream(socket.getOutputStream());// 獲取用戶名this.name = receive();this.send("歡迎你的到來");this.sendOthers(this.name + "來了xxx聊天室", true);} catch (IOException e) {System.out.println("------1------");this.release();}}

4、用戶關閉線程，給其他用戶發(fā)送提示信息，提示用戶已離開

// 釋放資源private void release() {this.isRuning = false;IOUtils.close(dis, dos, socket);// 退出all.remove(this);sendOthers(this.name + "離開了聊天室。。。", true);}

運行測試：

實現(xiàn)私聊：

通過判斷用戶輸入信息是否包含“@xxx:”確定是否為私聊，修改群發(fā)方法：

/*** 群聊：獲取自己的信息，發(fā)送消息給其他人* 私聊：約定數(shù)據(jù)格式: @xxx:msg* @param msg* @param isSys*/private void sendOthers(String msg, boolean isSys) {if(msg.startsWith("@")) {// 私聊int endIndex = msg.indexOf("：");String targetName = msg.substring(1, endIndex);String info = msg.substring(endIndex + 1);for(Channel other : all) {if(other.name.equals(targetName)) {other.send(this.name + "悄悄對你說：" + info);}}}else {// 群聊for(Channel other : all) {if(other == this) {continue;}if (!isSys) {// 群聊消息other.send(this.name + "說：" + msg);}else {// 系統(tǒng)消息other.send(msg);}}}}

好了，現(xiàn)在已經(jīng)實現(xiàn)了私聊。
運行測試一下：

總結

以上是生活随笔為你收集整理的Java 网络编程 -- 基于TCP 实现聊天室 群聊 私聊的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。