17370845950

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

实现一个简单的Java聊天室，核心是使用Socket编程完成客户端与服务器之间的通信。通过多线程处理多个客户端连接，服务器能实时转发消息给所有在线用户。下面是一个基础但完整的实现思路和代码结构。

1. 聊天室的基本架构

系统由一个服务器端和多个客户端组成：

• 服务器：监听指定端口，接收客户端连接，并维护所有客户端的输出流，用于广播消息。
• 客户端：连接服务器，发送用户输入的消息，并持续监听来自服务器的消息并显示。

2. 服务器端实现

服务器使用ServerSocket监听端口，每有一个客户端连接就启动一个线程处理其消息，并将消息广播给其他客户端。

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. 客户端实现

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

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"可退出当前客户端。

基本上就这些。这个简单聊天室没有用户名、私聊等功能，但展示了网络通信和多线程协作的核心机制。后续可扩展添加昵称注册、在线列表、私信等特性。