使用ThreadLocalScopeManager时Liquibase命令线程不安全问题咨询

问题背景 #

使用Java API结合ThreadLocalScopeManager多线程操作多个数据库时，出现连接关闭异常，根源在于LockServiceCommandStep的类成员database被多线程共享，即使配置了线程本地Scope管理器，仍无法避免状态复用导致的连接冲突。官方对应测试用例目前处于忽略状态。

解决方案 #

1. 每个线程独立构建CommandScope执行操作 #

放弃Liquibase类的便捷方法（如update()、tag()），改用手动创建CommandScope实例，确保每个线程的命令执行链完全独立，避免共享全局命令步骤对象：

Scope.setScopeManager(new ThreadLocalScopeManager());
ExecutorService executor = Executors.newFixedThreadPool(8);

for (int i=0; i<8; i++) {
    String dbName = "DB_" + i;
    executor.submit(() -> {
        try(MemoryDatabase db = MemoryDatabase.create(dbName); Connection con = db.getConnection()) {
            Database database = new JdbcConnection(con);
            ResourceAccessor resourceAccessor = new ClassLoaderResourceAccessor();
            String changelogPath = "com/example/changelog.xml";

            // 执行test_started标签
            new CommandScope("tag")
                .addArgumentValue("changelogFile", changelogPath)
                .addArgumentValue("database", database)
                .addArgumentValue("resourceAccessor", resourceAccessor)
                .addArgumentValue("tag", "test_started")
                .execute();

            // 执行更新操作
            new CommandScope("update")
                .addArgumentValue("changelogFile", changelogPath)
                .addArgumentValue("database", database)
                .addArgumentValue("resourceAccessor", resourceAccessor)
                .addArgumentValue("contexts", new Contexts())
                .addArgumentValue("labelExpression", new LabelExpression())
                .execute();

            // 执行test_complete标签
            new CommandScope("tag")
                .addArgumentValue("changelogFile", changelogPath)
                .addArgumentValue("database", database)
                .addArgumentValue("resourceAccessor", resourceAccessor)
                .addArgumentValue("tag", "test_complete")
                .execute();
        } catch (LiquibaseException e) {
            throw new IllegalStateException(e.getMessage(), e);
        } catch (SQLException e) {
            throw new RuntimeException(e);
        }
    });
}

该方式直接绕过了Liquibase类内部复用的全局命令步骤，每个线程的命令执行都拥有独立的状态实例，彻底避免多线程共享连接的问题。

2. 显式创建线程独立的Scope上下文 #

在每个线程任务内部显式创建子Scope，强化线程间的上下文隔离：

executor.submit(() -> {
    try (Scope.ScopedRunner runner = Scope.child()) {
        runner.run(() -> {
            // 此处放置数据库连接创建、Liquibase操作代码
        });
    } catch (LiquibaseException e) {
        throw new IllegalStateException(e.getMessage(), e);
    }
});

显式的子Scope确保每个线程的Liquibase上下文完全独立，不会与其他线程的Scope状态产生交叉。

3. 升级Liquibase版本（优先推荐） #

4.22.0版本存在ThreadLocalScopeManager相关的线程安全缺陷，后续版本（如4.23.0及以上）已修复该问题，官方对应测试用例也已解除忽略。若项目依赖允许，升级到最新稳定版本可从根源解决该问题。

4. 自定义线程安全的LockService实现 #

若无法升级版本，可自定义LockService确保每个线程的锁服务实例独立：

Database database = new JdbcConnection(con);
database.setLockService(new StandardLockService() {
    private final ThreadLocal<Boolean> locked = ThreadLocal.withInitial(() -> false);
    
    @Override
    public void acquireLock() throws LiquibaseException {
        if (!locked.get()) {
            super.acquireLock();
            locked.set(true);
        }
    }

    @Override
    public void releaseLock() throws LiquibaseException {
        if (locked.get()) {
            super.releaseLock();
            locked.set(false);
        }
    }
});

通过ThreadLocal维护锁状态，避免多线程间的锁服务状态共享。

内容的提问来源于stack exchange，提问作者Kesav Bharadwaj R