Software 2.0

Cloudflare Workers 快速指南

admin -

Cloudflare Workers彻底改变了我们在边缘构建和部署应用的方式。通过在离全球用户更近的地方运行代码，开发者可以创建闪电般快速的、可扩展的应用，而无需管理传统服务器。在这份全面的指南中，我们将探讨你可以使用Cloudflare Workers构建什么，并逐步进行实际实现。

1、什么是Cloudflare Workers？

Cloudflare Workers是在Cloudflare全球网络上运行的无服务器函数。你的代码不是在某个位置的单台服务器上运行，而是在Cloudflare全球边缘位置执行——这意味着无论用户身处何地，都能获得更快的响应时间和更好的可靠性。

2、你可以构建什么

2.1 边缘计算与性能优化

API网关与路由

Workers最强大的用例之一是构建统一的API网关。你可以将请求路由到多个后端服务，添加认证层，实现速率限制，并缓存响应——所有这些都在请求到达源服务器之前在边缘完成。

智能URL管理

创建带有内置分析的自定义URL缩短器，通过将用户路由到不同应用版本来实施A/B测试，或设置基于地理位置的重定向，自动将用户发送到特定区域的网站以获得更好的性能和本地化内容。

2.2 AI驱动的应用

Cloudflare Workers AI允许你直接在边缘运行机器学习模型。以下是一个简单的示例：

const response = await env.AI.run('@cf/meta/llama-2-7b-chat-int8', {
  prompt: "Explain edge computing in simple terms"
});

这一能力为聊天机器人、内容生成、图像识别和智能数据处理打开了大门——所有这些都无需管理AI基础设施。

2.3 自动化工作流

Workers支持复杂的多步骤自动化流程。你可以构建：

  • 解析传入邮件并触发操作的邮件处理管道
  • 在系统之间清理和迁移信息的数据转换任务
  • 运行维护操作、生成报告或同步数据的定时任务
  • 响应第三方服务Webhook的事件驱动工作流

2.4 安全与认证

在边缘实施强大的安全措施：

  • 在请求到达后端之前验证JSON Web Token（JWT）
  • 集成OAuth或单点登录（SSO）系统
  • 管理API密钥并强制执行访问控制
  • 检测和阻止恶意机器人
  • 自动为所有响应添加安全头
  • 强制执行内容安全策略（CSP）

2.5 使用Durable Objects的实时应用

Durable Objects为有状态应用提供强一致性存储。使用它们来构建：

  • 带有消息持久化的实时聊天应用
  • 多个用户同时工作的协作编辑工具
  • 具有同步状态的多人游戏后端
  • 实时通知系统
  • 基于房间的通信平台

2.6 数据集成与管理

Workers与Cloudflare的存储解决方案无缝集成：

// Query D1 (SQLite database)
const users = await env.DB.prepare("SELECT * FROM users WHERE active = ?")
  .bind(true)
  .all();
// Store in KV (Key-Value storage)
await env.KV.put('user:123', JSON.stringify(userData));
// Access R2 (Object storage)
const file = await env.BUCKET.get('documents/report.pdf');

这使你能够构建完整的数据驱动应用，而无需离开边缘。

2.7 内容转换

在内容流经Workers时动态修改：

  • 实时调整和优化图片大小
  • 根据浏览器支持转换图像格式（JPEG转WebP/AVIF）
  • 重写HTML以注入分析脚本或修改元素
  • 为页面添加自定义页眉和页脚
  • 根据用户属性个性化内容

3、逐步实现指南

步骤1：环境设置

首先，安装Wrangler CLI——Cloudflare的开发工具：

npm install -g wrangler
wrangler login

步骤2：创建你的第一个Worker

初始化一个新项目：

wrangler init my-worker
cd my-worker

这会创建一个包含配置文件的基本项目结构。

步骤3：配置你的Worker

编辑wrangler.toml来定义你的Worker设置：

name = "my-api-gateway"
main = "src/index.js"
compatibility_date = "2024-01-15"
[vars]
ENVIRONMENT = "production"

关于配置的重要提示：永远不要将API密钥或数据库密码等敏感凭据提交到版本控制中。使用Cloudflare的密钥管理：

wrangler secret put API_KEY

这会安全地存储密钥，只有你的Worker在运行时才能访问。

