1. 개요
이전 기사 에서 우리는 @Scheduled 를 사용하여 Spring에서 작업을 예약하는 방법을 시연 했습니다. 어노테이션. 이 기사 에서는 이전 기사에 제시된 각 사례에 대해 Jakarta EE 애플리케이션에서 타이머 서비스를 사용하여 동일한 작업을 수행하는 방법을 보여줍니다 .
2. 일정 지원 활성화
Jakarta EE 애플리케이션에서는 시간 제한 작업에 대한 지원을 활성화할 필요가 없습니다. 타이머 서비스는 응용 프로그램이 시간 기반 이벤트에 대해 예약된 메서드를 호출할 수 있도록 하는 컨테이너 관리 서비스입니다. 예를 들어, 응용 프로그램은 통계를 생성하기 위해 특정 시간에 일부 일일 보고서를 실행해야 할 수 있습니다.
타이머에는 두 가지 유형이 있습니다.
- 프로그래밍 방식 의 타이머: 타이머 서비스는 모든 빈(상태 저장 세션 빈 제외)에 주입할 수 있으며 비즈니스 로직은 @Timeout 어노테이션이 달린 메서드에 배치해야 합니다 . 타이머는 Bean의 @PostConstruct 어노테이션이 달린 메서드로 초기화 하거나 메서드를 호출하는 것만으로 초기화할 수도 있습니다.
- 자동 타이머 : 비즈니스 로직은 @Schedule 또는 @Schedules 어노테이션이 달린 모든 메서드에 배치됩니다 . 이러한 타이머는 응용 프로그램이 시작되는 즉시 초기화됩니다.
첫 번째 예부터 시작하겠습니다.
3. 고정 지연으로 작업 예약
Spring에서는 @Scheduled(fixedDelay = 1000) 어노테이션을 사용하여 간단하게 수행됩니다. 이 경우 마지막 실행 종료와 다음 실행 시작 사이의 기간이 고정됩니다. 작업은 항상 이전 작업이 완료될 때까지 기다립니다.
Jakarta EE에서 정확히 동일한 작업을 수행하는 것은 제공되는 유사한 기본 제공 메커니즘이 없기 때문에 달성하기가 약간 더 어렵습니다. 그럼에도 불구하고 약간의 추가 코딩으로 유사한 시나리오를 구현할 수 있습니다. 이 작업이 어떻게 수행되는지 살펴보겠습니다.
@Singleton
public class FixedTimerBean {
@EJB
private WorkerBean workerBean;
@Lock(LockType.READ)
@Schedule(second = "*/5", minute = "*", hour = "*", persistent = false)
public void atSchedule() throws InterruptedException {
workerBean.doTimerWork();
}
}
@Singleton
public class WorkerBean {
private AtomicBoolean busy = new AtomicBoolean(false);
@Lock(LockType.READ)
public void doTimerWork() throws InterruptedException {
if (!busy.compareAndSet(false, true)) {
return;
}
try {
Thread.sleep(20000L);
} finally {
busy.set(false);
}
}
}보시다시피 타이머는 5초마다 트리거되도록 예약되어 있습니다. 그러나 우리의 경우에 트리거된 메서드 는 현재 Thread 에서 sleep() 호출을 통해 20초의 응답 시간을 시뮬레이트했습니다 .
결과적으로 컨테이너는 매 5초마다 doTimerWork() 를 계속 호출하지만 이전 호출이 완료되지 않은 경우 메서드 시작 부분에 있는 busy.compareAndSet(false, true) 조건이 즉시 반환됩니다. 여기서 우리는 이전 작업이 완료된 후에만 다음 작업이 실행되도록 합니다.
4. 고정 속도로 작업 예약
이를 수행하는 한 가지 방법은 @Resource 를 사용하여 주입되고 @PostConstruct 어노테이션이 지정된 메서드에서 구성 되는 타이머 서비스 를 사용하는 것 입니다. @Timeout 어노테이션이 달린 메서드 는 타이머가 만료되면 호출됩니다.
이전 기사에서 언급했듯이 태스크 실행의 시작은 이전 실행이 완료될 때까지 기다리지 않습니다. 이 옵션은 작업의 각 실행이 독립적일 때 사용해야 합니다. 다음 코드 스니펫은 매초마다 실행되는 타이머를 생성합니다.
@Startup
@Singleton
public class ProgrammaticAtFixedRateTimerBean {
@Inject
Event<TimerEvent> event;
@Resource
TimerService timerService;
@PostConstruct
public void initialize() {
timerService.createTimer(0,1000, "Every second timer with no delay");
}
@Timeout
public void programmaticTimout(Timer timer) {
event.fire(new TimerEvent(timer.getInfo().toString()));
}
}또 다른 방법은 @Scheduled 어노테이션을 사용하는 것입니다. 다음 코드 스니펫에서는 5초마다 타이머를 실행합니다.
@Startup
@Singleton
public class ScheduleTimerBean {
@Inject
Event<TimerEvent> event;
@Schedule(hour = "*", minute = "*", second = "*/5", info = "Every 5 seconds timer")
public void automaticallyScheduled(Timer timer) {
fireEvent(timer);
}
private void fireEvent(Timer timer) {
event.fire(new TimerEvent(timer.getInfo().toString()));
}
}5. 초기 지연이 있는 작업 예약
사용 사례 시나리오에서 지연으로 타이머를 시작해야 하는 경우에도 그렇게 할 수 있습니다. 이 경우 Jakarta EE는 타이머 서비스 의 사용을 허용합니다 . 타이머의 초기 지연 시간이 10초이고 5초마다 실행되는 예를 살펴보겠습니다.
@Startup
@Singleton
public class ProgrammaticWithInitialFixedDelayTimerBean {
@Inject
Event<TimerEvent> event;
@Resource
TimerService timerService;
@PostConstruct
public void initialize() {
timerService.createTimer(10000, 5000, "Delay 10 seconds then every 5 seconds timer");
}
@Timeout
public void programmaticTimout(Timer timer) {
event.fire(new TimerEvent(timer.getInfo().toString()));
}
}샘플에 사용된 createTimer 메서드는 다음 시그니처 c reateTimer ( long initialDuration, long intervalDuration, java.io.Serializable info) 를 사용합니다 . 여기서 initialDuration 은 첫 번째 타이머 만료 알림 전에 경과해야 하는 밀리초 수이고 intervalDuration 은 타이머 만료 알림 사이에 경과해야 하는 밀리초.
이 예제에서는 10초의 initialDuration 과 5초의 intervalDuration 을 사용하고 있습니다. 태스크는 initialDuration 값 이후에 처음으로 실행되며 intervalDuration 에 따라 계속 실행됩니다 .
6. Cron 표현식을 사용하여 작업 예약
프로그래밍 방식과 자동 모두 우리가 본 모든 스케줄러는 cron 표현식의 사용을 허용합니다. 예를 보자:
@Schedules ({
@Schedule(dayOfMonth="Last"),
@Schedule(dayOfWeek="Fri", hour="23")
})
public void doPeriodicCleanup() { ... }이 예제에서 doPeriodicCleanup() 메서드 는 매주 금요일 23:00와 매월 말일에 호출됩니다.
7. 결론
이 기사 에서는 Spring을 사용하여 샘플을 수행한 이전 기사를 시작점으로 사용하여 Jakarta EE 환경에서 작업을 예약하는 다양한 방법을 살펴보았습니다 .
코드 샘플은 GitHub 리포지토리 에서 찾을 수 있습니다 .
