基于Java的群聊服务器问题：客户端无法互显消息（JDBC尝试失败）

Hey there! Let's break down your group chat problem step by step—first off, the core issue is that your server isn't relaying messages between clients, which is why no one can see each other's messages. Trying to add JDBC right now was probably overcomplicating things; let's fix the basic message routing first, then we can talk about persistence if you need it.

First, let's spot the key gaps in your current code: #

• Your ChatServer tracks connected clients, but there's no logic to broadcast incoming messages from one client to all others
• The ClientThread (which handles individual client connections) is missing code to read messages from the client and pass them to the server for broadcasting
• Your client's ServerThread needs to properly receive messages from the server and update the GUI safely
• Also, you accidentally duplicated the entire ChatServer class—make sure to delete one of those copies!

Let's fix the server-side broadcast logic #

First, add a broadcast method to your ChatServer that sends a message to every connected client:

public void broadcastMessage(String senderName, String message) {
    String formattedMessage = String.format("[%s] %s", senderName, message);
    // Loop through all connected clients and send the message
    for (ClientThread client : clients) {
        client.sendMessage(formattedMessage);
    }
}

Next, fix the ClientThread to handle message reading and forwarding #

This class is the bridge between a single client and the server. It needs to read messages from the client, then trigger the server's broadcast:

public class ClientThread implements Runnable {
    private ChatServer server;
    private Socket socket;
    private BufferedReader inputReader;
    private PrintWriter outputWriter;
    private String clientUsername;

    public ClientThread(ChatServer server, Socket socket) {
        this.server = server;
        this.socket = socket;
        try {
            inputReader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
            outputWriter = new PrintWriter(socket.getOutputStream(), true);
            // Read the username the client sends right after connecting
            this.clientUsername = inputReader.readLine();
        } catch (IOException e) {
            System.err.println("Failed to initialize client thread: " + e.getMessage());
            e.printStackTrace();
        }
    }

    @Override
    public void run() {
        String incomingMessage;
        try {
            // Listen for messages from the client until the connection closes
            while ((incomingMessage = inputReader.readLine()) != null) {
                // Pass the message to the server to broadcast to everyone else
                server.broadcastMessage(clientUsername, incomingMessage);
            }
        } catch (IOException e) {
            System.err.println("Client disconnected: " + socket.getRemoteSocketAddress());
        } finally {
            // Clean up: remove client from server's list and close the socket
            server.getClients().remove(this);
            try {
                socket.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }

    // Send a message from the server to this client
    public void sendMessage(String message) {
        outputWriter.println(message);
    }
}

Update the client's ServerThread to receive and display messages #

Your client needs to safely update the Swing GUI (always use SwingUtilities.invokeLater for GUI updates to avoid thread issues):

public class ServerThread implements Runnable {
    private Socket socket;
    private BufferedReader serverReader;
    private PrintWriter serverWriter;
    private String username;

    public ServerThread(Socket socket, String username) {
        this.socket = socket;
        this.username = username;
        try {
            serverReader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
            serverWriter = new PrintWriter(socket.getOutputStream(), true);
            // Send the username to the server immediately after connecting
            serverWriter.println(username);
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    @Override
    public void run() {
        String serverMessage;
        try {
            // Listen for messages from the server and display them
            while ((serverMessage = serverReader.readLine()) != null) {
                SwingUtilities.invokeLater(() -> {
                    Client.output.append(serverMessage + "\n");
                });
            }
        } catch (IOException e) {
            System.err.println("Lost connection to the chat server");
        }
    }

    // Send a user's input message to the server
    public void addNextMessage(String message) {
        serverWriter.println(message);
    }
}

A note about JDBC: #

Right now, adding JDBC is adding unnecessary complexity. You're still working out the core message routing—once that's stable, you can add code to persist messages to a database (e.g., call a JDBC insert method inside the broadcastMessage function). But trying to do both at once leads to the errors you're seeing, since JDBC requires handling connections, exceptions, and thread safety that's unrelated to your current problem.

Test these changes first—you should see clients receiving each other's messages once this is set up correctly!

内容的提问来源于stack exchange，提问作者user9424128