1. 개요

Spring Cloud Task의 목표는 Spring Boot 애플리케이션을위한 단기 마이크로 서비스를 생성하는 기능을 제공하는 것입니다 .

Spring Cloud Task에서 우리는 모든 작업을 동적으로 실행하고 필요에 따라 리소스를 할당하고 작업 완료 후 결과를 검색 할 수있는 유연성을 얻었습니다.

Tasks는 Spring Cloud Data Flow 내의 새로운 기본 요소로, 사용자는 거의 모든 Spring Boot 애플리케이션을 단기 작업으로 실행할 수 있습니다.

2. 간단한 작업 응용 프로그램 개발

2.1. 관련 의존성 추가

시작하려면 spring-cloud-task-dependencies를 사용 하여 의존성 관리 섹션을 추가 할 수 있습니다 .

<dependencyManagement>
    <dependencies>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-task-dependencies</artifactId>
            <version>2.2.3.RELEASE</version>
            <type>pom</type>
            <scope>import</scope>
        </dependency>
    </dependencies>
</dependencyManagement>

이 의존성 관리는 가져 오기 범위를 통해 의존성 버전을 관리합니다.

다음 의존성을 추가해야합니다.

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-task</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-task-core</artifactId>
</dependency>

이것은 spring-cloud-task-core 의 Maven Central에 대한 링크 입니다.

이제 Spring Boot 애플리케이션을 시작 하려면 관련 부모 가있는 spring-boot-starter 가 필요합니다 .

우리는 SpringData JPA를 ORM 도구로 사용할 것이므로 이에 대한 의존성도 추가해야합니다.

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-jpa</artifactId>
    <version>2.4.0</version>
</dependency>

SpringData JPA로 간단한 Spring Boot 애플리케이션을 부트 스트랩하는 방법에 대한 자세한 내용은 여기에서 확인할 수 있습니다 .

Spring-boot-starter-parent o n Maven Central 의 최신 버전을 확인할 수 있습니다 .

2.2. @EnableTask 어노테이션

Spring Cloud Task의 기능을 부트 스트랩하려면 @EnableTask 어노테이션 을 추가해야합니다 .

@SpringBootApplication
@EnableTask
public class TaskDemo {
    // ...
}

어노테이션은 그림에서 SimpleTaskConfiguration 클래스를 가져 와서 차례로 TaskRepository 및 해당 인프라를 등록합니다 . 기본적으로 메모리 내 맵은 TaskRepository 의 상태를 저장하는 데 사용됩니다 .

TaskRepository 의 기본 정보는 TaskExecution 클래스 에서 모델링됩니다 . 이 클래스의 언급 된 필드는 taskName , startTime , endTime , exitMessage 입니다. exitMessage는 출구시 사용할 수있는 정보를 저장합니다.

애플리케이션의 모든 이벤트에서 오류로 인해 종료가 발생한 경우 전체 예외 스택 추적이 여기에 저장됩니다.

Spring Boot는 포착되지 않은 예외를 철저한 디버그를 허용하는 종료 코드에 매핑 하는 인터페이스 ExitCodeExceptionMapper 를 제공합니다 . Cloud Task는 향후 분석을 위해 데이터 소스에 정보를 저장합니다.

2.3. 구성 데이터 소스 에 대한 TaskRepository을

TaskRepository 를 저장하기위한 메모리 내 맵 은 작업이 끝나면 사라지고 작업 이벤트와 관련된 데이터가 손실됩니다. 영구 저장소에 저장하기 위해 SpringData JPA를 사용하여 MySQL을 데이터 소스로 사용할 것입니다.

데이터 소스는 application.yml 파일 에서 구성 됩니다. 제공된 데이터 소스를 TaskRepository 의 저장소로 사용하도록 Spring Cloud Task를 구성하려면 DefaultTaskConfigurer 를 확장하는 클래스를 만들어야합니다 .

이제 구성된 데이터 소스 를 생성자 인수로 수퍼 클래스의 생성자에 보낼 수 있습니다 .

@Autowired
private DataSource dataSource;

public class HelloWorldTaskConfigurer extends DefaultTaskConfigurer{
    public HelloWorldTaskConfigurer(DataSource dataSource){
        super(dataSource);
    }
}

액션 위의 구성을 위해, 우리는의 인스턴스에 어노테이션을해야 할 데이터 소스를 함께 @Autowired 어노테이션과의 생성자 인자로 인스턴스를 주입 HelloWorldTaskConfigurer의 위에 정의 된 Bean :

@Bean
public HelloWorldTaskConfigurer getTaskConfigurer() {
    return new HelloWorldTaskConfigurer(dataSource);
}

이것으로 TaskRepository 를 MySQL 데이터베이스 에 저장하는 구성이 완료 됩니다.

2.4. 이행

Spring Boot에서는 애플리케이션이 시작을 완료하기 직전에 모든 태스크를 실행할 수 있습니다. ApplicationRunner 또는 CommandLineRunner 인터페이스를 사용하여 간단한 작업을 만들 수 있습니다 .

이러한 인터페이스 의 실행 메소드 를 구현 하고 구현 클래스를 Bean으로 선언해야합니다.

@Component
public static class HelloWorldApplicationRunner 
  implements ApplicationRunner {
 
    @Override
    public void run(ApplicationArguments arg0) throws Exception {
        System.out.println("Hello World from Spring Cloud Task!");
    }
}

