Java中提取RPM文件内容的实用方法与注意事项

import org.apache.commons.compress.archivers.cpio.CpioArchiveInputStream;
import org.apache.commons.compress.archivers.cpio.CpioArchiveEntry;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.nio.file.Files;
import java.nio.file.Path;
import java.nio.file.Paths;
import java.util.concurrent.TimeUnit;

/**
 * 实用类，用于从Java中提取RPM文件内容。
 * 依赖于系统环境中安装的'rpm2cpio'工具和Apache Commons Compress库。
 */
public class RpmExtractor {

    private static final int BUFFER_SIZE = 4096; // 缓冲区大小

    /**
     * 将RPM文件的内容提取到指定的目录。
     *
     * @param rpmFilePath       RPM文件的路径。
     * @param targetDirectoryPath 目标提取目录的路径。
     * @throws IOException 如果在文件操作或进程执行过程中发生错误。
     */
    public static void extractRpmToDirectory(String rpmFilePath, String targetDirectoryPath) throws IOException {
        Path targetDirPath = Paths.get(targetDirectoryPath);
        // 确保目标目录存在，如果不存在则创建
        if (!Files.exists(targetDirPath)) {
            Files.createDirectories(targetDirPath);
        }

        Process proc = null;
        try {
            // 构建并执行rpm2cpio命令
            // 注意：rpm2cpio必须在系统PATH中可用
            String command = String.format("rpm2cpio %s", rpmFilePath);
            System.out.println("Executing command: " + command);
            proc = Runtime.getRuntime().exec(command);

            // 获取rpm2cpio命令的标准输出流，该流包含CPIO归档数据
            try (InputStream cpioRawStream = proc.getInputStream();
                 CpioArchiveInputStream cpioStream = new CpioArchiveInputStream(cpioRawStream)) {

                CpioArchiveEntry entry;
                // 遍历CPIO归档中的每一个条目
                while ((entry = cpioStream.getNextEntry()) != null) {
                    if (!cpioStream.canReadEntryData(entry)) {
                        System.err.println("Warning: Cannot read entry data for: " + entry.getName());
                        continue;
                    }

                    // 构建条目在目标目录中的完整路径
                    Path entryPath = targetDirPath.resolve(entry.getName());

                    // 处理目录条目
                    if (entry.isDirectory()) {
                        Files.createDirectories(entryPath);
                    } else {
                        // 确保文件所在的父目录存在
                        Files.createDirectories(entryPath.getParent());

                        // 写入文件内容
                        try (FileOutputStream fos = new FileOutputStream(entryPath.toFile())) {
                            byte[] buffer = new byte[BUFFER_SIZE];
                            int bytesRead;
                            while ((bytesRead = cpioStream.read(buffer)) != -1) {
                                fos.write(buffer, 0, bytesRead);
                            }
                        }
                        // 可选：根据CPIO条目设置文件权限
                        // long permissions = entry.getMode();
                        // File file = entryPath.toFile();
                        // file.setExecutable((permissions & 0111) != 0, false);
                        // file.setReadable((permissions & 0444) != 0, false);
                        // file.setWritable((permissions & 0222) != 0, false);
                    }
                    System.out.println("Extracted: " + entry.getName());
                }
            } finally {
                // 确保外部进程被终止并检查其退出码
                if (proc != null) {
                    try {
                        // 等待进程完成，设置超时以避免死锁
                        if (!proc.waitFor(60, TimeUnit.SECONDS)) { // 最多等待60秒
                            System.err.println("rpm2cpio process timed out.");
                            proc.destroyForcibly(); // 强制终止进程
                        }

                        int exitCode = proc.exitValue();
                        if (exitCode != 0) {
                            System.err.println("rpm2cpio process exited with error code: " + exitCode);
                            // 读取错误流以获取更多信息
                            try (InputStream errorStream = proc.getErrorStream()) {
                                byte[] errorBytes = errorStream.readAllBytes();
                                if (errorBytes.length > 0) {
                                    System.err.println("rpm2cpio error output: " + new String(errorBytes));
                                }
                            }
                        }
                    } catch (InterruptedException e) {
                        Thread.currentThread().interrupt(); // 重新设置中断状态
                        System.err.println("Process interrupted: " + e.getMessage());
                    }
                }
            }
        } catch (IOException e) {
            System.err.println("Error extracting RPM file: " + e.getMessage());
            throw e; // 重新抛出异常
        } finally {
            // 确保进程资源被释放
            if (proc != null) {
                proc.destroy();
            }
        }
    }

    public static void main(String[] args) {
        if (args.length < 2) {
            System.out.println("Usage: java RpmExtractor <rpm_file_path> <target_directory_path>");
            return;
        }
        String rpmFile = args[0];
        String targetDir = args[1];

        try {
            System.out.println("Starting extraction of " + rpmFile + " to " + targetDir);
            extractRpmToDirectory(rpmFile, targetDir);
            System.out.println("Extraction completed successfully.");
        } catch (IOException e) {
            System.err.println("Extraction failed: " + e.getMessage());
            e.printStackTrace();
        }
    }
}

<dependency>
    <groupId>org.apache.commons</groupId>
    <artifactId>commons-compress</artifactId>
    <version>1.26.1</version> <!-- 请使用最新稳定版本 -->
</dependency>

implementation 'org.apache.commons:commons-compress:1.26.1' // 请使用最新稳定版本