Spring Cloud를 사용하여 마이크로서비스 아키텍처에서 작업 스케줄링 시스템을 개발하는 방법

인터넷이 발전하면서 애플리케이션 안정성, 확장성 및 유지 관리성을 개선하기 위해 분산 시스템을 구축하기 위해 마이크로서비스 아키텍처를 채택하는 기업이 점점 더 많아지고 있습니다. 마이크로서비스 아키텍처에서 작업 스케줄링 시스템은 일부 비동기 작업을 정기적으로 실행하고 다른 마이크로서비스 인터페이스를 호출하는 데 사용할 수 있는 매우 중요한 구성 요소입니다.

Spring Cloud는 Spring Cloud Netflix, Spring Cloud Config, Spring Cloud Stream, Spring Cloud Security 등과 같은 매우 강력한 도구와 프레임워크를 제공하는 오픈 소스 마이크로서비스 프레임워크입니다. 그중 Spring Cloud Netflix는 매우 인기 있는 마이크로서비스 프레임워크입니다. 이는 서비스 등록 및 검색, 클라이언트 로드 밸런싱, 구성 관리, 회로 차단기, API 게이트웨이 등과 같은 몇 가지 핵심 구성 요소 및 확장을 제공합니다.

이 기사에서는 Spring Cloud를 사용하여 작업 스케줄링 시스템을 개발하는 방법을 소개합니다. 여기에는 주로 다음 내용이 포함됩니다.

1. 작업 스케줄링 시스템의 요구 사항 분석
2. Spring Scheduler를 사용하여 작업 스케줄링 구현
3. Put Spring In Cloud 마이크로서비스 아키텍처에 작업 스케줄링 시스템

1. 작업 스케줄링 시스템의 요구사항 분석

마이크로서비스 아키텍처에서 작업 스케줄링 시스템은 다음 기능을 지원해야 합니다.

1. 작업 실행을 트리거할 수 있습니다. 특정 시점이나 순간.
2. 고정 시간 간격 또는 주기적인 시간 간격으로 작업 실행 트리거를 지원합니다.
3. 작업 실행 실패 후 재시도를 지원합니다.
4. 작업의 비동기 실행을 지원하며 기본 프로그램 실행에 영향을 주지 않습니다.
5. 작업의 동적 추가 및 삭제를 지원합니다.

2. Spring Scheduler를 사용하여 작업 스케줄링 구현

Spring Scheduler는 Spring 프레임워크의 모듈로 작업 스케줄링 기능을 쉽게 구현할 수 있는 경량 작업 스케줄링 프레임워크를 제공합니다.

1. Spring Scheduler 종속성 추가

pom 작업 로직에 Spring Scheduler 종속성을 추가합니다.

<dependency>
     <groupId>org.springframework.boot</groupId>
     <artifactId>spring-boot-starter</artifactId>
     <version>2.4.3</version>
 </dependency>

2. 작업 예약 구성 추가

Spring Boot 프로젝트에 작업 예약 구성 클래스를 추가하여 특정 작업 예약 전략과 실행된 작업을 구성합니다.

@Component
public class JobTask implements Runnable {
 
     @Override
     public void run() {
         System.out.println("running job...");
     }
 }

3. 작업 스케줄링 기능 테스트

Spring Boot 애플리케이션을 시작한 후 콘솔 출력을 볼 수 있으며 지정된 시간 간격과 주기에 따라 작업이 실행됩니다. 작업 실행 전략을 수정하려면 구성 클래스만 수정하면 됩니다.

3. Spring Cloud 마이크로서비스 아키텍처에 작업 스케줄링 시스템 넣기

작업 스케줄링 시스템 적용 시 Spring Cloud의 Eureka 또는 Consul을 사용하여 등록 검색 구성 요소를 사용하려면 작업 예약 시스템을 서비스 등록 센터에 등록하세요.

@Configuration
@EnableScheduling
public class ScheduleConfig {
 
     @Autowired
     private JobTask jobTask;
 
     //在每分钟的3秒和6秒执行一次
     @Scheduled(cron = "3-6 * * * * ?")
     public void scheduleJob1() {
         jobTask.run();
     }
 
     //在间隔5秒后执行第一次，之后每隔10秒执行一次
     @Scheduled(initialDelay = 5000, fixedRate = 10000)
     public void scheduleJob2() {
         jobTask.run();
     }
 }

1. 게이트웨이에서 라우팅 규칙 설정

Spring Cloud Gateway 또는 Zuul과 같은 API 게이트웨이를 사용하여 작업 예약 시스템을 다른 마이크로서비스에 노출하세요.

spring:
     application:
          name: task-scheduler
 
 eureka:
     instance:
          hostname: localhost
     client:
          service-url:
               defaultZone: http://localhost:8761/eureka/

2. 마이크로서비스에서 작업 예약 시스템 호출

다른 마이크로서비스에서는 Feign 또는 RestTemplate과 같은 도구를 사용하여 작업 예약 시스템에서 노출하는 RESTful API를 호출하여 비동기 작업을 실행하거나 작업 실행을 트리거합니다.

spring:
     application:
          name: api-gateway
          
 server:
     port: 8080
 
 eureka:
     instance:
          hostname: localhost
     client:
          service-url:
               defaultZone: http://localhost:8761/eureka/
 
 gateway:
     routes:
          - id: task-scheduler
               uri: lb://task-scheduler
               predicates:
                    - Path=/schedule/**

IV. 요약
3. 이 기사에서는 Spring Cloud를 사용하여 마이크로서비스 아키텍처에서 작업 예약 시스템을 개발하는 방법을 소개합니다. 여기에는 주로 Spring Scheduler를 사용하여 작업 예약을 구현하고 작업 예약 시스템을 Spring Cloud 마이크로서비스 아키텍처에 배치하는 것이 포함됩니다. 마이크로서비스 아키텍처를 도입하는 개발자들에게 안정성과 확장성이 뛰어난 분산 시스템을 보다 쉽게 ​​구축하는데 도움이 되기를 바랍니다.

위 내용은 Spring Cloud를 사용하여 마이크로서비스 아키텍처에서 작업 스케줄링 시스템을 개발하는 방법의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!