‫Cloudflare Workers برای توسعه‌دهندگان ASP.NET Core؛ بخش سوم: ذخیره‌سازی و مدیریت حالت در Edge

• خواندن (Read) بسیار سریع: خواندن داده از KV تقریباً آنی است، زیرا از نزدیک‌ترین کش Edge به کاربر خوانده می‌شود.
• نوشتن (Write) با تأخیر: وقتی شما داده‌ای را در KV می‌نویسید، ممکن است تا ۶۰ ثانیه طول بکشد تا این تغییر در تمام نقاط جهان منتشر شود.

• داده‌های پیکربندی و Feature Flags: مقادیری که به ندرت تغییر می‌کنند ولی به کرات خوانده می‌شوند.
• نقشه‌های ریدایرکت (Redirect Maps): نگهداری آدرس‌های کوتاه و بلند.
• اطلاعات پروفایل کاربری: ذخیره تنظیمات شخصی‌سازی کاربر.

• Namespace در KV مانند یک جدول یا یک دیتابیس مجزاست.

wrangler kv:namespace create "URL_STORE"

• Wrangler خروجی دستور قبل را به شما می‌دهد. آن را در فایل wrangler.toml کپی کنید تا Worker شما به این Namespace دسترسی داشته باشد.

[[kv_namespaces]]
binding = "URL_STORE"
id = "..."
preview_id = "..."

• یک POST request یک URL بلند را می‌گیرد، یک کد کوتاه تصادفی تولید می‌کند و آن را در KV ذخیره می‌کند.
• یک GET request با کد کوتاه، URL بلند را از KV می‌خواند و کاربر را به آن ریدایرکت می‌کند.

export default {
  async fetch(request: Request, env: Env): Promise<Response> {
    const url = new URL(request.url);

    if (request.method === 'POST') {
      // ۱. دریافت URL بلند از بدنه درخواست
      const longUrl = await request.text();
      if (!longUrl) return new Response('Missing URL in body', { status: 400 });

      // ۲. تولید یک کد کوتاه تصادفی
      const shortCode = Math.random().toString(36).substring(2, 8);

      // ۳. ذخیره در KV
      await env.URL_STORE.put(shortCode, longUrl);

      return new Response(`Your short URL is: ${url.origin}/${shortCode}`);
    }

    if (request.method === 'GET') {
      // ۴. دریافت کد کوتاه از مسیر
      const shortCode = url.pathname.slice(1);
      if (!shortCode) return new Response('Homepage - POST a URL to shorten it.', { status: 404 });

      // ۵. خواندن از KV
      const longUrl = await env.URL_STORE.get(shortCode);

      if (!longUrl) {
        return new Response('Short URL not found', { status: 404 });
      }

      // ۶. ریدایرکت کاربر
      return Response.redirect(longUrl, 302);
    }

    return new Response('Method not allowed', { status: 405 });
  },
};

interface Env {
  URL_STORE: KVNamespace;
}

• Bucket در R2 معادل یک کانتینر در Blob Storage است.

wrangler r2 bucket create "USER_UPLOADS"

[[r2_buckets]]
binding = "USER_UPLOADS"
bucket_name = "USER_UPLOADS"
preview_bucket_name = "USER_UPLOADS"

• یک PUT request فایل را در بدنه خود دریافت کرده و مستقیماً در R2 ذخیره می‌کند.
• یک GET request فایل را از R2 می‌خواند و برای کاربر ارسال می‌کند.

export default {
  async fetch(request: Request, env: Env): Promise<Response> {
    const url = new URL(request.url);
    const objectKey = url.pathname.slice(1);

    if (request.method === 'PUT') {
      // ۱. آپلود مستقیم بدنه درخواست در R2
      await env.USER_UPLOADS.put(objectKey, request.body);
      return new Response(`Object ${objectKey} uploaded successfully!`);
    }

    if (request.method === 'GET') {
      // ۲. دریافت آبجکت از R2
      const object = await env.USER_UPLOADS.get(objectKey);

      if (object === null) {
        return new Response('Object Not Found', { status: 404 });
      }

      // ۳. ساخت پاسخ با هدرهای مناسب
      const headers = new Headers();
      object.writeHttpMetadata(headers);
      headers.set('etag', object.httpEtag);

      // ۴. ارسال بدنه آبجکت (فایل) به کاربر
      return new Response(object.body, { headers });
    }

    return new Response('Method Not Allowed', { status: 405 });
  },
};

interface Env {
  USER_UPLOADS: R2Bucket;
}

• ابتدا کش را برای درخواست بررسی کن.
• اگر پاسخ در کش بود (Cache Hit)، همان را برگردان.
• اگر نبود (Cache Miss)، درخواست را به سرور اصلی بفرست.
• پاسخ را از سرور اصلی بگیر، آن را در کش قرار بده و سپس برای کاربر ارسال کن.

export default {
  async fetch(request: Request, env: Env, ctx: ExecutionContext): Promise<Response> {
    // ۱. دسترسی به کش پیش‌فرض Edge
    const cache = caches.default;
    
    // ۲. بررسی وجود درخواست در کش
    let response = await cache.match(request);
    
    if (response) {
      console.log('Cache HIT!');
      // ۳. اگر در کش بود، همان را برگردان
      return response;
    }
    console.log('Cache MISS!');

    // ۴. اگر در کش نبود، درخواست را به سرور اصلی بفرست
    response = await fetch(request);

    // ۵. یک کپی قابل تغییر از پاسخ بساز تا بتوانیم هدرها را تغییر دهیم
    response = new Response(response.body, response);
    
    // ۶. تنظیم هدر برای کش شدن در شبکه کلادفلر به مدت ۶۰ ثانیه
    response.headers.set('Cache-Control', 's-maxage=60');
    
    // ۷. پاسخ را در کش ذخیره کن. ctx.waitUntil باعث می‌شود این کار در پس‌زمینه انجام شود
    // و کاربر منتظر اتمام آن نماند.
    ctx.waitUntil(cache.put(request, response.clone()));
    
    // ۸. پاسخ را به کاربر برگردان
    return response;
  },
};