步骤4：编写Worker逻辑

以下是一个路由请求并添加认证的API网关示例：

export default {
  async fetch(request, env, ctx) {
    const url = new URL(request.url);
    
    // Authentication check
    const authHeader = request.headers.get('Authorization');
    if (!authHeader || !await validateToken(authHeader, env)) {
      return new Response('Unauthorized', { status: 401 });
    }
    
    // Route based on path
    if (url.pathname.startsWith('/api/users')) {
      return handleUsersAPI(request, env);
    } else if (url.pathname.startsWith('/api/products')) {
      return handleProductsAPI(request, env);
    }
    
    return new Response('Not Found', { status: 404 });
  }
};
async function validateToken(authHeader, env) {
  const token = authHeader.replace('Bearer ', '');
  // Validate against your authentication service
  // For production, integrate with your actual auth system
  return token.length > 0;
}

步骤5：实现缓存以提升性能

添加智能缓存以减少后端负载：

async function handleProductsAPI(request, env) {
  const cache = caches.default;
  const cacheKey = new Request(request.url, request);
  
  // Check cache first
  let response = await cache.match(cacheKey);
  
  if (!response) {
    // Fetch from origin if not cached
    response = await fetch('https://api.example.com/products', {
      headers: {
        'X-API-Key': env.BACKEND_API_KEY
      }
    });
    
    // Cache for 5 minutes
    const cachedResponse = new Response(response.body, response);
    cachedResponse.headers.set('Cache-Control', 'max-age=300');
    ctx.waitUntil(cache.put(cacheKey, cachedResponse.clone()));
  }
  
  return response;
}

步骤6：添加速率限制

保护你的API免受滥用：

async function checkRateLimit(clientIP, env) {
  const key = `rate_limit:${clientIP}`;
  const current = await env.KV.get(key);
  
  if (current && parseInt(current) > 100) {
    return false; // Rate limit exceeded
  }
  
  await env.KV.put(key, (parseInt(current || 0) + 1).toString(), {
    expirationTtl: 3600 // Reset after 1 hour
  });
  
  return true;
}

生产环境注意事项：按IP地址进行速率限制是防止滥用和确保公平使用资源的必要措施。但请注意，位于NAT或企业代理后面的用户可能共享IP地址。考虑对已认证的端点使用用户令牌或API密钥实施更复杂的速率限制。

步骤7：部署你的Worker

先在本地测试：

wrangler dev

准备好后，部署到生产环境：

wrangler deploy

步骤8：设置自定义路由

配置你的Worker处理哪些请求：

[[routes]]
pattern = "api.yourdomain.com/*"
zone_name = "yourdomain.com"

域名配置说明：此示例使用yourdomain.com作为占位符。请替换为你的实际域名。在生产环境中，使用自定义域名可提供更好的品牌形象，并允许你控制DNS设置以实现地理负载均衡等功能。

步骤9：监控和调试

使用Cloudflare的仪表板监控：

  • 请求量和响应时间
  • 错误率和错误类型
  • 缓存命中率
  • 资源使用情况（CPU时间、内存）

启用日志进行调试：

console.log('Request processed:', {
  url: request.url,
  method: request.method,
  timestamp: new Date().toISOString()
});

步骤10：实现定时任务

对于后台任务，添加cron触发器：

[triggers]
crons = ["0 0 * * *"] # Daily at midnight UTC
export default {
  async scheduled(event, env, ctx) {
    // Run daily cleanup, send reports, etc.
    await performDailyTasks(env);
  }
};

3、实际示例：Webhook处理系统

以下是一个处理来自多个来源的Webhook的Worker完整示例：

