Spring多服务调用遗留代码时偶发InterruptedException问题排查

从你提供的代码和堆栈信息来看，问题核心出在**InterruptedException的处理逻辑上**——当线程在Thread.sleep()时被中断，你的代码直接抛出PrintingException终止了整个重试流程，这就是为什么会偶发失败的关键原因。

为什么会出现这个问题？ #

在Spring服务中，线程（比如Tomcat工作线程、异步任务线程）可能会因为多种场景被中断：比如服务优雅停机、任务超时被取消、线程池资源回收等。你的代码捕获到InterruptedException后，既没有恢复线程的中断状态，也没有继续执行剩余的重试逻辑，直接终止了Socket连接流程，哪怕还有重试次数可用。

另外还有一个隐藏隐患：重试时复用了同一个Socket实例，如果第一次连接失败的Socket处于异常状态，后续复用会进一步提升连接失败的概率。

具体修复步骤 #

1. 正确处理中断，恢复中断状态

捕获到InterruptedException后，必须先恢复线程的中断标记（Thread.currentThread().interrupt()）——这是Java线程协作的规范，上层代码（比如Spring线程池、任务调度框架）需要感知到中断事件来做后续处理。之后可以根据业务需求选择继续重试或优雅终止。

2. 每次重试创建新的Socket实例

旧Socket在连接失败后可能处于不可用状态，每次重试都要生成新的Socket对象，避免复用导致的异常状态传递。

3. 合并冗余的重试逻辑

原代码把socket.setSoTimeout()单独做了一套重试循环，其实可以合并到连接重试的逻辑中，减少冗余代码，也避免在Socket未连接时设置超时的无效操作。

修改后的代码示例 #

private void openSocket() throws PrintingException {
    retries = 3;
    do {
        doRetry = false;
        // 每次重试都创建新的Socket实例
        socket = new Socket();
        inetSocketAddress = new InetSocketAddress(ip, port);
        try {
            socket.connect(inetSocketAddress, connectionTimeOut);
            // 连接成功后直接设置超时时间，合并逻辑
            socket.setSoTimeout(socketTimeOut);
            break; // 连接成功，跳出重试循环
        } catch (UnknownHostException e) {
            closeSocket(); // 关闭当前无效Socket
            throw new PrintingException("Error while trying to print on " + ip + ": " + e.getMessage());
        } catch (IOException e) {
            closeSocket(); // 关闭当前无效Socket
            if (retries > 0) {
                try {
                    Thread.sleep(timeToWaitForRetry);
                } catch (InterruptedException ex) {
                    // 恢复中断状态，让上层代码感知
                    Thread.currentThread().interrupt();
                    // 业务允许的话，继续执行重试流程
                    doRetry = true;
                    retries--;
                    continue;
                }
                doRetry = true;
                retries--;
            } else {
                throw new PrintingException("Error while trying to print on " + ip + ": " + e.getMessage());
            }
        }
    } while (doRetry);
    
    // 最终校验Socket是否成功连接
    if (socket == null || !socket.isConnected()) {
        throw new PrintingException("Failed to connect to printer " + ip + " after " + 3 + " retries");
    }
}

关键说明 #

• 恢复中断状态：Thread.currentThread().interrupt()会重新设置线程的中断标记，确保上层调用链（比如Spring异步任务框架）能正确处理任务取消或资源回收。
• 新Socket实例：避免复用失败Socket的异常状态，保证每次重试都是干净的连接尝试。
• 合并逻辑：减少冗余的重试循环，让代码更简洁，也避免了未连接Socket设置超时的无效操作。

额外建议 #

如果你的Spring服务使用了@Async异步线程，可以在异步方法中统一处理中断逻辑，或者配置线程池的中断策略，进一步降低中断对业务流程的影响。

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