使用 Shedlock 配置 Spring Scheduler 时没有 LockProvider 类型的合格 bean

Question

我正在尝试集成 Shedlock 以使 Spring boot 应用程序上的预定作业在多 Pod 部署中无缝运行。

主要类如下：

@SpringBootApplication
@EnableScheduling
@EnableSchedulerLock(defaultLockAtMostFor = "60m", defaultLockAtLeastFor = "15m")
@ComponentScan
public class MyService {

  public static void main(String[] args) {
    SconeApp.run(MyService.class, args);
  }
}

为了使用 Shedlock 配置调度程序，添加了以下类：

import com.salesforce.tm.scheduler.MyScheduler;
import net.javacrumbs.shedlock.core.LockProvider;
import net.javacrumbs.shedlock.provider.jdbctemplate.JdbcTemplateLockProvider;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.jdbc.core.JdbcTemplate;

@Configuration
public class LockProviderConfiguration {

  @Bean
  public LockProvider lockProvider(MyDbDataSource dataSource) {
    return new JdbcTemplateLockProvider(
        JdbcTemplateLockProvider.Configuration.builder()
            .withJdbcTemplate(new JdbcTemplate(dataSource))
            .build()
    );
  }

  @Bean
  public MyScheduler myScheduler(LockProvider lockProvider) {
    return new MyScheduler();
  }
}

MyDbDataSource类如下：

@Component
public class MyDbDataSource implements InitializingBean {

  public TcDbDataSource(..) {
    super();
    ...
  }

  @Override
  public void afterPropertiesSet() {
     ...
  }
}

我的调度程序类如下：

public class MyScheduler {

  @Scheduled(cron = "*/1 * * * * *")
  @SchedulerLock(name = "myTask",
      lockAtMostFor = "${scheduling.my-job.lock-at-most}",
      lockAtLeastFor = "${scheduling.my-joblock-at-least}")
  public void myCronJob() throws InterruptedException {
    LockAssert.assertLocked();
    while(true) {
      System.out.println("Test");
      Thread.sleep(1000L);
    }
  }
}

启动应用程序时，我收到以下错误：

org.springframework.beans.factory.NoSuchBeanDefinitionException: No qualifying bean of type 'net.javacrumbs.shedlock.core.LockProvider' available: expected at least 1 bean which qualifies as autowire candidate. Dependency annotations: {}
    at org.springframework.beans.factory.support.DefaultListableBeanFactory.raiseNoMatchingBeanFound(DefaultListableBeanFactory.java:1714)
    at org.springframework.beans.factory.support.DefaultListableBeanFactory.doResolveDependency(DefaultListableBeanFactory.java:1270)
    at org.springframework.beans.factory.support.DefaultListableBeanFactory.resolveDependency(DefaultListableBeanFactory.java:1224)
    at org.springframework.beans.factory.support.ConstructorResolver.resolveAutowiredArgument(ConstructorResolver.java:884)
    at org.springframework.beans.factory.support.ConstructorResolver.createArgumentArray(ConstructorResolver.java:788)

我不明白我在这里缺少什么。

Answer 1

尝试重新定义您的 LockProvider bean

@Bean
public LockProvider lockProvider(DataSource dataSource) {
    return new JdbcTemplateLockProvider(dataSource);
}

就像本指南中的那样https://www.baeldung.com/shedlock-spring