export default {
  async fetch(request, env, ctx) {
    if (request.method !== 'POST') {
      return new Response('Method not allowed', { status: 405 });
    }
    
    const url = new URL(request.url);
    const payload = await request.json();
    
    // Validate webhook signature
    if (!await verifySignature(request, payload, env)) {
      return new Response('Invalid signature', { status: 401 });
    }
    
    // Process based on source
    if (url.pathname === '/webhooks/payment') {
      await processPaymentWebhook(payload, env);
    } else if (url.pathname === '/webhooks/email') {
      await processEmailWebhook(payload, env);
    }
    
    return new Response('Webhook processed', { status: 200 });
  }
};
async function processPaymentWebhook(payload, env) {
  // Store transaction
  await env.DB.prepare(
    'INSERT INTO transactions (id, amount, status) VALUES (?, ?, ?)'
  ).bind(payload.id, payload.amount, payload.status).run();
  
  // Send confirmation email
  await fetch('https://api.example-email-service.com/send', {
    method: 'POST',
    headers: {
      'Authorization': `Bearer ${env.EMAIL_API_KEY}`,
      'Content-Type': 'application/json'
    },
    body: JSON.stringify({
      to: payload.customer_email,
      subject: 'Payment Confirmation',
      body: `Your payment of $${payload.amount} was successful.`
    })
  });
}

4、Cloudflare Workers的优势

全球性能：代码在全球边缘位置运行，显著降低延迟。东京和纽约的用户体验类似的响应时间。

自动扩展：Workers根据需求自动扩展。无需配置服务器或设置自动扩展组。

成本效益：免费套餐每天包含100,000个请求。付费套餐按使用量计费，无最低费用。

开发者体验：快速部署（通常在30秒以内）、即时回滚和预览测试环境。

内置安全：自动DDoS防护、TLS/SSL处理和执行上下文之间的隔离。

集成生态系统：与Cloudflare服务（如D1、KV、R2、Workers AI和Durable Objects）无缝集成。

5、缺点与局限性

执行时间限制：免费套餐的Worker每个请求有10毫秒的CPU时间限制。付费套餐将其增加到30-50毫秒。长时间运行的任务需要Workflows或Durable Objects。

内存限制：Worker限制为128MB内存，这可能不足以处理大型文件或数据集。

冷启动延迟：虽然通常很小，但当Worker最近没有运行时可能会有轻微延迟。

平台锁定：为Workers编写的代码可能需要大量修改才能在其他无服务器平台上运行，因为Cloudflare特定的API。

有限的文件系统：没有传统的文件系统访问。你必须使用KV、R2或外部存储解决方案。

调试复杂性：本地开发不能完美复制边缘环境，调试分布式系统可能具有挑战性。

网络限制：出站请求在协议和端口方面有限制。并非所有外部服务都可以访问。

6、安全考虑与注意事项

风险自负：虽然Cloudflare Workers是生产级别的，但实施安全关键功能需要仔细考虑。始终：

  • 彻底测试认证和授权逻辑
  • 使用密钥管理来处理敏感凭据，永远不要硬编码
  • 实施适当的输入验证以防止注入攻击
  • 在处理用户数据时保持谨慎并遵守隐私法规
  • 定期更新依赖项并监控安全公告
  • 实施全面的日志记录和监控
  • 在部署到生产环境之前使用测试环境

数据隐私：在边缘处理用户数据时，确保符合GDPR、CCPA和其他相关法规。了解数据驻留要求。

第三方依赖：谨慎引入外部库。Worker有大小限制，依赖项会增加攻击面。

错误处理：实施健壮的错误处理。未处理的异常可能会暴露敏感信息或使应用处于不一致状态。

7、结束语

Cloudflare Workers为构建现代分布式应用提供了一个强大的平台。无论你是创建简单的API网关、复杂的AI驱动系统，还是实时协作工具，Workers都提供了构建快速、可靠和可扩展解决方案的基础设施。

边缘计算范式将逻辑转移到更接近用户的地方，在简化基础设施管理的同时显著提高了性能。然而，这也带来了执行时间限制、调试复杂性和平台特定考虑等方面的权衡。

从URL重定向或API代理等简单用例开始，然后逐步探索Durable Objects和Workers AI等更高级的功能。全球分发、自动扩展和集成服务的组合使Workers成为现代Web开发的一个引人注目的选择。

请记住，虽然技术很强大，但成功取决于正确的架构、安全实践和对平台限制的理解。充分测试、主动监控，并根据真实使用模式进行迭代。

边缘是计算的未来，Cloudflare Workers为这一范式提供了一个易于上手的入口。无论你是构建第一个API的初创公司，还是正在使遗留系统现代化的企业，Workers都提供了帮助你成功的工具和能力。

原文链接: Building Powerful Applications with Cloudflare Workers: A Complete Guide

汇智网翻译整理，转载请标明出处