Java中简易聊天室项目实现-java教程-PHP中文网

Java中简易聊天室项目实现

P粉602998670

发布： 2025-10-09 11:27:02

原创

541人浏览过

先运行服务器再启动多个客户端实现群聊。服务器监听8888端口，为每个客户端创建线程，接收消息并广播给其他客户端；客户端输入昵称后发送消息，通过独立线程接收广播消息，输入exit退出。

java中简易聊天室项目实现

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

客户端连接到服务器，输入消息发送，同时能接收来自服务器转发的其他客户端消息。

网易天音

网易出品！一站式音乐创作工具！零基础写歌！

查看详情

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

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();
    }
}

登录后复制