Spring 启动 @Scheduler 在 Google Kubernetes Engine 中不工作
Spring boot @Scheduler not working in Google Kubernetes Engine
我有一个 Spring 启动应用程序,它由一个计划任务和一个休息控制器组成。计划任务使用 Javamail 连接到 Gmail 以解析某些电子邮件并将它们存储在 MongoDB 数据库中,控制器将在数据库中查询该数据。
我正在 GKE 中部署此应用程序。当我这样做时,我看到以下日志消息并且我的任务没有 运行:
控制器可以访问,但如您所见,应用程序启动,但随后 taskScheduler 执行程序服务关闭。我无法在日志中找到有关发生这种情况的原因的信息。当我 运行 它在本地工作时,所以我认为它可能与 Docker 有关,但我 运行 来自 Docker 容器(也在本地)的应用程序并且它工作以及。
我有另一个 spring 启动应用程序,它 运行 在 GKE 上部署了一些计划任务并且可以正常工作,唯一的区别是它不公开任何休息控制器。
你知道这个问题的原因是什么吗?
这是我的主要内容class
@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());
}
}
这是我的Docker文件
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 引导忽略了我的 catch 块中的 LOGGER.finest
。我首先通过在计划任务中的每一行代码之前添加一堆 LOGGER.info
然后将 LOGGER.finest
更改为 LOGGER.info
.
来发现这一点
因此,为了解决主要问题,我遵循了此 中的一些建议,为了解决 LOGGER.finest
的问题,我在 [=] 中添加了 属性 logging.level.my-package=DEBUG
25=](将 my-package 更改为应用程序中要设置日志级别的包)。如果您对较低的环境和生产有不同的配置文件,您可以在生产配置文件中将其设置为 ERROR。
我有一个 Spring 启动应用程序,它由一个计划任务和一个休息控制器组成。计划任务使用 Javamail 连接到 Gmail 以解析某些电子邮件并将它们存储在 MongoDB 数据库中,控制器将在数据库中查询该数据。 我正在 GKE 中部署此应用程序。当我这样做时,我看到以下日志消息并且我的任务没有 运行:
控制器可以访问,但如您所见,应用程序启动,但随后 taskScheduler 执行程序服务关闭。我无法在日志中找到有关发生这种情况的原因的信息。当我 运行 它在本地工作时,所以我认为它可能与 Docker 有关,但我 运行 来自 Docker 容器(也在本地)的应用程序并且它工作以及。 我有另一个 spring 启动应用程序,它 运行 在 GKE 上部署了一些计划任务并且可以正常工作,唯一的区别是它不公开任何休息控制器。
你知道这个问题的原因是什么吗?
这是我的主要内容class
@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());
}
}
这是我的Docker文件
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 引导忽略了我的 catch 块中的 LOGGER.finest
。我首先通过在计划任务中的每一行代码之前添加一堆 LOGGER.info
然后将 LOGGER.finest
更改为 LOGGER.info
.
因此,为了解决主要问题,我遵循了此 LOGGER.finest
的问题,我在 [=] 中添加了 属性 logging.level.my-package=DEBUG
25=](将 my-package 更改为应用程序中要设置日志级别的包)。如果您对较低的环境和生产有不同的配置文件,您可以在生产配置文件中将其设置为 ERROR。