java - 带有@Scheduled批注的方法在Spring Boot应用程序中不起作用

tl;博士:您能想到我在Spring Boot应用程序中未执行@Scheduled任务的情况吗？

我实现了example，效果很好，但是，在我正在开发的更复杂的Spring Boot应用程序中，我无法运行@Scheduled方法。

我的主要 class 是这样的:

package com.mypackage.myapp;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.security.config.annotation.web.configuration.EnableWebSecurity;

@SpringBootApplication
@EnableWebSecurity
@EnableScheduling
public class MyApp {
    public static void main(String[] args) {
        SpringApplication.run(MyApp.class);
    }
}

预定应用程序所在的组件如下所示:

(...)

@Component
public class MyComponent {
    private static final Logger logger = LoggerFactory.getLogger(MyComponent.class);

    (...)

    @Scheduled(fixedRate = 5000)
    public void myScheduledTask() {
        logger.info("Executing scheduled task");

    (...)
    }
}

整个应用程序显然更加复杂，但这实际上就是它。不幸的是，"Executing scheduled task"在日志中不显示任何位置，即使我调试断点也永远无法到达。

正如我所说，最小的示例对我有用，但是在我的应用程序中却没有。您能想到我可以检查哪些地方没有执行@Scheduled任务的情况吗？例如，配置可以被任何东西否决吗？有什么可以干扰的吗？

我正在使用1.5.1.RELEASE版本。

最佳答案

我想我知道了。我还有另一个实现SmartLifecycle的组件，start()方法包含一个我永远不会离开的while循环(有意地从Kafka流中读取)。这本质上导致初始化被卡住，因此@Scheduled方法从未真正调度过。

我可以用while(true)在一个最小的示例中重现它。一旦我知道了，就不会执行@Scheduled方法，当我删除while时，它就可以正常工作。

package com.mypackage.myapp;

import java.util.concurrent.CompletableFuture;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.context.SmartLifecycle;
import org.springframework.stereotype.Component;

@Component
public class StartLoop implements SmartLifecycle {

    private static final Logger log = LoggerFactory.getLogger(StartLoop.class);
    private static final int LAST_PHASE = Integer.MAX_VALUE;
    private boolean running;

    @Override
    public void start() {
        runMyCode();
    }

    private void runMyCode() {
        running = true;
        log.info("Starting ...");
        while (running) {
            try {
                log.info("running");
                Thread.sleep(5000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }

        }
    }

    @Override
    public boolean isRunning() {
        return running;
    }

    @Override
    public void stop() {
        log.info("Stopping ...");
    }

    @Override
    public void stop(Runnable callback) {
        callback.run();
    }

    @Override
    public boolean isAutoStartup() {
        return true;
    }

    @Override
    public int getPhase() {
        return LAST_PHASE;
    }

}

如果我现在将start()方法替换为

@Override
public void start() {
    CompletableFuture.runAsync(this::runMyCode);
}

它工作得很好。

关于java - 带有@Scheduled批注的方法在Spring Boot应用程序中不起作用，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/44327147/