springxd模块中调度的使用方法

Question

我正在做一个项目，需要实现以下功能：

扫描一个文件夹，获取新增的文件名
给定一个固定的时间，作业将按计划执行

我目前正在使用 spring BOOT 并且该模块针对 SpringXD

我想在这个模块中使用 Spring 调度。

感谢您给我描述或任何我可以阅读的资源。谢谢

Answer 1

我现在正在使用spring integration的ftp-inbound-adapter来实现这些功能。这是给那些来这里寻求答案的人。

Answer 2

为了启用调度，需要一个调度程序：link to official documentation

其实开启调度真的很简单。使用注释时，您需要做的是：

在您的配置中添加@EnableScheduling class:

@Configuration
@EnableAsync
@EnableScheduling
public class AppConfig {
}

并且，在您选择的 bean 中，在方法上方添加以下注释：

@Scheduled(fixedDelay=5000)

如果您需要外部 XML 配置：

将以下内容添加到您的 xml 配置文件

<task:annotation-driven executor="myExecutor" scheduler="myScheduler"/>
<task:executor id="myExecutor" pool-size="5"/>
<task:scheduler id="myScheduler" pool-size="10"/>

然后指出你要安排的方法：

<task:scheduled-tasks scheduler="myScheduler">
    <task:scheduled ref="beanA" method="methodA" fixed-delay="5000"/>
</task:scheduled-tasks>

其他有效资源： https://spring.io/guides/gs/scheduling-tasks/ 要么 http://www.mkyong.com/spring-batch/spring-batch-and-spring-taskscheduler-example/

springxd模块中调度的使用方法

How to use scheduling in springxd module

spring

spring-integration

spring-xd

spring-boot