手撸一个java简易聊天室

创建一个Java聊天室涉及到网络编程、多线程处理以及用户界面设计。这里我将提供一个简单的Java聊天室实现，包括服务器端和客户端的基本逻辑。
服务器端
服务器端负责接收客户端的消息，并将其广播给所有连接的客户端。
java
复制
import java.io.;
import java.net.;
import java.util.*;

public class ChatServer {
private static final int PORT = 6789;
private static List clients = Collections.synchronizedList(new ArrayList<>());

public static void main(String[] args) throws IOException {
    ServerSocket serverSocket = new ServerSocket(PORT);
    System.out.println("Chat server started on port " + PORT);

    while (true) {
        try (Socket clientSocket = serverSocket.accept()) {
            System.out.println("New client connected: " + clientSocket.getRemoteSocketAddress());
            ClientHandler clientHandler = new ClientHandler(clientSocket);
            clients.add(clientHandler);
            clientHandler.start();
        }
    }
}

public static void broadcastMessage(String message) {
    for (ClientHandler client : clients) {
        client.sendMessage(message);
    }
}

private static class ClientHandler extends Thread {
    private Socket clientSocket;
    private PrintWriter out;

    public ClientHandler(Socket socket) {
        this.clientSocket = socket;
    }

    @Override
    public void run() {
        try {
            BufferedReader in = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
            out = new PrintWriter(clientSocket.getOutputStream(), true);

            String inputLine;
            while ((inputLine = in.readLine()) != null) {
                broadcastMessage(inputLine);
            }
        } catch (IOException e) {
            System.out.println("Error in client handler: " + e.getMessage());
        } finally {
            try {
                clientSocket.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
            clients.remove(this);
        }
    }

    public void sendMessage(String message) {
        out.println(message);
    }
}

}
客户端
客户端负责连接服务器，发送消息，并接收服务器广播的消息。
java
复制
import java.io.;
import java.net.;
import java.util.Scanner;

public class ChatClient {
private static final String HOST = “localhost”;
private static final int PORT = 6789;

public static void main(String[] args) throws IOException {
    try (Socket socket = new Socket(HOST, PORT);
         PrintWriter out = new PrintWriter(socket.getOutputStream(), true);
         BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
         Scanner scanner = new Scanner(System.in)) {

        System.out.println("Connected to the chat server");

        // Receive messages from the server
        new Thread(() -> {
            try {
                String inputLine;
                while ((inputLine = in.readLine()) != null) {
                    System.out.println(inputLine);
                }
            } catch (IOException e) {
                e.printStackTrace();
            }
        }).start();

        // Send messages to the server
        while (scanner.hasNextLine()) {
            String userMessage = scanner.nextLine();
            out.println(userMessage);
        }
    }
}

}
运行说明
首先运行 ChatServer 类，它将启动服务器并等待客户端连接。
然后运行一个或多个 ChatClient 实例，它们将连接到服务器并允许用户输入消息。
用户在客户端输入的消息将被发送到服务器，服务器将广播给所有连接的客户端。
注意事项
这个聊天室实现是多线程的，每个客户端连接都会创建一个新的线程。
客户端和服务器之间的通信使用TCP协议。
这个实现是基本的，没有考虑异常处理、断线重连、用户身份验证等高级特性。
为了更好的用户体验，你可以考虑添加图形用户界面(GUI)，使用Swing或JavaFX等库。
这个聊天室是一个基础的示例，可以根据你的需要进行扩展和改进。