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

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

P粉602998670

发布： 2025-10-26 23:55:01

原创

567人浏览过

聊天室由服务器和多个客户端组成，服务器通过ServerSocket监听连接，为每个客户端启动线程处理通信；2. 服务器维护所有客户端的输出流，收到消息后广播给所有在线用户；3. 客户端使用双线程：一个发送用户输入，一个接收并显示服务器转发的消息；4. 运行时先启动服务器，再运行多个客户端实例，任意客户端发送消息均被广播，输入"bye"退出。

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

实现一个简单的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<PrintWriter> 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. 客户端实现

客户端连接到服务器，开启两个线程：一个用于读取用户输入并发送，另一个用于接收服务器广播的消息。

Grammarly

Grammarly是一款在线语法纠正和校对工具，伟大的AI辅助写作工具

253

查看详情

立即学习“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();
        }
    }
}

登录后复制