📖 12주차 03강: Redis 캐시 아키텍처, 캐시 태그(Cache Tags)와 병렬 동시성(Concurrency)

<?php

namespace App\Services;

use App\Models\Book;
use Illuminate\Support\Facades\Cache;

class BookRankingService
{
    /**
     * 주간 종합 베스트셀러 10권 조회 (1시간 동안 캐싱)
     */
    public function getWeeklyBestsellers(): array
    {
        // 'bestsellers:weekly' 키로 캐시가 있으면 반환, 없으면 클로저 실행 후 캐시 저장
        return Cache::tags(['books', 'bestsellers'])->remember('bestsellers:weekly', now()->addHour(), function () {
            // 복잡한 집계 쿼리 실행
            return Book::with(['authors', 'publisher'])
                ->where('is_sold_out', false)
                ->orderByDesc('sales_count')
                ->take(10)
                ->get()
                ->toArray();
        });
    }

    /**
     * 카테고리별 인기 도서 조회 (캐시 태그 다중 적용)
     */
    public function getBestsellersByCategory(int $categoryId): array
    {
        $cacheKey = "category_bestsellers:{$categoryId}";

        return Cache::tags(['books', "category:{$categoryId}"])->remember($cacheKey, now()->addMinutes(30), function () use ($categoryId) {
            return Book::where('category_id', $categoryId)
                ->orderByDesc('sales_count')
                ->take(8)
                ->get()
                ->toArray();
        });
    }
}

<?php

namespace App\Observers;

use App\Models\Book;
use Illuminate\Support\Facades\Cache;
use Illuminate\Support\Facades\Log;

class BookObserver
{
    public function updated(Book $book): void
    {
        // 1. 해당 도서가 속한 카테고리 태그의 캐시만 정밀 삭제
        Cache::tags(["category:{$book->category_id}"])->flush();

        // 2. 베스트셀러 태그 캐시 삭제
        Cache::tags(['bestsellers'])->flush();

        Log::info("[캐시 무효화] 도서 #{$book->id} 변경으로 카테고리 #{$book->category_id} 및 베스트셀러 캐시가 갱신되었습니다.");
    }
}

use Illuminate\Support\Facades\Cache;

public function processPayment(Request $request, int $orderId)
{
    // 'lock:order:123' 락을 최대 10초 동안 획득 시도
    $lock = Cache::lock("lock:order:{$orderId}", 10);

    if (!$lock->get()) {
        return response()->json([
            'message' => '현재 결제 처리가 이미 진행 중입니다. 잠시만 기다려 주세요.'
        ], 429);
    }

    try {
        // 결제 PG사 통신 및 주문 완료 처리
        $this->chargeCard($orderId);

        return response()->json(['status' => 'success']);
    } finally {
        // 처리가 끝나면 안전하게 락 해제
        $lock->release();
    }
}

<?php

namespace App\Http\Controllers;

use Illuminate\Support\Facades\Concurrency;
use Illuminate\Support\Facades\Http;
use Illuminate\Http\JsonResponse;

class OrderTrackingController extends Controller
{
    public function trackAllCarriers(string $trackingNumber): JsonResponse
    {
        $startTime = microtime(true);

        // 라라벨 11 Concurrency 파사드로 3개의 외부 HTTP 조회를 병렬 실행!
        [$cjStatus, $hanjinStatus, $postStatus] = Concurrency::run([
            fn () => $this->fetchCarrierStatus('CJ대한통운', 'https://api.mock.test/cj/' . $trackingNumber),
            fn () => $this->fetchCarrierStatus('한진택배', 'https://api.mock.test/hanjin/' . $trackingNumber),
            fn () => $this->fetchCarrierStatus('우체국택배', 'https://api.mock.test/epost/' . $trackingNumber),
        ]);

        $elapsed = round(microtime(true) - $startTime, 2);

        return response()->json([
            'elapsed_seconds' => $elapsed,
            'carriers' => [
                'CJ' => $cjStatus,
                'Hanjin' => $hanjinStatus,
                'Epost' => $postStatus,
            ],
        ]);
    }

    private function fetchCarrierStatus(string $name, string $url): array
    {
        // 1초 슬립 시뮬레이션
        usleep(1000000); 

        return [
            'carrier' => $name,
            'status' => '배송 중 (간선 상차 완료)',
            'updated_at' => now()->toDateTimeString(),
        ];
    }
}

// flexible 캐시 (신선한 캐시 5분, 만료 후 백그라운드 갱신 허용 유예 10분)
Cache::flexible('bestsellers', [300, 600], function () {
    return Book::topSales()->get();
});