Распределенная блокировка в Java Spring Boot

У меня есть 2 экземпляра контейнеров с запланированным заданием, и я хотел бы защититься от запуска одной и той же задачи в каждом контейнере докеров. Я решил сделать распределенную блокировку с помощью SQL Server.

я добавил конфигурацию

  @Bean
    public DefaultLockRepository DefaultLockRepository(DataSource dataSource) {
        return new DefaultLockRepository(dataSource);
    }

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

И я пытаюсь получить блокировку следующим образом:

   public void doSomething() throws InterruptedException {
        boolean lockAcquired;
        var lock = lockRegistry.obtain("main");

        try {
            
            lockAcquired = lock.tryLock();
            if (lockAcquired == true) {
                logger.info("Locked");
            } else {
                logger.info("Not locked");
            }

        } catch (Exception ex) {
            lockAcquired = false;
            logger.info("Not locked");
        }

        Thread.sleep(3600000);

        lock.unlock();
    }

Я запустил 2 экземпляра приложения с одинаковым кодом. Когда я вошел в метод первого экземпляра приложения, была получена блокировка - и я получил сообщение "Заблокировано" - так что все в порядке.

В базе данных я увидел такую ​​запись:

LOCK_KEY    REGION  CLIENT_ID   CREATED_DATE
fad58de7-3664-35db-8650-cfefac2fcd61    DEFAULT c0314b87-0bee-4bdd-8567-a939fd21f0bf    2024-03-16 13:20:43.2559575I saw that in datatabase I've got new entry like this:

Когда я запустил второй экземпляр приложения, я ожидал получить сообщение «Не заблокировано», поскольку блокировка была получена в первом приложении, которое все еще работает, но нет - у меня снова есть журнал «Заблокировано», и моя запись в базе данных была обновлена ​​до:

LOCK_KEY    REGION  CLIENT_ID   CREATED_DATE
fad58de7-3664-35db-8650-cfefac2fcd61    DEFAULT ad58971d-c991-4709-a03b-9acb39a38c54    2024-03-16 13:24:42.3002365

Итак, моя распределенная блокировка не работает.

Что я делаю не так? Как я могу защититься от выполнения запланированной задачи с помощью распределенной блокировки во многих контейнерах докеров.

//ОБНОВЛЯТЬ

Когда я выполняю метод в двух экземплярах за короткий промежуток времени (например, менее 5 с), он работает, но когда я выполняю метод в первом экземпляре и пытаюсь выполнить его во втором экземпляре через 30 с, это не работает.

//ОБНОВЛЕНИЕ2

Как предположил Алекс, это была проблема с TTL в DefaultLockRepository. Блокировка была установлена ​​на время по умолчанию 10 секунд. После изменения кода следующим образом:

 @Bean
    public DefaultLockRepository DefaultLockRepository(DataSource dataSource) {
        var repo = new DefaultLockRepository(dataSource);
        repo.setTimeToLive(1000 * 100);
        return repo;
    }

Для блокировки установлено значение 100 секунд, и в течение следующих 100 секунд другой экземпляр службы не сможет заблокировать метод.