Java同步执行命令行进程：解决AWS Lambda环境下ClamAV扫描未完成问题

首先得明确：你遇到的“未执行完成就退出”的核心原因不是Lambda主动提前终止，而是Java调用外部进程时的流处理逻辑有问题，导致ClamAV进程被阻塞，最终触发Lambda的超时机制。

问题根源 #

Java的Process对象的标准输出(stdout)和错误输出(stderr)缓冲区是有限的。当ClamAV输出的内容填满缓冲区后，它会暂停执行，等待缓冲区被读取。但你的代码是先调用proc.waitFor()等待进程结束，之后才去读缓冲区——这就形成了死锁：ClamAV等着缓冲区被清空，你的Java代码等着ClamAV结束，最终Lambda因为超过预设的执行时间被强制终止，看起来就像“未执行完成就退出”。

最佳修复方案：提前读取流，避免缓冲区阻塞 #

正确的做法是在调用waitFor()之前，启动独立的线程去读取stdout和stderr，让ClamAV能持续输出内容，不会被缓冲区阻塞。这里给你修改后的代码示例：

Runtime rt = Runtime.getRuntime();
Process proc = rt.exec(command);

// 启动线程读取标准输出，避免缓冲区满导致进程阻塞
Thread stdoutReaderThread = new Thread(() -> {
    try (BufferedReader inputReader = new BufferedReader(new InputStreamReader(proc.getInputStream()))) {
        String line;
        StringBuilder out = new StringBuilder();
        while ((line = inputReader.readLine()) != null) {
            out.append("\n").append(line);
            // 可以根据需要记录日志或者保存输出内容
            logger.info("ClamAV stdout: " + line);
        }
    } catch (IOException e) {
        logger.error("Failed to read ClamAV standard output", e);
    }
});

// 启动线程读取错误输出，同理避免阻塞
Thread stderrReaderThread = new Thread(() -> {
    try (BufferedReader errorReader = new BufferedReader(new InputStreamReader(proc.getErrorStream()))) {
        String line;
        StringBuilder errOut = new StringBuilder();
        while ((line = errorReader.readLine()) != null) {
            errOut.append("\n").append(line);
            logger.error("ClamAV stderr: " + line);
        }
    } catch (IOException e) {
        logger.error("Failed to read ClamAV error output", e);
    }
});

// 启动两个读取线程
stdoutReaderThread.start();
stderrReaderThread.start();

// 等待ClamAV进程执行完成
int exitValue = proc.waitFor();
// 等待两个读取线程处理完所有输出，确保内容都被读取完毕
stdoutReaderThread.join();
stderrReaderThread.join();

logger.info("ClamAV exit value: " + exitValue);

关于Thread.sleep的临时方案（不推荐） #

如果实在要使用Thread.sleep作为临时缓解，你应该把它放在**proc.waitFor()之后，读取流之前**，给ClamAV一点时间把剩余输出写入缓冲区。但这只是治标不治本——如果ClamAV输出内容超过缓冲区大小，还是会卡住。示例位置：

int exitValue = proc.waitFor();
// 临时sleep，时间根据实际输出调整，比如1000ms
try {
    Thread.sleep(1000);
} catch (InterruptedException e) {
    Thread.currentThread().interrupt();
    logger.error("Sleep interrupted", e);
}
logger.info("Exit Value:" + exitValue);
// 之后再读取流...

但再次强调：优先采用多线程读取流的方案，这才是解决问题的根本，sleep只是临时的权宜之计，无法适配所有场景。

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