资讯 更多 >>
4月18日基金净值:景顺长城内需贰号...
C罗出租马德里豪华别墅 乔治娜曾表...
无法自拔是什么意思啊_词语无法自拔...
小孩几岁换儿童奶粉_孩子应该多大换...
万和电气(002543):4月18日北向资...
上街区济源路街道:“四声”聚力 ...
小女儿迎来1岁生日,C罗晒合照送祝...
四川省南充市市场监管局抽检食品200...
焦点信息:三只松鼠(300783):4月1...
天天讯息:中国经济信心说丨一季度...
业界更多 >>
环球快讯:工信部:加快电力设备绿色...
天天百事通!欧洲试图发展动力电池...
焦点信息:2022激光聚会活动回顾|AC...
环球热推荐:丹佛斯服贸会携手三大...
天天速递!精彩依旧,图尔克荣获202...
环球速看:运用数字孪生+智能算法,...
世界播报:锂电池快充或将突破技术难关
每日快讯!喜报!清能德创荣获国家级...
天天要闻:腾讯成国内首个获批创新...
环球消息!机器人的仿生之道
看点:广域网:通往可扩展物联网的网关
当前滚动:Kerk专利设计的静音轴套-...
天天时讯:工信部:我国已建成60家...
每日看点!机器人一定要像人吗?实力...
天天信息:移动终端市场遭遇低谷,纷...
【环球聚看点】共筑5G新生态 全面...
快看点丨马斯克:未来十年,新车有...
环球百事通!乘联会:预估8月新能源...
世界时讯:拥抱电气化,汽车动力进...
新消息丨发展燃料动力锂电池和混合...
专题报道 
当前位置: 基金 > >> 正文
 
Spring Cloud Task 任务开发-实现任务处理逻辑(二)
来源:腾讯云     时间:2023-04-19 07:05:28


【资料图】

创建任务配置类

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

@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

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

关键词:

上一条:热消息:银翼猎车手_银翼猎手 下一条:最后一页