Java客户端-服务器程序客户端异常终止问题求助

核心问题排查与修复方案 #

1. 客户端异常被完全吞噬，无法定位错误 #

客户端构造函数的catch块为空，所有连接失败、IO异常、GUI初始化异常都会被隐藏，导致程序无声终止。
修复： 在客户端构造函数的catch块中添加异常打印：

catch (Exception e) {
    e.printStackTrace(); // 打印异常栈，定位问题根源
    JOptionPane.showMessageDialog(null, "客户端初始化失败：" + e.getMessage());
    System.exit(1);
}

2. Swing组件未在事件调度线程(EDT)中创建 #

Swing是单线程模型，所有GUI操作必须在EDT线程执行，直接在main线程创建GUI会导致不稳定甚至崩溃。
修复： 修改客户端main方法，用SwingUtilities.invokeLater启动GUI：

public static void main(String[] args) {
    System.out.println("This is Client...");
    SwingUtilities.invokeLater(() -> new Client()); // 在EDT线程创建客户端
}

3. 服务器仅支持单客户端连接 #

服务器仅调用一次server.accept()，处理完一个客户端断开后，无法接受新连接，导致后续客户端连接请求被挂起，看似自行终止。
修复： 服务器构造函数中添加循环，持续接受新客户端：

public Server() {
    try {
        server = new ServerSocket(56473);
        System.out.println("Server is ready to accept connection!");
        while (true) { // 循环接受新客户端
            System.out.println("Waiting...");
            socket = server.accept();
            System.out.println("New client connected!");

            br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
            out = new PrintWriter(socket.getOutputStream());

            startReading();
            startWriting();
        }
    } catch (Exception e) {
        e.printStackTrace();
    }
}

4. 客户端图片加载失败可能触发未捕获异常 #

客户端中heading.setIcon(new ImageIcon("clogo.jpg"));若图片不存在或路径错误，会触发异常，被空catch块吞噬导致GUI初始化失败。
修复： 要么确保图片在正确路径，要么暂时注释图片加载代码测试：

// 暂时注释图片加载，先确保GUI正常运行
// heading.setIcon(new ImageIcon("clogo.jpg"));

5. 客户端读取线程中br.readLine()返回null未处理 #

当服务器断开连接时，br.readLine()会返回null，此时调用msg.equals("exit")会触发NullPointerException，导致线程终止，若主线程已退出，进程可能终止。
修复： 在读取线程中先判断msg是否为null：

String msg = br.readLine();
if (msg == null) { // 服务器断开连接
    System.out.println("Server disconnected!");
    JOptionPane.showMessageDialog(Client.this, "Server disconnected!");
    messageInput.setEnabled(false);
    socket.close();
    break;
}
if (msg.equals("exit")) {
    // 原有逻辑
}

修改后的关键代码片段 #

客户端main方法与构造函数修改 #

public static void main(String[] args) {
    System.out.println("This is Client...");
    SwingUtilities.invokeLater(() -> new Client());
}

public Client() {
    try {
        System.out.println("Sending Request to Server");
        socket = new Socket("192.168.43.245", 56473);
        System.out.println("Connection Done!");

        br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
        out = new PrintWriter(socket.getOutputStream());

        createGUI();
        handleEvents();
        startReading();
    } catch (Exception e) {
        e.printStackTrace();
        JOptionPane.showMessageDialog(null, "客户端连接失败：" + e.getMessage());
        System.exit(1);
    }
}

客户端读取线程修改 #

public void startReading() {
    Runnable r1 = () -> {
        System.out.println("Reader Started...");
        try {
            while (true) {
                String msg = br.readLine();
                if (msg == null) {
                    System.out.println("Server disconnected!");
                    JOptionPane.showMessageDialog(Client.this, "Server disconnected!");
                    messageInput.setEnabled(false);
                    socket.close();
                    break;
                }
                if (msg.equals("exit")) {
                    System.out.println("Server terminated the chat!");
                    JOptionPane.showMessageDialog(Client.this, "Server Terminated the Chat!");
                    messageInput.setEnabled(false);
                    socket.close();
                    break;
                }
                messageArea.append("Server : " + msg + "\n");
            }
        } catch (Exception e) {
            e.printStackTrace();
            System.out.println("Connection Closed!");
        }
    };
    new Thread(r1).start();
}

服务器构造函数修改 #

public Server() {
    try {
        server = new ServerSocket(56473);
        System.out.println("Server is ready to accept connection!");
        while (true) {
            System.out.println("Waiting...");
            socket = server.accept();
            System.out.println("New client connected!");

            br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
            out = new PrintWriter(socket.getOutputStream());

            startReading();
            startWriting();
        }
    } catch (Exception e) {
        e.printStackTrace();
    }
}

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