跨线程用JdbcLockRegistry加解锁遇Mutex未持有异常的问题求助

问题原因 #

Spring JdbcLockRegistry返回的Mutex内部通过ThreadLocal标记当前线程的锁持有状态。在GCP分布式环境下，Temporal工作流的acquire和release操作可能被调度到不同Worker实例或不同线程执行，此时release时的Mutex实例无法检测到当前线程持有锁，因此抛出该异常。本地环境因操作在同一线程/实例执行，无此问题。

可行解决方案 #

方案1：改用Temporal原生分布式锁 #

Temporal内置了适配工作流场景的分布式锁，完美解决跨实例锁操作问题，无需依赖外部组件：

import io.temporal.workflow.Workflow;
import io.temporal.workflow.Mutex;

public class ParentWorkflowImpl implements ParentWorkflow {
    // 根据业务lockKey创建全局锁，Temporal自动处理跨实例竞争
    private final Mutex workflowMutex = Workflow.newMutex("your-target-lock-key");

    @Override
    public void executeWorkflow() {
        try {
            workflowMutex.lock();
            // 执行需锁保护的业务逻辑
            // ...
        } finally {
            // 无论工作流在哪台Worker执行，都能正确释放锁
            workflowMutex.unlock();
        }
    }
}

该方案自动处理锁续期、故障恢复，完全适配Temporal的工作流调度模型，是最优选择。

方案2：直接操作数据库释放锁 #

若必须保留JdbcLockRegistry，可绕过Mutex的线程检查，直接通过SQL删除锁记录：

修改DatabaseLockManager：

import org.springframework.jdbc.core.JdbcTemplate;

public class DatabaseLockManager {

    private final JdbcLockRegistry lockRegistry;
    private final JdbcTemplate jdbcTemplate;

    @Autowired
    public DatabaseLockManager(JdbcLockRegistry lockRegistry, JdbcTemplate jdbcTemplate){
        this.lockRegistry = lockRegistry;
        this.jdbcTemplate = jdbcTemplate;
    }

    public void acquire(String lockKey){
        lockRegistry.obtain(lockKey).lock();
    }

    public void release(String lockKey){
        // 需根据实际锁表结构调整SQL，默认表名LOCK，主键LOCK_KEY
        String deleteSql = "DELETE FROM LOCK WHERE LOCK_KEY = ?";
        jdbcTemplate.update(deleteSql, lockKey);
    }
}

注意：可结合锁表的OWNER字段做验证，仅允许持有锁的主体释放，避免误删其他实例的锁。

方案3：自定义JdbcLockRegistry跳过线程检查 #

继承JdbcLockRegistry，重写Mutex的unlock方法，移除线程持有检查：

import org.springframework.integration.jdbc.lock.DefaultLockRepository;
import org.springframework.integration.jdbc.lock.JdbcLockRegistry;
import org.springframework.integration.jdbc.lock.Mutex;

public class CustomJdbcLockRegistry extends JdbcLockRegistry {

    public CustomJdbcLockRegistry(DefaultLockRepository lockRepository) {
        super(lockRepository);
    }

    @Override
    public Mutex obtain(String lockKey) {
        return new CustomMutex(getLockRepository(), lockKey);
    }

    private static class CustomMutex extends Mutex {

        public CustomMutex(DefaultLockRepository lockRepository, String lockKey) {
            super(lockRepository, lockKey);
        }

        @Override
        public void unlock() {
            // 跳过线程检查，直接执行数据库释放逻辑
            super.doRelease();
        }
    }
}

配置类中替换默认实现：

@Bean
public JdbcLockRegistry jdbcLockRegistry(DefaultLockRepository lockRepository) {
    return new CustomJdbcLockRegistry(lockRepository);
}

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