用户请求 → Cloudflare CDN（边缘节点）
         ↓
    Cloudflare Pages（前端静态资源）
         ↓
    Cloudflare Workers（API 服务）
         ↓
    ┌─────────┬─────────┬─────────┐
    │    KV   │   R2    │   D1    │
    │ 缓存/状态 │ 对象存储 │ 数据库   │
    └─────────┴─────────┴─────────┘
         ↓
    Cloudflare Private Network（私有网络）
         ↓
    自有 VPS / 容器（重任务处理）

# 安装 Wrangler
npm install -g wrangler

# 本地开发
wrangler pages dev

# 直接部署（甚至不用接 GitHub）
wrangler pages deploy ./.svelte-kit/cloudflare/

// src/worker.js
export default {
  async fetch(request, env) {
    const url = new URL(request.url);

    // 路由分发
    if (url.pathname === '/api/hello') {
      return new Response(JSON.stringify({
        message: 'Hello from Cloudflare Workers!',
        location: request.cf?.colo  // 告诉你这个请求是哪个边缘节点处理的
      }), {
        headers: { 'Content-Type': 'application/json' }
      });
    }

    // 其他请求走前端静态资源
    return env.ASSETS.fetch(request);
  }
};

name = "my-app"
compatibility_date = "2026-06-01"

# 绑定 Pages 前端
[assets]
directory = "./static"

# 绑定 KV 命名空间
[[kv_namespaces]]
binding = "CACHE"
id = "your-kv-namespace-id"

# 绑定 R2 存储桶
[[r2_buckets]]
binding = "FILES"
bucket_name = "my-app-files"

# 绑定 D1 数据库
[[d1_databases]]
binding = "DB"
database_name = "my-app-db"
database_id = "your-db-id"

// 缓存 API 响应
const cacheKey = `posts:${page}`;
let posts = await env.CACHE.get(cacheKey, { type: 'json' });

if (!posts) {
  // 缓存没命中，查数据库
  posts = await getPostsFromDB(page);
  // 写入缓存，TTL 1 分钟
  await env.CACHE.put(cacheKey, JSON.stringify(posts), {
    expirationTtl: 60
  });
}

// 上传文件
const formData = await request.formData();
const file = formData.get('file');
const key = `uploads/${crypto.randomUUID()}-${file.name}`;

await env.FILES.put(key, file.stream(), {
  httpMetadata: { contentType: file.type }
});

// 返回公开 URL（R2 可以自定义域名）
return new Response(JSON.stringify({
  url: `https://files.yourdomain.com/${key}`
}));

// 下载/访问文件
const object = await env.FILES.get(key);
if (!object) return new Response('Not found', { status: 404 });
return new Response(object.body, {
  headers: { 'Content-Type': object.httpMetadata.contentType }
});

// 创建用户
const { success } = await env.DB.prepare(`
  INSERT INTO users (id, email, name, created_at)
  VALUES (?, ?, ?, ?)
`)
.bind(crypto.randomUUID(), email, name, Date.now())
.run();

// 查询
const user = await env.DB.prepare(`
  SELECT * FROM users WHERE email = ?
`)
.bind(email)
.first();

// 分页查询
const { results } = await env.DB.prepare(`
  SELECT * FROM posts ORDER BY created_at DESC LIMIT ? OFFSET ?
`)
.bind(limit, offset)
.all();

-- migrations/0001_init.sql
CREATE TABLE users (
  id TEXT PRIMARY KEY,
  email TEXT UNIQUE NOT NULL,
  name TEXT,
  created_at INTEGER NOT NULL
);

CREATE INDEX idx_users_email ON users(email);

# 执行迁移
wrangler d1 execute my-app-db --file ./migrations/0001_init.sql

# 本地开发用本地数据库
wrangler dev --local

用户 → Cloudflare → Worker → 私有网络 → 你的 VPS（公网不可见）

# 安装
curl -L --output cloudflared.deb https://github.com/cloudflare/cloudflared/releases/latest/download/cloudflared-linux-amd64.deb
dpkg -i cloudflared.deb

# 认证
cloudflared tunnel login

# 创建隧道
cloudflared tunnel create my-backend

# ~/.cloudflared/config.yml
tunnel: your-tunnel-id
credentials-file: /root/.cloudflared/your-tunnel-id.json

ingress:
  # 后端 API 服务跑在本地 8080
  - hostname: api-internal.yourdomain.com
    service: http://localhost:8080
  - 其他服务...
  - service: http_status:404

// Worker 里直接通过私有域名访问，走 Cloudflare 内部网络
async function processHeavyTask(taskData) {
  // 这个请求走 Cloudflare 私有网络，不经过公网，延迟极低
  const response = await fetch('https://api-internal.yourdomain.com/process', {
    method: 'POST',
    body: JSON.stringify(taskData),
    headers: { 'Content-Type': 'application/json' }
  });
  return response.json();
}

// Producer (Worker)：发送任务到队列
async function enqueueTask(taskData) {
  await env.QUEUE.send(taskData, {
    contentType: 'json'
  });
  return { status: 'queued' };
}

// Consumer (Worker)：处理队列任务
export default {
  async queue(batch, env) {
    for (const message of batch.messages) {
      const task = message.body;
      // 调用后端处理
      await processHeavyTask(task);
      message.ack();
    }
  }
};

1. 用户上传图片
   ↓
2. Worker 接收请求，把图片原片存到 R2
   ↓
3. 发送消息到 Queue（"有新图片需要处理"）
   ↓
4. 给用户返回"上传成功"（用户不需要等处理完成）
   ↓
5. Queue Consumer 收到消息
   ↓
6. 消费者通过私有网络调用 VPS 上的图片处理服务
   ↓
7. VPS 生成缩略图、压缩、加水印，存回 R2
   ↓
8. 更新 D1 数据库，把图片状态改为"已处理"
   ↓
9. KV 缓存失效，下次访问时拿到新的缩略图

# wrangler.toml 加个定时任务保活
[triggers]
crons = ["0 * * * *"]

// Worker 里处理定时任务
async function scheduled(event, env) {
  // 简单访问一下各个服务，保持热状态
  await env.CACHE.get('health-check');
  await env.DB.prepare('SELECT 1').run();
}