首页 > 滚动

Spring Cloud Task 任务开发-实现任务处理逻辑(二)

环球网 2023-04-21 16:21:08


【资料图】

创建任务配置类

接下来,我们需要创建一个任务配置类,用于配置任务的输入和输出。

@Configuration@EnableTaskpublic class StringReverseTaskConfiguration {    @Bean    public TaskConfigurer taskConfigurer() {        return new DefaultTaskConfigurer(dataSource());    }    @Bean    public DataSource dataSource() {        return new EmbeddedDatabaseBuilder()                .setType(EmbeddedDatabaseType.H2)                .addScript("classpath:org/springframework/cloud/task/schema-h2.sql")                .build();    }    @Bean    public CommandLineRunner commandLineRunner(TaskExplorer taskExplorer) {        return args -> {            List taskExecutions = taskExplorer.getTaskExecutions(taskExplorer.getLatestTaskExecution("string-reverse-task").getTaskName());            for (TaskExecution taskExecution : taskExecutions) {                System.out.println("Execution: " + taskExecution.getExecutionId() + " / Task name: " + taskExecution.getTaskName() + " / Start time: " + taskExecution.getStartTime() + " / End time: " + taskExecution.getEndTime() + " / Exit code: " + taskExecution.getExitCode());            }        };    }    @Bean    public Task stringReverseTask() {        return new SimpleTaskBuilder()                .name("string-reverse-task")                .input("Hello World!")                .tasklet(new StringReverseTask())                .build();    }}

在上面的代码中,我们创建了一个名为stringReverseTask的任务,使用SimpleTaskBuilder类创建任务对象。我们通过name方法来为任务命名,通过input方法设置任务的输入,通过tasklet方法设置任务的执行逻辑。这里我们使用了之前实现的StringReverseTask类作为任务执行逻辑。

运行任务

现在,我们已经实现了任务的输入、输出以及任务处理逻辑,接下来我们需要运行任务。

我们可以通过CommandLineRunner类运行任务,CommandLineRunner接口在Spring Boot应用程序启动后执行一些预定义的任务。我们在之前的StringReverseTaskConfiguration类中定义了一个CommandLineRunner类,该类通过TaskExplorer类查询任务执行结果并将结果输出到控制台。

现在我们可以运行Spring Boot应用程序,看到任务的执行结果:

Received input: Hello World!Output: !dlroW olleHExecution: 1 / Task name: string-reverse-task / Start time: 2022-04-23 17:09:27.149 / End time: 2022-04-23 17:09:27.155 / Exit code: 0

在上面的输出中,我们可以看到任务的输入和输出,以及任务的执行结果。此外,我们还可以看到任务的执行时间和退出码。

上一篇 下一篇
热文推荐 更多

Spring Cloud Task 任务开发-实现任务处理逻辑(二)

2023-04-21

<第5594期>【榜样】安徽新闻联播|高军:公益诉讼“探路者” 头条焦点

2023-04-21

有毒,千万别吃!国家卫健委紧急提示

2023-04-21

世界微动态丨安徽金融为科创企业发展保驾护航

2023-04-21

齐齐哈尔:中车齐车集团齐车公司再添一项国家级荣誉 焦点

2023-04-21

动态焦点:大连足球史上今天:2000年实德5比0狂胜山东鲁能,面对卫冕冠军强势爆发!(4月20日)

2023-04-21

世界视讯!众神的黄昏:2023上海车展,这些燃油车想绝地反击?

2023-04-21

今日热讯:2022马桶十大品牌排行榜_马桶哪个牌子好

2023-04-21

曹操高陵遗址博物馆高质量发展专家座谈会安阳召开

2023-04-21

可爱爆棚!自动驾驶小巴开到滇池绿道坝河湿地公园

2023-04-21

房山区窦店镇苏村推行“垃圾不落地”政策 规范垃圾收运方式

2023-04-21

凯迪拉克ct6用什么机油,凯迪拉克ct6机油型号 当前通讯

2023-04-21

91充值平台_91豆充值中心 世界最新

2023-04-21

椰视频 | 万宁长丰镇举办黎族苗族传统节日“三月三”分会场活动

2023-04-21

11岁女孩玩密室逃脱被惊吓致9级伤残,获赔20余万

2023-04-21

RMC:巴黎管理层以及姆巴佩将与加尔蒂就歧视事件沟通交流

2023-04-21

P7为什么能漂移带动布局 控制配置和动力是关键?-世界时讯

2023-04-21

国海证券给予爱玛科技买入评级 全球速读

2023-04-21

4月20日南通星辰双酚A装置稳定 焦点报道

2023-04-21

全球今热点:Scout再度证明自己!院长实力很强,为何展现强悍带队能力?

2023-04-21