[chore] : 스케줄러에 shedlock 설정 추가 및 적용 (#52)

* chore : 모듈별 프로퍼티파일 설정 추가

* chore : shedlock, redis 의존성 추가

* chore : shedlock 설정 추가 및 적용

.gitignore

@@ -8,6 +8,9 @@ build/
 .DS_Store
 core/src/main/resources/application.yml
 scheduler/src/main/resources/application.yml
+api/src/main/resources/application.yml
+application-core.yml
+application-scheduler.yml
 
 ### STS ###
 .apt_generated

api/src/main/java/dev/hooon/ApiApplication.java

@@ -7,6 +7,7 @@
 public class ApiApplication {
 
     public static void main(String[] args) {
+        System.setProperty("spring.config.name", "application-core,application,application-scheduler");
         SpringApplication.run(ApiApplication.class, args);
     }
 }

core/build.gradle

@@ -3,6 +3,7 @@ dependencies {
     implementation 'org.springframework.boot:spring-boot-starter'
     implementation 'org.springframework.boot:spring-boot-starter-data-jpa'
     implementation 'com.fasterxml.jackson.core:jackson-databind'
+    implementation 'org.springframework.boot:spring-boot-starter-data-redis'
     //테스트 픽쳐에서 사용할 의존성
     testFixturesImplementation 'org.springframework.boot:spring-boot-starter-test'
     testFixturesImplementation "org.testcontainers:testcontainers:1.19.3"

core/src/main/java/dev/hooon/common/config/RedisConfig.java

@@ -0,0 +1,20 @@
+package dev.hooon.common.config;
+
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory;
+
+@Configuration
+public class RedisConfig {
+
+	@Value("${spring.data.redis.host}")
+	public String host;
+	@Value("${spring.data.redis.port}")
+	public int port;
+
+	@Bean
+	public LettuceConnectionFactory lettuceConnectionFactory() {
+		return new LettuceConnectionFactory(host, port);
+	}
+}

scheduler/build.gradle

@@ -2,6 +2,9 @@ dependencies {
     implementation 'org.springframework.boot:spring-boot-starter-mail'
     implementation 'org.springframework.boot:spring-boot-starter-thymeleaf'
     implementation 'org.springframework:spring-tx:6.1.1'
+    // shedlock
+    implementation 'net.javacrumbs.shedlock:shedlock-spring:5.1.0'
+    implementation 'net.javacrumbs.shedlock:shedlock-provider-redis-spring:5.1.0'
 
     implementation project(':core')
     testImplementation(testFixtures(project(':core')))

scheduler/src/main/java/dev/hooon/SchedulerApplication.java

@@ -7,6 +7,7 @@
 public class SchedulerApplication {
 
 	public static void main(String[] args) {
+		System.setProperty("spring.config.name", "application-core,application,application-scheduler");
 		SpringApplication.run(SchedulerApplication.class, args);
 	}
 }

scheduler/src/main/java/dev/hooon/common/config/SchedulerConfig.java

@@ -2,16 +2,28 @@
 
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
+import org.springframework.data.redis.connection.RedisConnectionFactory;
 import org.springframework.scheduling.TaskScheduler;
 import org.springframework.scheduling.annotation.EnableAsync;
 import org.springframework.scheduling.annotation.EnableScheduling;
 import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;
 
+import net.javacrumbs.shedlock.core.LockProvider;
+import net.javacrumbs.shedlock.provider.redis.spring.RedisLockProvider;
+import net.javacrumbs.shedlock.spring.annotation.EnableSchedulerLock;
+
 @Configuration
 @EnableScheduling
 @EnableAsync
+@EnableSchedulerLock(defaultLockAtLeastFor = "10s", defaultLockAtMostFor = "30s")
 public class SchedulerConfig {
 
+	@Bean
+	public LockProvider lockProvider(RedisConnectionFactory redisConnectionFactory) {
+		String lockEnv = System.getProperty("spring.profiles.active");
+		return new RedisLockProvider(redisConnectionFactory, lockEnv);
+	}
+
 	@Bean("scheduler")
 	public TaskScheduler taskScheduler() {
 		ThreadPoolTaskScheduler executor = new ThreadPoolTaskScheduler();

scheduler/src/main/java/dev/hooon/waitingbooking/scheduler/WaitingBookingScheduler.java

@@ -3,22 +3,30 @@
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
 
+import net.javacrumbs.shedlock.spring.annotation.SchedulerLock;
+
 import dev.hooon.waitingbooking.application.facade.WaitingBookingFacade;
 import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
 
+@Slf4j
 @Component
 @RequiredArgsConstructor
 public class WaitingBookingScheduler {
 
 	private final WaitingBookingFacade waitingBookingFacade;
 
 	@Scheduled(cron = "0 0/10 * * * *")
+	@SchedulerLock(name = "wb_1", lockAtLeastFor = "9m", lockAtMostFor = "15m")
 	public void scheduleWaitingBookingProcess() {
+		log.info("wb_1 : run");
 		waitingBookingFacade.processWaitingBooking();
 	}
 
 	@Scheduled(cron = "0/5 * * * * *")
+	@SchedulerLock(name = "wb_2", lockAtLeastFor = "4s", lockAtMostFor = "8s")
 	public void scheduleExpiredWaitingBookingProcess() {
+		log.info("wb_2 : run : run");
 		waitingBookingFacade.processExpiredWaitingBooking();
 	}
 }