이제 애플리케이션을 실행하면 태스크의 이벤트 데이터를 로깅하는 MySQL 데이터베이스에 생성 된 필수 테이블로 필요한 출력을 생성하는 태스크를 가져와야합니다.

3. Spring Cloud 태스크의 수명주기

처음에는 TaskRepository에 항목을 만듭니다 . 이는 모든 Bean이 Application에서 사용할 준비가되었으며 Runner 인터페이스 의 run 메소드를 실행할 준비가되었음을 나타냅니다 .

실행 메서드 실행이 완료 되거나 ApplicationContext 이벤트가 실패 하면 TaskRepository 가 다른 항목으로 업데이트됩니다.

작업 수명주기 동안 TaskExecutionListener 인터페이스 에서 사용 가능한 리스너를 등록 할 수 있습니다 . Task의 각 이벤트에서 트리거되는 onTaskEnd , onTaksFailed 및 onTaskStartup의 세 가지 메소드가있는 인터페이스를 구현하는 클래스가 필요합니다 .

TaskDemo 클래스 에서 구현 클래스의 빈을 선언해야합니다 .

@Bean
public TaskListener taskListener() {
    return new TaskListener();
}

4. Spring Batch와 통합

Spring Batch Job을 Task로 실행하고 Spring Cloud Task를 사용하여 Job 실행 이벤트를 기록 할 수 있습니다. 이 기능을 활성화하려면 부트 및 클라우드와 관련된 배치 의존성을 추가해야합니다.

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-batch</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-task-batch</artifactId>
</dependency>

다음 은 spring-cloud-task-batch 의 Maven Central에 대한 링크 입니다.

작업을 태스크로 구성하려면 JobConfiguration 클래스 에 Job Bean을 등록해야합니다 .

@Bean
public Job job2() {
    return jobBuilderFactory.get("job2")
      .start(stepBuilderFactory.get("job2step1")
      .tasklet(new Tasklet(){
          @Override
          public RepeatStatus execute(
            StepContribution contribution,
            ChunkContext chunkContext) throws Exception {
            System.out.println("This job is from Baeldung");
                return RepeatStatus.FINISHED;
          }
    }).build()).build();
}

@EnableBatchProcessing 어노테이션으로 TaskDemo 클래스 를 장식해야합니다 .

//..Other Annotation..
@EnableBatchProcessing
public class TaskDemo {
    // ...
}

@EnableBatchProcessing의 어노테이션 배치 작업을 설정하는 데 필요한 기본 구성으로 스프링 배치의 기능을 사용할 수 있습니다.

이제 애플리케이션을 실행하면 @EnableBatchProcessing 어노테이션이 Spring Batch Job 실행을 트리거하고 Spring Cloud Task는 springcloud 데이터베이스 에서 실행 된 다른 Task와 함께 모든 배치 작업의 실행 이벤트를 기록 합니다.

5. 스트림에서 작업 시작

Spring Cloud Stream에서 태스크를 트리거 할 수 있습니다. 이 목적을 달성하기 위해 @EnableTaskLaucnher 어노테이션이 있습니다. Spring Boot 앱으로 어노테이션을 추가하면 TaskSink를 사용할 수 있습니다.

@SpringBootApplication
@EnableTaskLauncher
public class StreamTaskSinkApplication {
    public static void main(String[] args) {
        SpringApplication.run(TaskSinkApplication.class, args);
    }
}

TaskSink이 유효 성분으로서 단백질 스트림으로부터 메시지를 수신 GenericMessage 함유 TaskLaunchRequest를 페이로드로한다. 그런 다음 작업 시작 요청에 제공된 좌표를 기반으로 작업을 트리거합니다.

TaskSink가 작동 하려면 TaskLauncher 인터페이스 를 구현하는 Bean을 구성해야합니다 . 테스트 목적으로 여기에서 구현을 조롱하고 있습니다.

@Bean
public TaskLauncher taskLauncher() {
    return mock(TaskLauncher.class);
}

여기서 TaskLauncher 인터페이스는 spring-cloud-deployer-local 의존성 을 추가 한 후에 만 ​​사용할 수 있다는 점에 유의해야합니다 .

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-deployer-local</artifactId>
    <version>2.3.1.RELEASE</version>
</dependency>

Sink 인터페이스의 입력 을 호출하여 Task가 시작되었는지 테스트 할 수 있습니다 .

public class StreamTaskSinkApplicationTests {
   
    @Autowired
    private Sink sink; 
    
    //
}

이제 TaskLaunchRequest 의 인스턴스를 생성하고 GenericMessage < TaskLaunchRequest > 개체 의 페이로드로 보냅니다 . 그런 다음 GenericMessage 개체를 채널에 유지하는 Sink 의 입력 채널을 호출 할 수 있습니다 .

6. 결론

이 예제에서는 Spring Cloud Task가 수행하는 방법과 데이터베이스에 이벤트를 기록하도록 구성하는 방법을 살펴 보았습니다. 또한 Spring Batch 작업이 TaskRepository에 어떻게 정의되고 저장되는지 관찰 했습니다 . 마지막으로 Spring Cloud Stream 내에서 Task를 트리거하는 방법을 설명했습니다.

항상 그렇듯이 코드는 GitHub에서 사용할 수 있습니다 .