如何用Java实现简单的聊天室功能-java教程-PHP中文网

如何用Java实现简单的聊天室功能

P粉602998670

发布： 2025-10-04 15:12:02

原创

459人浏览过

答案：通过Java的Socket编程和多线程技术实现聊天室，服务器端使用ServerSocket监听端口，为每个客户端创建ClientHandler线程处理消息接收与广播，维护客户端输出流列表实现消息转发，客户端通过输入输出流与服务器通信，分别用独立线程处理消息发送与接收，支持多用户实时群聊，可扩展用户名、私聊等功能。

如何用java实现简单的聊天室功能

要实现一个简单的聊天室功能，核心是使用Java的网络编程和多线程技术。通过Socket建立客户端与服务器之间的连接，再利用多线程让服务器能同时处理多个用户的消息转发。下面是一个基础但完整的实现思路和代码结构。

1. 设计服务器端

服务器需要监听指定端口，接收多个客户端的连接请求，并为每个客户端分配一个独立线程来处理消息的读取和广播。

关键点：

使用ServerSocket监听端口
每有一个客户端连接，启动一个ClientHandler线程
维护一个共享的客户端输出流列表，用于消息广播

import java.io.*;
import java.net.*;
import java.util.*;

public class ChatServer {
    private static final int PORT = 12345;
    private List<PrintWriter> clientWriters = new ArrayList<>();

    public void start() {
        try (ServerSocket serverSocket = new ServerSocket(PORT)) {
            System.out.println("服务器已启动，等待客户端连接...");

            while (true) {
                Socket clientSocket = serverSocket.accept();
                System.out.println("有新客户端连接: " + clientSocket.getInetAddress());

                PrintWriter writer = new PrintWriter(clientSocket.getOutputStream(), true);
                clientWriters.add(writer);

                Thread handler = new ClientHandler(clientSocket, this);
                handler.start();
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    // 广播消息给所有客户端
    public void broadcast(String message, PrintWriter sender) {
        for (PrintWriter writer : clientWriters) {
            if (writer != sender) { // 不发回给自己
                writer.println(message);
            }
        }
    }

    // 移除断开的客户端
    public void removeClient(PrintWriter writer) {
        clientWriters.remove(writer);
    }

    public static void main(String[] args) {
        new ChatServer().start();
    }
}

登录后复制

2. 客户端处理线程

每个客户端连接后，服务器为其创建一个ClientHandler线程，负责接收该客户端发送的消息，并将其转发给其他用户。

立即学习“Java免费学习笔记（深入）”；

极简智能王

极简智能- 智能聊天AI绘画，还可以创作、编写、翻译、写代码等多种功能，满足用户生活和工作的多方面需求

查看详情

class ClientHandler extends Thread {
    private Socket socket;
    private ChatServer server;
    private PrintWriter writer;

    public ClientHandler(Socket socket, ChatServer server) {
        this.socket = socket;
        this.server = server;
    }

    public void run() {
        try (
            BufferedReader reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
        ) {
            writer = new PrintWriter(socket.getOutputStream(), true);

            String message;
            while ((message = reader.readLine()) != null) {
                if ("exit".equalsIgnoreCase(message)) {
                    break;
                }
                System.out.println("收到消息: " + message);
                server.broadcast(message, writer);
            }
        } catch (IOException e) {
            // 客户端断开
        } finally {
            server.removeClient(writer);
            try {
                socket.close();
            } catch (IOException e) {}
        }
    }
}

登录后复制

3. 编写客户端程序

客户端连接服务器，发送和接收消息。使用两个线程：一个用于读取用户输入并发送，另一个用于监听服务器发来的消息。

import java.io.*;
import java.net.*;

public class ChatClient {
    private static final String SERVER_ADDRESS = "localhost";
    private static final int SERVER_PORT = 12345;

    public void start() {
        try (
            Socket socket = new Socket(SERVER_ADDRESS, SERVER_PORT);
            BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
            PrintWriter out = new PrintWriter(socket.getOutputStream(), true);
            BufferedReader console = new BufferedReader(new InputStreamReader(System.in));
        ) {

            // 接收服务器消息的线程
            Thread receiver = new Thread(() -> {
                try {
                    String message;
                    while ((message = in.readLine()) != null) {
                        System.out.println("[群聊] " + message);
                    }
                } catch (IOException e) {
                    System.out.println("连接已断开");
                }
            });
            receiver.start();

            // 发送消息
            System.out.println("输入消息开始聊天（输入exit退出）：");
            String input;
            while ((input = console.readLine()) != null) {
                out.println(input);
                if ("exit".equalsIgnoreCase(input)) {
                    break;
                }
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    public static void main(String[] args) {
        new ChatClient().start();
    }
}

登录后复制