Cloudflare代理Worker中替代clone()检查Response错误码的高效方法

你的场景核心是避免用clone()加载整个响应体到内存，同时能判断JSON响应中的errorCode，还要兼容文件/纯文本响应。可以通过Web Streams API结合Content-Type判断来实现，既高效又不破坏原响应流。

实现思路 #

1. 先根据响应的Content-Type判断是否为JSON类型，非JSON响应直接返回，跳过解析逻辑，避免无效操作。
2. 对JSON响应，用TransformStream流式读取响应体：
   • 逐步收集响应数据，尝试解析JSON（数据不完整时会抛出错误，继续等待后续chunk）
   • 一旦检测到errorCode，立即终止流并返回错误响应
   • 未检测到错误则将流原样传递，不影响原响应内容

完整代码示例 #

const response = await fetch(...);

// 先判断是否为JSON类型响应，避免对文件/文本做无用解析
const isJson = response.headers.get('Content-Type')?.includes('application/json');

if (!isJson) {
  return response;
}

// 处理JSON响应的流式解析逻辑
let collectedData = '';
const transformStream = new TransformStream({
  async transform(chunk, controller) {
    // 将当前chunk转为字符串并收集
    collectedData += new TextDecoder().decode(chunk);
    
    try {
      // 尝试解析已收集的JSON（数据不完整会抛出错误，继续等待后续chunk）
      const json = JSON.parse(collectedData);
      if (json.errorCode) {
        console.log(json.errorCode, json.message);
        // 检测到错误，终止流并抛出错误，后续会捕获并返回500响应
        controller.error('Detected error in response');
      } else {
        // 无错误，将当前chunk传递下去
        controller.enqueue(chunk);
      }
    } catch (e) {
      // JSON解析失败（数据不完整），继续收集后续chunk
      controller.enqueue(chunk);
    }
  }
});

try {
  // 将原响应的流通过TransformStream处理后返回
  return new Response(response.body.pipeThrough(transformStream), response);
} catch (e) {
  // 捕获到流终止的错误，返回自定义500响应
  return new Response('An error occurred', { status: 500 });
}

方案优势 #

• 内存高效：不需要将整个响应体加载到内存，流式处理适合大文件或大体积JSON响应
• 兼容非JSON响应：通过Content-Type判断跳过解析逻辑，不影响文件/纯文本的正常返回
• 不破坏原响应：只有检测到错误时才终止流，否则原响应流会完整传递

注意事项 #

• 如果代理服务返回的JSON是分块传输且errorCode不在开头部分，可能需要收集更多数据才能检测到错误，但这种情况在API设计中比较少见
• 如果响应声称是JSON但实际格式错误，代码会继续传递原流，避免误判

内容的提问来源于stack exchange，提问作者Ben Wong