Merge pull request #249 from DevKor-github/develop

#245 ~ #248 반영해 운영 서버 배포

Author: soonduck-dreams

build.gradle

@@ -78,6 +78,9 @@ dependencies {
 
 	// FCM admin SDK 추가
 	implementation 'com.google.firebase:firebase-admin:9.5.0'
+
+    // Redis
+    implementation 'org.springframework.boot:spring-boot-starter-data-redis'
 }
 
 tasks.named('test') {

deploy/docker-compose.dev.yml

@@ -10,12 +10,10 @@ services:
     cpus: "0.25"
     mem_limit: "512m"
 
-    # 런타임에 생성한 RAM env 파일을 컨테이너로 그대로 주입
     env_file:
       - /run/saerok/env.dev
 
     environment:
-      # dev 오버레이에서 명시적으로 고정하고 싶은 값만 남김
       SPRING_PROFILES_ACTIVE: "dev"
       JAVA_OPTS: >-
         -Duser.timezone=Asia/Seoul
@@ -25,9 +23,13 @@ services:
         -XX:ReservedCodeCacheSize=48m
         -XX:+UseSerialGC
         -XX:+ExitOnOutOfMemoryError
+      # Redis 연결 정보
+      SPRING_DATA_REDIS_HOST: redis
+      SPRING_DATA_REDIS_PORT: "6379"
 
     depends_on:
       - postgres
+      - redis
 
   postgres:
     image: saerok-postgres:ko
@@ -38,16 +40,52 @@ services:
     # 로컬 개발/디버깅도 필요하면 열어두고, 진짜 막고 싶으면 나중에 빼면 됨
     ports:
       - "5432:5432"
-
     environment:
       POSTGRES_DB: saerok
       POSTGRES_USER: ${DB_USERNAME}
       POSTGRES_PASSWORD: ${DB_PASSWORD}
       POSTGRES_INITDB_ARGS: "--locale=ko_KR.utf8 --encoding=UTF8"
-
     volumes:
       - ./postgres-data:/var/lib/postgresql/data
 
     # t2.micro 고려한 소박한 리소스
     cpus: "0.25"
     mem_limit: "256m"
+
+  redis:
+    image: redis:7-alpine
+    container_name: saerok-redis-dev
+    restart: unless-stopped
+    # 내부 전용: 필요 시에만 포트 노출
+    # ports:
+    #   - "6379:6379"
+    command:
+      - "redis-server"
+      # --- RDB 느슨한 주기, AOF 끔 ---
+      - "--save"
+      - "900"
+      - "1"                    # 15분 동안 1건 이상 변경 시 스냅샷
+      - "--save"
+      - "300"
+      - "10"                   # 5분 동안 10건 이상 변경 시 스냅샷
+      - "--appendonly"
+      - "no"                   # AOF 비활성화
+      - "--rdbcompression"
+      - "yes"                  # 스냅샷 압축(기본값이지만 명시)
+      - "--stop-writes-on-bgsave-error"
+      - "no"                   # dev: 백업 실패로 쓰기 중단 방지
+      # --- 캐시 특성: 메모리 상한과 축출 정책 ---
+      - "--maxmemory"
+      - "128mb"
+      - "--maxmemory-policy"
+      - "allkeys-lru"
+    volumes:
+      - ./redis-data:/data      # dump.rdb 저장 위치(단일 파일로 덮어씀)
+    healthcheck:
+      test: ["CMD", "redis-cli", "ping"]
+      interval: 5s
+      timeout: 3s
+      retries: 20
+      start_period: 5s
+    cpus: "0.15"
+    mem_limit: "192m"

deploy/docker-compose.override.yml

@@ -16,16 +16,41 @@ services:
       JAVA_OPTS: >-
         -Duser.timezone=Asia/Seoul
         -XX:MaxRAMPercentage=60
+      # Redis 연결 (Spring Boot 표준 환경변수)
+      SPRING_DATA_REDIS_HOST: redis
+      SPRING_DATA_REDIS_PORT: "6379"
 
     extra_hosts:
       - "host.docker.internal:host-gateway"
 
     ports:
       - "8080:8080"
 
+    depends_on:
+      - redis
+
     healthcheck:
       test: ["CMD-SHELL", "curl -fsS http://localhost:8080/health >/dev/null || exit 1"]
       interval: 10s
       timeout: 3s
       retries: 10
       start_period: 20s
+
+  redis:
+    image: redis:7-alpine
+    container_name: saerok-redis
+    restart: unless-stopped
+    ports:
+      - "6379:6379"
+    command: ["redis-server", "--appendonly", "yes"]
+    volumes:
+      - redis-data:/data
+    healthcheck:
+      test: ["CMD", "redis-cli", "ping"]
+      interval: 5s
+      timeout: 3s
+      retries: 20
+      start_period: 5s
+
+volumes:
+  redis-data:

deploy/docker-compose.prod.yml

@@ -9,7 +9,7 @@ services:
     ports:
       - "8080:8080"
 
-    # t3.small 자원 컷
+    # t3.small 자원 컷 (기존 값 유지)
     cpus: "1.0"
     cpu_shares: 768
     mem_limit: "1100m"
@@ -31,9 +31,52 @@ services:
         -XX:ReservedCodeCacheSize=96m
         -XX:+UseG1GC
         -XX:+ExitOnOutOfMemoryError
+      # Redis 연결 정보 (prod에서도 명시)
+      SPRING_DATA_REDIS_HOST: redis
+      SPRING_DATA_REDIS_PORT: "6379"
+
+    depends_on:
+      - redis
 
     logging:
       driver: json-file
       options:
         max-size: "10m"
         max-file: "5"
+
+  redis:
+    image: redis:7-alpine
+    container_name: saerok-redis-prod
+    restart: unless-stopped
+    # 외부 노출 금지(내부 네트워크만). 필요 시에만 열 것
+    # ports:
+    #   - "6379:6379"
+    command:
+      - "redis-server"
+      # 운영: 내구성 보장(AOF), 성능 타협은 everysec로
+      - "--appendonly"
+      - "yes"
+      - "--appendfsync"
+      - "everysec"
+      - "--auto-aof-rewrite-percentage"
+      - "100"
+      - "--auto-aof-rewrite-min-size"
+      - "64mb"
+      # 캐시 특성: 메모리 상한과 축출 정책
+      - "--maxmemory"
+      - "256mb"
+      - "--maxmemory-policy"
+      - "allkeys-lru"
+    volumes:
+      - redis-data:/data
+    healthcheck:
+      test: ["CMD", "redis-cli", "ping"]
+      interval: 5s
+      timeout: 3s
+      retries: 20
+      start_period: 5s
+    cpus: "0.4"
+    mem_limit: "384m"
+
+volumes:
+  redis-data:

src/main/java/org/devkor/apu/saerok_server/domain/ad/api/AdController.java

@@ -0,0 +1,124 @@
+package org.devkor.apu.saerok_server.domain.ad.api;
+
+import io.swagger.v3.oas.annotations.Operation;
+import io.swagger.v3.oas.annotations.media.Content;
+import io.swagger.v3.oas.annotations.media.Schema;
+import io.swagger.v3.oas.annotations.responses.ApiResponse;
+import io.swagger.v3.oas.annotations.tags.Tag;
+import jakarta.validation.Valid;
+import lombok.RequiredArgsConstructor;
+import org.devkor.apu.saerok_server.domain.ad.api.dto.request.AdEventRequest;
+import org.devkor.apu.saerok_server.domain.ad.api.dto.response.AdEventStatusResponse;
+import org.devkor.apu.saerok_server.domain.ad.api.dto.response.GetAdSlotResponse;
+import org.devkor.apu.saerok_server.domain.ad.application.AdEventService;
+import org.devkor.apu.saerok_server.domain.ad.application.AdSelectionResult;
+import org.devkor.apu.saerok_server.domain.ad.application.AdSelectorService;
+import org.devkor.apu.saerok_server.domain.ad.core.entity.Ad;
+import org.devkor.apu.saerok_server.domain.ad.core.entity.AdEventType;
+import org.devkor.apu.saerok_server.global.shared.infra.ImageDomainService;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+@Tag(name = "Ad API", description = "클라이언트 광고 노출 및 이벤트 API")
+@RestController
+@RequiredArgsConstructor
+@RequestMapping("${api_prefix}/ad")
+public class AdController {
+
+    private final AdSelectorService adSelectorService;
+    private final AdEventService adEventService;
+    private final ImageDomainService imageDomainService;
+
+    @GetMapping("/slots/{slotName}")
+    @Operation(
+            summary = "슬롯 단위 광고 요청",
+            description = """
+                    주어진 슬롯 이름에 대해 광고를 하나 선택해서 반환합니다.<br>
+                    - 슬롯의 fallbackRatio에 따라 FALLBACK 또는 AD를 응답합니다.<br>
+                    - AD인 경우 이미지 URL과 클릭 시 이동할 URL을 함께 내려줍니다.
+                    """,
+            responses = {
+                    @ApiResponse(responseCode = "200", description = "응답 성공",
+                            content = @Content(schema = @Schema(implementation = GetAdSlotResponse.class))),
+                    @ApiResponse(responseCode = "404", description = "슬롯을 찾을 수 없음", content = @Content)
+            }
+    )
+    public GetAdSlotResponse getSlotAd(
+            @PathVariable String slotName
+    ) {
+        AdSelectionResult result = adSelectorService.selectAdForSlot(slotName);
+
+        if (result.isFallback()) {
+            return new GetAdSlotResponse("FALLBACK", result.ttlSeconds(), null);
+        }
+
+        Ad ad = result.ad();
+        String imageUrl = imageDomainService.toUploadImageUrl(ad.getObjectKey());
+
+        GetAdSlotResponse.AdPayload payload = new GetAdSlotResponse.AdPayload(
+                ad.getId(),
+                imageUrl,
+                ad.getTargetUrl()
+        );
+
+        return new GetAdSlotResponse("AD", result.ttlSeconds(), payload);
+    }
+
+    @PostMapping("/event/impression")
+    @Operation(
+            summary = "광고 노출 이벤트 기록",
+            description = """
+                    광고 이미지가 실제로 렌더링되었을 때 호출해 주세요.<br>
+                    deviceId는 서버에서 SHA-256 해싱 후 deviceHash로 저장합니다.<br>
+                    동일 기기에서 10초 내에 같은 슬롯의 같은 광고가 노출된 기록은 중복 기록되지 않습니다.
+                    """,
+            responses = {
+                    @ApiResponse(responseCode = "200", description = "기록 성공",
+                            content = @Content(schema = @Schema(implementation = AdEventStatusResponse.class))),
+                    @ApiResponse(responseCode = "400", description = "잘못된 요청", content = @Content),
+                    @ApiResponse(responseCode = "404", description = "광고를 찾을 수 없음", content = @Content)
+            }
+    )
+    public AdEventStatusResponse logImpression(
+            @Valid @RequestBody AdEventRequest request
+    ) {
+        adEventService.logEvent(
+                AdEventType.IMPRESSION,
+                request.adId(),
+                request.slotName(),
+                request.deviceId()
+        );
+        return new AdEventStatusResponse("ok");
+    }
+
+    @PostMapping("/event/click")
+    @Operation(
+            summary = "광고 클릭 이벤트 기록",
+            description = """
+                    광고 클릭 시 호출해 주세요.<br>
+                    deviceId는 서버에서 SHA-256 해싱 후 deviceHash로 저장합니다.<br>
+                    동일 기기에서 10초 내에 같은 슬롯의 같은 광고를 클릭한 기록은 중복 기록되지 않습니다.
+                    """,
+            responses = {
+                    @ApiResponse(responseCode = "200", description = "기록 성공",
+                            content = @Content(schema = @Schema(implementation = AdEventStatusResponse.class))),
+                    @ApiResponse(responseCode = "400", description = "잘못된 요청", content = @Content),
+                    @ApiResponse(responseCode = "404", description = "광고를 찾을 수 없음", content = @Content)
+            }
+    )
+    public AdEventStatusResponse logClick(
+            @Valid @RequestBody AdEventRequest request
+    ) {
+        adEventService.logEvent(
+                AdEventType.CLICK,
+                request.adId(),
+                request.slotName(),
+                request.deviceId()
+        );
+        return new AdEventStatusResponse("ok");
+    }
+}