Spring Boot @Scheduler 在 Google Kubernetes Engine 中不起作用

如何解决Spring Boot @Scheduler 在 Google Kubernetes Engine 中不起作用

我有一个 Spring 启动应用程序，它由一个计划任务和一个休息控制器组成。计划任务使用 Javamail 连接到 Gmail 以解析某些电子邮件并将它们存储在 MongoDB 数据库中，控制器将在数据库中查询该数据。 我正在 GKE 中部署此应用程序。当我这样做时，我看到以下日志消息并且我的任务没有运行：

控制器是可访问的，但正如您所看到的，应用程序启动但 taskScheduler 执行程序服务关闭。我无法在日志中找到有关发生这种情况的原因的信息。当我在本地运行它时，它可以工作，所以我认为它可能与 Docker 相关，但我从 Docker 容器（也在本地）运行该应用程序并且它也能正常工作。 我有另一个 Spring Boot 应用程序，它运行一些部署在 GKE 上的计划任务，唯一的区别是它不公开任何休息控制器。

您知道导致此问题的原因是什么吗？

这是我的主要课程

@EnableScheduling
@EnableMongoRepositories
@SpringBootApplication
public class EmailApplication {
    public static void main(String[] args) {
        SpringApplication.run(EmailCheckerApplication.class,args);
    }
}

这是我的计划任务。这根本不运行。

@Scheduled(fixedDelay = 60000) // I also tried with @Scheduled(cron = "0 */1 * * * *")
public void checkEmails() {
    try {
        //connects to Gmail
        Message[] messages = getMessages();
        //parse emails & store them in DB
        closeAll();
    } catch (Exception e) {
        LOGGER.finest("Error Parsing emails: " + e.getMessage());
    }
}

这是我的 Dockerfile

FROM adoptopenjdk/openjdk13:jre-13.0.2_8-alpine

COPY build/libs/email-checker-0.0.1.jar /tmp
RUN chmod 744 /tmp/email-checker-0.0.1.jar
CMD ["java","-jar","-Dspring.profiles.active=${SPRING_PROFILES_ACTIVE}","/tmp/email-checker-0.0.1.jar"]

这是我在 build.gradle 中的依赖项

dependencies {
    implementation 'org.springframework.boot:spring-boot-starter'
    implementation 'org.springframework.boot:spring-boot-starter-web'
    implementation group: 'javax.mail',name: 'mail',version: '1.4.7'
    compile group: 'org.springframework.boot',name: 'spring-boot-starter-actuator',version: '2.4.2'
    compile group: 'org.springframework.data',name: 'spring-data-mongodb',version: '3.1.3'
    compile group: 'org.springframework.boot',name: 'spring-boot-starter-data-mongodb',version: '2.4.2'
    compileOnly 'org.projectlombok:lombok'
    annotationProcessor 'org.projectlombok:lombok'
    testImplementation 'org.springframework.boot:spring-boot-starter-test'
}

编辑

奇怪，如果我跑 kubectl logs -n service <pod-name> -f 我没有看到 ExecutorServices 关闭的日志消息，但我也没有看到计划任务的日志消息。

这是最后的日志消息

解决方法

我解决了这个问题。实际上有两个问题，但主要的一个是当我的应用程序尝试连接到 Gmail 时，它抛出一个异常，说需要 Web 登录。所以我意识到 Spring boot 在我的 catch 块中忽略了 LOGGER.finest。我首先通过在计划任务中的每一行代码前添加一堆 LOGGER.info 然后将 LOGGER.finest 更改为 LOGGER.info 来发现这一点。

因此，为了解决主要问题，我遵循了 SO question 中的一些建议，并使用 LOGGER.finest 解决了问题，我在 application.properties 中添加了属性 logging.level.my-package=DEBUG（更改 my-package 到应用程序中要设置日志级别的包）。如果您对较低的环境和生产有不同的配置文件，您可以在生产配置文件中将其设置为 ERROR。