Java中简易聊天室项目实现
先运行服务器再启动多个客户端实现群聊。服务器监听8888端口，为每个客户端创建线程，接收消息并广播给其他客户端；客户端输入昵称后发送消息，通过独立线程接收广播消息，输入exit退出。
实现一个简易的Java聊天室项目，主要涉及网络编程中的Socket通信、多线程处理多个客户端连接以及简单的I/O操作。下面是一个基础但完整的实现思路和代码结构，适合初学者理解和动手实践。
1. 项目结构与基本原理
该聊天室采用C/S（客户端-服务器）架构：
- 服务器端（Server）：监听指定端口，接收多个客户端的连接请求，并负责转发消息。
- 客户端（Client）：连接服务器，发送和接收消息。
- 多线程：每个客户端连接由独立线程处理，确保并发通信。
2. 服务器端实现
服务器启动后等待客户端接入，为每个客户端创建一个线程来处理消息收发，并将收到的消息广播给所有在线客户端。
import java.io.*;
import java.net.*;
import java.util.*;
public class ChatServer {
private static final int PORT = 8888;
private static Set clientWriters = new HashSet<>();
public static void main(String[] args) throws IOException {
ServerSocket serverSocket = new ServerSocket(PORT);
System.out.println("服务器已启动，等待客户端连接...");
while (true) {
Socket clientSocket = serverSocket.accept();
System.out.println("有新客户端连接: " + clientSocket.getInetAddress());
// 启动线程处理该客户端
new ClientHandler(clientSocket).start();
}
}
// 内部类：处理单个客户端的通信
private static class ClientHandler ext
ends Thread {
private Socket socket;
private PrintWriter out;
public ClientHandler(Socket socket) {
this.socket = socket;
}
public void run() {
try (
BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
PrintWriter out = new PrintWriter(socket.getOutputStream(), true);
) {
this.out = out;
// 将当前客户端的输出流加入集合
synchronized (clientWriters) {
clientWriters.add(out);
}
String message;
while ((message = in.readLine()) != null) {
if ("exit".equalsIgnoreCase(message)) {
break;
}
// 广播消息给所有客户端
broadcast(message, out);
}
} catch (IOException e) {
System.out.println("客户端断开: " + socket.getInetAddress());
} finally {
// 移除客户端
if (out != null) {
synchronized (clientWriters) {
clientWriters.remove(out);
}
}
try {
socket.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
}
// 向所有客户端发送消息（除了发送者）
private static void broadcast(String message, PrintWriter sender) {
synchronized (clientWriters) {
for (PrintWriter writer : clientWriters) {
if (writer != sender) {
writer.println(message);
}
}
}
}
}
ends Thread {
private Socket socket;
private PrintWriter out;
public ClientHandler(Socket socket) {
this.socket = socket;
}
public void run() {
try (
BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
PrintWriter out = new PrintWriter(socket.getOutputStream(), true);
) {
this.out = out;
// 将当前客户端的输出流加入集合
synchronized (clientWriters) {
clientWriters.add(out);
}
String message;
while ((message = in.readLine()) != null) {
if ("exit".equalsIgnoreCase(message)) {
break;
}
// 广播消息给所有客户端
broadcast(message, out);
}
} catch (IOException e) {
System.out.println("客户端断开: " + socket.getInetAddress());
} finally {
// 移除客户端
if (out != null) {
synchronized (clientWriters) {
clientWriters.remove(out);
}
}
try {
socket.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
}
// 向所有客户端发送消息（除了发送者）
private static void broadcast(String message, PrintWriter sender) {
synchronized (clientWriters) {
for (PrintWriter writer : clientWriters) {
if (writer != sender) {
writer.println(message);
}
}
}
}
}
3. 客户端实现
客户端连接到服务器，输入消息发送，同时能接收来自服务器转发的其他客户端消息。
import java.io.*;
import java.net.*;
public class ChatClient {
private static final String SERVER_ADDRESS = "localhost";
private static final int PORT = 8888;
public static void main(String[] args) throws IOException {
Socket socket = new Socket(SERVER_ADDRESS, PORT);
// 输入输出流
BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
PrintWriter out = new PrintWriter(socket.getOutputStream(), true);
BufferedReader consoleInput = new BufferedReader(new InputStreamReader(System.in));
System.out.print("请输入昵称: ");
String nickname = consoleInput.readLine();
System.out.println("欢迎进入聊天室，" + nickname + "！输入 'exit' 退出。");
// 接收服务器消息的线程
new Thread(() -> {
try {
String received;
while ((received = in.readLine()) != null) {
System.out.println(received);
}
} catch (IOException e) {
System.out.println("连接中断");
}
}).start();
// 发送消息主线程
String input;
while ((input = consoleInput.readLine()) != null) {
out.println(nickname + ": " + input);
if ("exit".equalsIgnoreCase(input)) {
break;
}
}
socket.close();
}
}
4. 运行说明
- 先运行 ChatServer，启动服务器。
- 再运行多个 ChatClient 实例，模拟不同用户登录。
- 在客户端输入消息，所有其他客户端都能看到（广播）。
- 输入 exit 可安全退出客户端。
基本上就这些。这个简易聊天室实现了基本的群聊功能，适合学习Java网络编程和多线程协作。后续可扩展的功能包括私聊、用户名管理、图形界面（Swing/JavaFX）、消息记录等。
