聊天室由服务器和多个客户端组成，服务器通过ServerSocket监听连接，为每个客户端启动线程处理通信；2. 服务器维护所有客户端的输出流，收到消息后广播给所有在线用户；3. 客户端使用双线程：一个发送用户输入，一个接收并显示服务器转发的消息；4. 运行时先启动服务器，再运行多个客户端实例，任意客户端发送消息均被广播，输入"bye"退出。
实现一个简单的Java聊天室，核心是使用Socket编程完成客户端与服务器之间的通信。通过多线程处理多个客户端连接，服务器能实时转发消息给所有在线用户。下面是一个基础但完整的实现思路和代码结构。
1. 聊天室的基本架构
系统由一个服务器端和多个客户端组成：
- 服务器：监听指定端口，接收客户端连接，并维护所有客户端的输出流，用于广播消息。
- 客户端：连接服务器，发送用户输入的消息，并持续监听来自服务器的消息并显示。
2. 服务器端实现
服务器使用ServerSocket监听端口，每有一个客户端连接就启动一个线程处理其消息，并将消息广播给其他客户端。
// ChatServer.java
import java.io.*;
import java.net.*;
import java.util.*;
public class ChatServer {
private static final int PORT = 12345;
private List clients = new ArrayList<>();
public void start() throws IOException {
ServerSocket serverSocket = new ServerSocket(PORT);
System.out.println("聊天室服务器已启动，等待客户端连接...");
while (true) {
Socket clientSocket = serverSocket.accept();
PrintWriter out = new PrintWriter(clientSocket.getOutputStream(), true);
clients.add(out);
new ClientHandler(clientSocket).start();
}
}
private void broadcast(String message) {
for (PrintWriter writer : clients) {
writer.println(message);
}
}
private class ClientHandler extends Thread {
private Socket socket;
private BufferedReader in;
public ClientHandler(Socket socket) {
this.socket = socket;
}
public void run() {
try {
in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
String message;
while ((message = in.readLine()) != null) {
System.out.println("收到消息: " + message);
broadcast(message);
}
} catch (IOException e) {
System.out.println("客户端断开连接");
} finally {
if (in != null) {
try {
in.close();
} catch (IOException e) { }
}
clients.removeIf(writer -> {
try {
// 判断是否异常或关闭
writer.checkError();
return false;
} catch (Exception e) {
return true;
}
});
}
}
}
public static void main(String[] args) {
try {
new ChatServer().start();
} catch (IOException e) {
e.printStackTrace();
}
}
}
3. 客户端实现
客户端连接到服务器，开启两个线程：一个用于读取用户输入并发送，另一个用于接收服务器广播的消息。
立即学习“Java免费学习笔记（深入）”；
// ChatClient.java
import java.io.*;
import java.net.*;
public class ChatClient {
private static final String SERVER_ADDRESS = "localhost";
private static final int PORT = 12345;
public void start() throws IOException {
Socket socket = new Socket(SERVER_ADDRESS, PORT);
PrintWriter out = new PrintWriter(socket.getOutputStream(), true);
// 接收消息的线程
new Thread(() -> {
try {
BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
String message;
while ((message = in.readLine()) != null) {
System.out.println("\n" + message);
}
} catch (IOException e) {
System.out.println("与服务器断开");
}
}).start();
// 发送消息的线程
BufferedReader console = new BufferedReader(new InputStreamReader(System.in));
String input;
while ((input = console.readLine()) != null) {
out.println(input);
if (input.equalsIgnoreCase("bye")) break;
}
socket.close();
}
public static void main(String[] args) {
try {
new ChatClient().start();
} catch (IOException e) {
e.printStackTrace();
}
}
}
4. 运行说明
步骤如下：
- 先运行ChatServer，启动服务器。
- 再运行多个ChatClient实例（可在不同终端）。
- 任意客户端输入文字后，所有客户端都会收到该消息。
- 输入"bye"可退出当前客户端。
基本上就这些。这个简单聊天室没有用户名、私聊等功能，但展示了网络通信和多线程协作的核心机制。后续可扩展添加昵称注册、在线列表、私信等特性。
