Java多线程TCP服务器执行ADD/VIEW操作时崩溃问题求助

核心问题分析 #

从客户端抛出的java.net.SocketException来看，服务器崩溃的常见诱因包括：

• 多线程环境下共享Bug存储集合的并发修改异常，导致线程未捕获崩溃进而影响服务器进程
• IO流或Socket连接被提前错误关闭，引发客户端读写时的连接中断异常
• 指令解析逻辑未做校验，触发未捕获的异常导致线程终止

具体修复步骤 #

1. 确保共享资源线程安全 #

如果服务器使用ArrayList等非线程安全集合存储Bug数据，需替换为线程安全实现或添加同步锁：

// 方案1：使用CopyOnWriteArrayList（适合读多写少场景）
private static List<Bug> bugRepository = new CopyOnWriteArrayList<>();

// 方案2：对集合操作加同步锁
public synchronized void addBug(Bug newBug) {
    bugRepository.add(newBug);
}

public synchronized List<Bug> getAllBugs() {
    return new ArrayList<>(bugRepository); // 返回副本避免外部修改
}

2. 优化Socket连接与IO流管理 #

• 不要在单次指令处理后关闭Socket或流，保持连接直到客户端主动发送退出指令
• 在客户端线程的run()方法外层添加全局异常捕获，避免单个线程崩溃拖垮整个服务器：

@Override
public void run() {
    try (Socket clientConn = this.clientSocket;
         BufferedReader input = new BufferedReader(new InputStreamReader(clientConn.getInputStream()));
         PrintWriter output = new PrintWriter(clientConn.getOutputStream(), true)) {
        
        // 先处理登录逻辑
        boolean isLoggedIn = handleLogin(input, output);
        if (!isLoggedIn) return;

        // 循环处理客户端指令
        String command;
        while ((command = input.readLine()) != null) {
            processClientCommand(command, input, output);
        }
    } catch (SocketException se) {
        // 客户端正常断开，仅打印日志
        System.out.println("客户端连接已断开: " + se.getMessage());
    } catch (IOException e) {
        // 捕获IO异常，避免线程崩溃
        e.printStackTrace();
    }
}

3. 完善指令解析的异常防护 #

对ADD/VIEW指令做格式校验，避免因非法指令触发未捕获异常：

private void processClientCommand(String command, BufferedReader input, PrintWriter output) {
    String[] cmdParts = command.trim().split("\\s+");
    if (cmdParts.length == 0) {
        output.println("错误：无效指令");
        return;
    }

    switch (cmdParts[0].toUpperCase()) {
        case "ADD":
            if (cmdParts.length < 3) {
                output.println("错误：ADD指令格式应为 ADD <Bug标题> <Bug描述>");
                return;
            }
            String title = cmdParts[1];
            String desc = String.join(" ", Arrays.copyOfRange(cmdParts, 2, cmdParts.length));
            bugRepository.add(new Bug(title, desc));
            output.println("Bug已成功添加");
            break;
        case "VIEW":
            if (bugRepository.isEmpty()) {
                output.println("当前无已注册的Bug");
            } else {
                output.println("=== 已注册Bug列表 ===");
                for (int i = 0; i < bugRepository.size(); i++) {
                    Bug bug = bugRepository.get(i);
                    output.printf("%d. 标题：%s | 描述：%s%n", i+1, bug.getTitle(), bug.getDesc());
                }
            }
            break;
        // 其他指令处理
        default:
            output.println("错误：未知指令，请输入ADD或VIEW");
    }
}

4. 客户端侧补充异常处理 #

在客户端发送ADD/VIEW请求时，捕获SocketException并提示用户，避免客户端直接崩溃：

try {
    PrintWriter out = new PrintWriter(socket.getOutputStream(), true);
    BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
    
    // 发送ADD/VIEW指令
    out.println("ADD 登录模块崩溃 点击登录按钮无响应");
    String response = in.readLine();
    System.out.println("服务器响应：" + response);
} catch (SocketException se) {
    System.err.println("服务器连接中断，请检查服务器状态");
} catch (IOException e) {
    e.printStackTrace();
}

验证效果 #

修复后执行以下步骤验证：

1. 启动服务器，多个客户端同时登录
2. 每个客户端执行多次ADD和VIEW操作
3. 检查服务器是否稳定运行，无崩溃现象
4. 客户端能正常接收服务器返回的Bug列表或添加成功提示

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