时间戳

首页 > 解决方案 > Spring boot @Scheduler 在 Google Kubernetes Engine 中不起作用

spring-boot - Spring boot @Scheduler 在 Google Kubernetes Engine 中不起作用

问题描述

我有一个 Spring Boot 应用程序，它由一个计划任务和一个休息控制器组成。计划任务使用 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 关闭的日志消息，但我也看不到计划任务的日志消息。

这是最后的日志消息 在此处输入图像描述

标签： spring-bootgoogle-kubernetes-enginecron-tasktaskscheduler

解决方案

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

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

推荐阅读