江苏龙网

  1. 主页 > 生活百科 > >

什么是Spring Cloud Task啊？简单示例下( 三 )

Spring Cloud

5. 从Stream启动任务我们可以从Spring Cloud Stream触发任务 。为了达到这个目的，我们使用@EnableTaskLaucnher注解 。这一次，我们使用Spring Boot应用程序添加注释，TaskSink将可用：
@SpringBootApplication@EnableTaskLauncherpublic class StreamTaskSinkApplication {public static void main(String[] args) {SpringApplication.run(TaskSinkApplication.class, args);}}TaskSink从一个流中接收消息，信息中包含GenericMessage含有TaskLaunchRequest作为有效负载 。然后它触发任务启动请求中提供的基于任务的坐标 。
要使TaskSink起作用，我们需要配置一个实现TaskLauncher接口的bean 。出于测试目的，我们在这里Mock实现：
@Beanpublic TaskLauncher taskLauncher() {return mock(TaskLauncher.class);}我们需要注意的是，TaskLauncher接口仅在添加
spring-cloud-deployer-local依赖项后才可用：
<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-deployer-local</artifactId><version>1.3.1.RELEASE</version></dependency>我们可以测试通过调用发起的任务是否输入了Sink：
public class SpringCloudTaskSinkApplicationIntegrationTest{@Autowiredprivate Sink sink;//}现在，我们创建一个TaskLaunchRequest实例，并将其作为GenericMessage < TaskLaunchRequest >对象的有效负载发送 。然后我们可以调用Sink的输入通道，将GenericMessage对象保留在通道中 。
六，结论在本文中，我们探讨了Spring Cloud Task的执行方式以及如何配置它以在数据库中记录其事件 。我们还观察了如何定义Spring Batch作业并将其存储在TaskRepository中 。最后，我们解释了如何从Spring Cloud Stream中触发Task 。

【什么是Spring Cloud Task啊？简单示例下】


推荐阅读


上一篇：日语中的修饰语是什么?日语修饰词是什么意思

下一篇：她救了他,他宠她一生?全新重生甜宠文-这是她第二次成为他的心尖宠