使用Apache Commons Transaction实现文件事务性移动的代码是否正确？

你的代码存在几处关键问题，导致无法正确实现事务性文件移动，下面逐一说明并给出修正方案：

核心问题点 #

• moveResource 参数误用：该方法的第二个和第三个参数是资源名称（即workDir下的文件名），而非完整目录路径。FileResourceManager的workDir是源文件的根目录，storeDir是目标文件的根目录，你需要指定具体要移动的文件名，而不是直接传入整个目录。
• 方法名拼写错误：generatedUniqueTxId() 应为 generateUniqueTxId()（少了字母e），会导致编译错误。
• 空指针风险：异常处理块中，如果fileResourceManager初始化失败（比如目录不存在），直接调用rollbackTransaction会触发空指针异常。
• 资源未释放：没有在finally块中关闭FileResourceManager，可能导致资源泄漏。
• 异常覆盖不全：仅捕获ResourceManagerException，未处理其他运行时异常，会导致事务无法回滚。

修正后的代码 #

import org.apache.commons.transaction.file.FileResourceManager;
import org.apache.commons.transaction.util.LoggerFacade;

import java.io.File;

public class TransactionalFileMove {
    private static final LoggerFacade LOGGER_FACADE = new LoggerFacade() {
        // 实现日志方法，根据需要调整
        @Override
        public void debug(String message) {
            System.out.println("DEBUG: " + message);
        }

        @Override
        public void info(String message) {
            System.out.println("INFO: " + message);
        }

        @Override
        public void warn(String message) {
            System.out.println("WARN: " + message);
        }

        @Override
        public void error(String message, Throwable throwable) {
            System.err.println("ERROR: " + message);
            throwable.printStackTrace();
        }

        // 实现其他未覆盖的LoggerFacade方法
        @Override
        public void debug(String message, Throwable throwable) {}
        @Override
        public void info(String message, Throwable throwable) {}
        @Override
        public void warn(String message, Throwable throwable) {}
        @Override
        public void error(String message) {}
        @Override
        public boolean isDebugEnabled() { return true; }
        @Override
        public boolean isInfoEnabled() { return true; }
        @Override
        public boolean isWarnEnabled() { return true; }
        @Override
        public boolean isErrorEnabled() { return true; }
    };

    public static void moveFiles() {
        FileResourceManager fileResourceManager = null;
        String txId = null;
        try {
            String workDir = "D:\\source";
            String storeDir = "D:\\destination";
            // 指定要移动的文件名（假设源目录下有test.txt文件）
            String fileName = "test.txt";

            // 初始化FileResourceManager：参数顺序是storeDir, workDir, readOnly, logger, createIfNotExists
            fileResourceManager = new FileResourceManager(storeDir, workDir, false, LOGGER_FACADE, true);
            fileResourceManager.start();

            txId = fileResourceManager.generateUniqueTxId();
            fileResourceManager.startTransaction(txId);

            // 移动资源：参数为事务ID、源资源名（workDir下的文件名）、目标资源名（storeDir下的文件名）、是否覆盖
            fileResourceManager.moveResource(txId, fileName, fileName, true);

            fileResourceManager.commitTransaction(txId);
            System.out.println("文件移动成功，事务已提交");
        } catch (Exception e) {
            // 仅当事务已启动且资源管理器不为null时执行回滚
            if (fileResourceManager != null && txId != null) {
                try {
                    fileResourceManager.rollbackTransaction(txId);
                    System.out.println("操作失败，事务已回滚");
                } catch (Exception rollbackEx) {
                    System.err.println("回滚失败：");
                    rollbackEx.printStackTrace();
                }
            }
            e.printStackTrace();
        } finally {
            // 关闭资源管理器，释放资源
            if (fileResourceManager != null) {
                try {
                    fileResourceManager.stop();
                } catch (Exception stopEx) {
                    stopEx.printStackTrace();
                }
            }
        }
    }

    public static void main(String[] args) {
        moveFiles();
    }
}

关键说明 #

1. 资源名称的正确使用：moveResource方法操作的是workDir和storeDir下的具体文件，所以需要传入文件名作为资源名，而非目录路径。如果要移动目录下的所有文件，需要遍历workDir下的文件，逐个调用moveResource。
2. 事务边界的安全处理：在finally块中关闭FileResourceManager，确保资源被正确释放；回滚操作前先判断资源管理器和事务ID是否有效，避免空指针。
3. 异常范围扩大：捕获所有Exception，确保任何异常都能触发回滚逻辑。

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