✨feat: 선 업로드 이미지에 대한 가비지 컬렉션을 구현[#213]

주기적으로 만료된 그룹 이미지를 Redis 및 S3에서 삭제하는 예약 작업을 추가하여 스토리지 용량 증가를 방지합니다.

작업자는 유예 기간을 기준으로 만료된 이미지를 식별하고 메타데이터와 이미지 파일을 삭제합니다.
인덱스만 남아 있는 경우에도 완전한 정리를 수행합니다.

Author: LimdaeIl

src/main/java/team/wego/wegobackend/group/v2/application/service/PreUploadedGroupImageOrphanGcWorker.java

@@ -0,0 +1,76 @@
+package team.wego.wegobackend.group.v2.application.service;
+
+import java.time.Instant;
+import java.time.Duration;
+import java.util.List;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+import team.wego.wegobackend.group.v2.application.dto.common.PreUploadedGroupImage;
+import team.wego.wegobackend.group.v2.infrastructure.redis.PreUploadedGroupImageRedisRepository;
+import team.wego.wegobackend.image.application.service.ImageUploadService;
+
+@Slf4j
+@RequiredArgsConstructor
+@Component
+public class PreUploadedGroupImageOrphanGcWorker {
+
+    private final PreUploadedGroupImageRedisRepository redisRepository;
+    private final ImageUploadService imageUploadService;
+
+    // “사용자가 업로드 후 모임 생성까지 걸릴 수 있는 최대 시간”
+    // 최소 변경이 목적이면 1~2시간 정도를 권장 (너무 짧으면 정상 플로우도 삭제 위험)
+//    private static final Duration ORPHAN_GRACE = Duration.ofHours(2);
+    private static final Duration ORPHAN_GRACE = Duration.ofSeconds(30);
+
+    // 한 번에 너무 많이 지우지 않도록 제한
+    private static final int BATCH_LIMIT = 200;
+
+    // 10분마다 정도면 충분히 안정적
+    @Scheduled(fixedDelay = 30_000L)
+    public void gc() {
+        long thresholdEpochSec = Instant.now().minus(ORPHAN_GRACE).getEpochSecond();
+
+        List<String> candidates = redisRepository.findExpiredCandidates(thresholdEpochSec, BATCH_LIMIT);
+        if (candidates.isEmpty()) {
+            return;
+        }
+
+        int deleted = 0;
+        int indexOnly = 0;
+        int failed = 0;
+
+        for (String imageKey : candidates) {
+            try {
+                // 메타가 있어야 S3 URL을 알 수 있음
+                PreUploadedGroupImage meta = redisRepository.find(imageKey).orElse(null);
+
+                if (meta == null) {
+                    // TTL로 메타는 이미 만료됨 -> 인덱스만 청소
+                    redisRepository.removeIndex(imageKey);
+                    indexOnly++;
+                    continue;
+                }
+
+                // S3 삭제 (main + thumb)
+                imageUploadService.deleteAllByUrls(List.of(meta.url440x240(), meta.url100x100()));
+
+                // Redis에서 원자적으로 소비(삭제) + index 제거
+                // (이미 누가 consume했을 수도 있으니, 여기서는 "있으면 지운다" 수준으로 충분)
+                redisRepository.consume(imageKey);
+
+                deleted++;
+
+            } catch (Exception e) {
+                failed++;
+                // 실패한 건 다음 스케줄에서 재시도하게 “인덱스를 남겨둔다”
+                log.error("[PRE_UPLOADED_IMG_GC] failed imageKey={} reason={}",
+                        imageKey, e.toString(), e);
+            }
+        }
+
+        log.info("[PRE_UPLOADED_IMG_GC] done candidates={} deleted={} indexOnly={} failed={}",
+                candidates.size(), deleted, indexOnly, failed);
+    }
+}

src/main/java/team/wego/wegobackend/group/v2/infrastructure/redis/PreUploadedGroupImageRedisRepository.java

@@ -1,43 +1,72 @@
 package team.wego.wegobackend.group.v2.infrastructure.redis;
 
 import java.time.Duration;
+import java.util.ArrayList;
+import java.util.List;
 import java.util.Optional;
+import java.util.Set;
 import lombok.RequiredArgsConstructor;
 import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.data.redis.core.StringRedisTemplate;
 import org.springframework.stereotype.Repository;
 import team.wego.wegobackend.group.v2.application.dto.common.PreUploadedGroupImage;
 
 @RequiredArgsConstructor
 @Repository
 public class PreUploadedGroupImageRedisRepository {
 
-    private static final Duration TTL = Duration.ofHours(2);
+    // 메타데이터는 넉넉히: 1일 (GC, 장애 대비)
+    private static final Duration META_TTL = Duration.ofDays(1);
+
     private static final String PREFIX = "group:v2:img:pre:";
+    private static final String IDX_KEY = "group:v2:img:pre:idx";
 
-    private final RedisTemplate<String, PreUploadedGroupImage> preUploadedGroupImageRedisTemplate;
+    private final RedisTemplate<String, PreUploadedGroupImage> valueTemplate;
+    private final StringRedisTemplate stringRedisTemplate;
 
     private String key(String imageKey) {
         return PREFIX + imageKey;
     }
 
     public void save(PreUploadedGroupImage value) {
-        preUploadedGroupImageRedisTemplate.opsForValue().set(
-                key(value.imageKey()),
-                value,
-                TTL
-        );
-    }
+        valueTemplate.opsForValue().set(key(value.imageKey()), value, META_TTL);
 
-    public Optional<PreUploadedGroupImage> find(String imageKey) {
-        PreUploadedGroupImage value =
-                preUploadedGroupImageRedisTemplate.opsForValue().get(key(imageKey));
-        return Optional.ofNullable(value);
+        long score = value.createdAt().atZone(java.time.ZoneId.systemDefault()).toEpochSecond();
+        stringRedisTemplate.opsForZSet().add(IDX_KEY, value.imageKey(), score);
+        // IDX 자체 TTL은 옵션: 하루에 한 번 갱신해도 되고, 그냥 둬도 됩니다(멤버 정리로 관리).
     }
 
+
+    // 소비는 원자적으로 가져가면서 삭제
     public Optional<PreUploadedGroupImage> consume(String imageKey) {
         PreUploadedGroupImage value =
-                preUploadedGroupImageRedisTemplate.opsForValue().getAndDelete(key(imageKey));
+                valueTemplate.opsForValue().getAndDelete(key(imageKey));
+
+        // 인덱스에서도 제거(있든 없든)
+        stringRedisTemplate.opsForZSet().remove(IDX_KEY, imageKey);
+
         return Optional.ofNullable(value);
     }
+
+    public Optional<PreUploadedGroupImage> find(String imageKey) {
+        return Optional.ofNullable(valueTemplate.opsForValue().get(key(imageKey)));
+    }
+
+
+    // 고아 이미지 삭제 전용: 특정 시간 이전 imageKey들 배치로 뽑기
+    public List<String> findExpiredCandidates(long thresholdEpochSec, int limit) {
+        // ZRANGEBYSCORE idx -inf threshold LIMIT 0 limit
+        Set<String> set = stringRedisTemplate.opsForZSet()
+                .rangeByScore(IDX_KEY, Double.NEGATIVE_INFINITY, thresholdEpochSec, 0, limit);
+
+        if (set == null || set.isEmpty()) {
+            return List.of();
+        }
+        return new ArrayList<>(set);
+    }
+
+    public void removeIndex(String imageKey) {
+        stringRedisTemplate.opsForZSet().remove(IDX_KEY, imageKey);
+    }
 }