ป้ายกำกับ: Theme

<?php
// 1. การตั้งค่าและเตรียมการ (Setup)
require 'vendor/autoload.php'; // สมมติว่าใช้ Composer autoload
use Redis;

/**
 * @var Redis $redisInstance ตัวแปรสำหรับเชื่อมต่อ Redis
 */
try {
    $redisInstance = new Redis();
    // เชื่อมต่อไปยัง Redis Server ที่ localhost:6379
    $redisInstance->connect('127.0.0.1', 6379);
    echo "✅ Connected to Redis successfully.";
} catch (Exception $e) {
    die("❌ Could not connect to Redis: " . $e->getMessage());
}

/**
 * ฟังก์ชันจำลองการดึงข้อมูลจากฐานข้อมูล (Database Layer)
 * @param int $productId รหัสสินค้าที่ต้องการค้นหา
 * @return array|null ข้อมูลสินค้า หรือ null หากไม่พบ
 */
function getProductFromDatabase(int $productId): ?array {
    echo "--- 💾 [DB CALL] กำลังเรียกข้อมูลจากฐานข้อมูลสำหรับ Product ID: {$productId} ... (Slow Operation) ---\n";
    // จำลองการหน่วงเวลาเพื่อแสดงว่านี่คือภาระงานที่หนัก
    sleep(1); 
    return [
        'id' => $productId,
        'name' => 'Product Alpha ' . $productId,
        'description' => 'This is a highly detailed description for product ' . $productId,
        'price' => 999.00
    ];
}

/**
 * ฟังก์ชันหลักที่ใช้ Object Caching (Service Layer)
 * @param Redis $redisInstance ตัวเชื่อมต่อ Redis
 * @param int $productId รหัสสินค้า
 * @return array|null ข้อมูลสินค้า
 */
function getProductCached(Redis $redisInstance, int $productId): ?array {
    // 1. กำหนด Key สำหรับการ Cache (ควรเป็น Unique และระบุ Context)
    $cacheKey = "product:{$productId}:details";
    
    echo "\n--- 🔍 [CACHE CHECK] ตรวจสอบข้อมูลใน Redis ด้วย Key: {$cacheKey} ---\n";

    // 2. ลองดึงข้อมูลจาก Cache ก่อน (Read Operation)
    $cachedData = $redisInstance->get($cacheKey);

    if ($cachedData !== false) {
        echo "✅ [CACHE HIT] พบข้อมูลใน Redis! ข้ามการเรียก DB.\n";
        // เนื่องจากเราเก็บเป็น JSON string ต้องทำการ Decode กลับมาเป็น PHP Array/Object
        return json_decode($cachedData, true); 
    } else {
        echo "❌ [CACHE MISS] ไม่พบข้อมูลใน Redis. ต้องไปดึงจากฐานข้อมูลจริง.\n";
    }

    // 3. ถ้า Cache Miss ให้เรียกใช้ Database (Expensive Operation)
    $data = getProductFromDatabase($productId);

    if ($data) {
        // 4. เมื่อได้ข้อมูลแล้ว ให้ทำการเก็บเข้า Cache ด้วย TTL (Time To Live)
        // เรากำหนดให้ข้อมูลนี้มีอายุแค่ 60 วินาที
        $ttlSeconds = 60;
        $serializedData = json_encode($data);
        $redisInstance->setex($cacheKey, $ttlSeconds, $serializedData);
        echo "💾 [CACHE WRITE] บันทึกข้อมูลลง Redis เรียบร้อยแล้ว (TTL: {$ttlSeconds}s).\n";
    }

    return $data;
}


// ====================================================
// 🚀 การทดสอบการทำงาน (Simulation)
// ====================================================

$productIdToTest = 101;

echo "==================================================\n";
echo ">>> RUN 1: ครั้งแรกที่เรียกใช้ (Cache Miss) <<<\n";
echo "==================================================";
$productData1 = getProductCached($redisInstance, $productIdToTest);
print_r($productData1);

// รอเวลาสั้นๆ เพื่อให้เห็นความแตกต่างของการทำงาน
sleep(1); 

echo "\n\n==================================================\n";
echo ">>> RUN 2: เรียกใช้ซ้ำทันที (Cache Hit) <<<\n";
echo "==================================================";
$productData2 = getProductCached($redisInstance, $productIdToTest);
print_r($productData2);

// ล้างข้อมูลใน Cache เพื่อจำลองการหมดอายุของ TTL
$redisInstance->del("product:{$productIdToTest}:details");
echo "\n\n--- 🗑️ [CLEANUP] ลบข้อมูลออกจาก Redis เพื่อทดสอบรอบถัดไป ---\n";


echo "\n\n==================================================\n";
echo ">>> RUN 3: เรียกใช้หลังจาก Cache หมดอายุ (Cache Miss อีกครั้ง) <<<\n";
echo "==================================================";
$productData3 = getProductCached($redisInstance, $productIdToTest);
print_r($productData3);

// ปิดการเชื่อมต่อ Redis เมื่อเสร็จสิ้น
$redisInstance->close();
?>