Google Drive 이미지 프록시 성능 개선 2

Browser → Nginx → Spring Boot(/photo/**) → Google Drive API (이미지 다운로드) → 응답

// 기존 코드
val metaFuture = asyncSupply(virtualThreadExecutor) {
    drive.files().get(fileId)
        .setFields("id, name, mimeType, size")
        .execute()                                   // ← Google Drive 왕복 ①
}
val downloadFuture = asyncSupply(virtualThreadExecutor) {
    val buffer = ByteArrayOutputStream()
    drive.files().get(fileId).executeMediaAndDownloadTo(buffer)  // ← Google Drive 왕복 ②
    buffer.toByteArray()
}
val fileMeta = metaFuture.get()
val mimeType = fileMeta.mimeType

// 개선 후
private fun resolveMimeType(fileName: String): String? {
    return when (fileName.substringAfterLast('.', "").lowercase()) {
        "jpg", "jpeg" -> "image/jpeg"
        "png"         -> "image/png"
        "webp"        -> "image/webp"
        "gif"         -> "image/gif"
        "heic"        -> "image/heic"
        else          -> null
    }
}

fun getImageByPath(path: String): ImageResource? {
    // ...
    val mimeType = resolveMimeType(fileName)
        ?: throw RuntimeException("file is not image : $fileName (경로: $path)")

    val buffer = ByteArrayOutputStream()
    drive.files().get(fileId).executeMediaAndDownloadTo(buffer)
    val bytes = buffer.toByteArray()

    return ImageResource(
        inputStream = ByteArrayInputStream(bytes),
        mimeType = mimeType,
        fileName = fileName,
        fileSize = bytes.size.toLong()
    )
}

// 구현은 간단하지만...
@DynamicCacheable(value = ["driveImageBytes"], key = "#path", ttlMinutes = 1440)
fun getImageBytes(path: String, fileId: String, drive: Drive): ByteArray {
    val buffer = ByteArrayOutputStream()
    drive.files().get(fileId).executeMediaAndDownloadTo(buffer)
    return buffer.toByteArray()
}

# 캐시 저장소 선언 (http 블록)
proxy_cache_path /var/cache/nginx/photo
                 levels=1:2
                 keys_zone=photo_cache:10m
                 max_size=3g
                 inactive=14d;

# 이미지 서빙 (server 블록)
location /photo/ {
    proxy_pass http://127.0.0.1:8080;
    proxy_cache photo_cache;
    proxy_cache_key "$uri";
    proxy_cache_valid 200 14d;
    proxy_cache_use_stale error timeout updating;
    add_header X-Cache-Status $upstream_cache_status;

    # ↓ 업스트림의 Cache-Control 무시하고 nginx 기준으로 캐시
    proxy_ignore_headers Cache-Control Expires;
    # 업로드 후 캐시 갱신용 — X-Cache-Refresh 헤더가 있으면 캐시 우회 후 재저장
    proxy_cache_bypass $http_x_cache_refresh;
    proxy_no_cache     $http_x_cache_refresh;
}

private fun refreshNginxCache(path: String) {
    runCatching {
        val headers = HttpHeaders().apply { set("X-Cache-Refresh", "1") }
        restTemplate.exchange(
            "http://127.0.0.1/photo/$path",
            HttpMethod.GET,
            HttpEntity<Void>(headers),
            ByteArray::class.java
        )
    }.onFailure { log.warn("Nginx cache refresh 실패: $path", it) }
}

private fun warmUpNginxCache(path: String) {
    runCatching {
        restTemplate.getForEntity("http://127.0.0.1/photo/$path", ByteArray::class.java)
    }.onFailure { log.warn("Nginx cache warm-up 실패: $path", it) }
}

fun uploadImage(folderPath: String, file: MultipartFile): Pair<File, File> {
    // ... 기존 업로드 로직 ...
    googleDriveCacheSaver.evictAllFileIdCache()
    val result = Pair(mainJobFuture.get(), subJobFuture.get())

    // 원본 + 썸네일 비동기 캐시 워밍 (업로드 응답을 블로킹하지 않음)
    asyncSupply(virtualThreadExecutor) { warmUpNginxCache("$folderPath/${result.first.name}") }
    asyncSupply(virtualThreadExecutor) { warmUpNginxCache("$folderPath/${result.second.name}") }

    return result
}

Cache-Control: public, max-age=86400
Cf-Cache-Status: MISS

Browser → Cloudflare (MISS) → Nginx → Spring Boot → Google Drive

# Nginx 캐시 동작 확인 (origin에 직접 요청)
curl -sI http://127.0.0.1:80/photo/lifelog/pictures/5/_DSC0976-2.jpg \
  | grep -i 'x-cache-status\|cache-control'

# 결과
Cache-Control: public, max-age=86400
X-Cache-Status: HIT

accept-ranges: bytes
age: 3102
cf-cache-status: HIT        ← Cloudflare 엣지에서 서빙
x-cache-status: EXPIRED     ← Cloudflare가 origin 캐시 채울 때의 Nginx 상태 (현재 요청과 무관)
cache-control: public, max-age=86400

Browser → Cloudflare → Nginx → Spring Boot → Google Drive

[Cloudflare HIT — 대부분의 요청]
  Browser → Cloudflare (HIT) → 응답 반환
  ※ Nginx, Spring Boot, Google Drive 모두 우회

[Cloudflare MISS — 캐시 만료 또는 첫 요청]
  Browser → Cloudflare (MISS) → Nginx (HIT) → 응답 반환
  ※ Spring Boot, Google Drive 우회

[nginx도 MISS — nginx 캐시 만료 시]
  Browser → Cloudflare (MISS) → Nginx (MISS) → Spring Boot → Google Drive
  → Nginx 캐시 저장 → Cloudflare 캐시 저장 → 응답 반환