중복 스케줄링 문제 예방

app-scheduler/build.gradle

@@ -10,4 +10,7 @@ dependencies {
     implementation 'org.springframework.boot:spring-boot-starter-actuator'
     // 프로메테우스 추가
     implementation 'io.micrometer:micrometer-registry-prometheus'
+    // shed-lock
+    implementation 'net.javacrumbs.shedlock:shedlock-spring:5.1.0'
+    implementation 'net.javacrumbs.shedlock:shedlock-provider-jdbc-template:5.1.0'
 }

app-scheduler/src/main/java/com/parkingcomestrue/SchedulerApplication.java

@@ -2,11 +2,13 @@
 
 import jakarta.annotation.PostConstruct;
 import java.util.TimeZone;
+import net.javacrumbs.shedlock.spring.annotation.EnableSchedulerLock;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.scheduling.annotation.EnableScheduling;
 
 @EnableScheduling
+@EnableSchedulerLock(defaultLockAtMostFor = "80s")
 @SpringBootApplication
 public class SchedulerApplication {
 

app-scheduler/src/main/java/com/parkingcomestrue/external/config/ShedLockConfig.java

@@ -0,0 +1,22 @@
+package com.parkingcomestrue.external.config;
+
+import javax.sql.DataSource;
+import net.javacrumbs.shedlock.core.LockProvider;
+import net.javacrumbs.shedlock.provider.jdbctemplate.JdbcTemplateLockProvider;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.jdbc.core.JdbcTemplate;
+
+@Configuration
+public class ShedLockConfig {
+
+    @Bean
+    public LockProvider lockProvider(DataSource dataSource) {
+        return new JdbcTemplateLockProvider(
+                JdbcTemplateLockProvider.Configuration.builder()
+                        .withJdbcTemplate(new JdbcTemplate(dataSource))
+                        .usingDbTime()
+                        .build()
+        );
+    }
+}

app-scheduler/src/main/java/com/parkingcomestrue/external/scheduler/ParkingUpdateScheduler.java

@@ -1,10 +1,10 @@
 package com.parkingcomestrue.external.scheduler;
 
-import com.parkingcomestrue.external.coordinate.CoordinateApiService;
-import com.parkingcomestrue.external.parkingapi.ParkingApiService;
 import com.parkingcomestrue.common.domain.parking.Location;
 import com.parkingcomestrue.common.domain.parking.Parking;
 import com.parkingcomestrue.common.domain.parking.repository.ParkingRepository;
+import com.parkingcomestrue.external.coordinate.CoordinateApiService;
+import com.parkingcomestrue.external.parkingapi.ParkingApiService;
 import java.util.Collection;
 import java.util.Collections;
 import java.util.List;
@@ -17,6 +17,7 @@
 import java.util.stream.Collectors;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
+import net.javacrumbs.shedlock.spring.annotation.SchedulerLock;
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
 
@@ -30,6 +31,7 @@ public class ParkingUpdateScheduler {
     private final ParkingRepository parkingRepository;
 
     @Scheduled(cron = "0 */30 * * * *")
+    @SchedulerLock(name = "autoUpdateOffer")
     public void autoUpdateOfferCurrentParking() {
         Map<String, Parking> parkingLots = readBy(ParkingApiService::offerCurrentParking);
         Map<String, Parking> saved = findAllByName(parkingLots.keySet());

domain/src/main/resources/db/migration/mysql/V5.0.0__create_shed_lock_table.sql

@@ -0,0 +1,8 @@
+CREATE TABLE shedlock
+(
+    name       VARCHAR(64)  NOT NULL,
+    lock_until TIMESTAMP(3) NOT NULL,
+    locked_at  TIMESTAMP(3) NOT NULL DEFAULT CURRENT_TIMESTAMP(3),
+    locked_by  VARCHAR(255) NOT NULL,
+    PRIMARY KEY (name)
+);