Cloudflare Worker中将Node.js Readable Stream作为Response返回报错如何解决

问题根因 #

1. pipeTo参数类型错误 #

你引入的web-streams-polyfill提供的ReadableStream实现，和Cloudflare Worker原生的WritableStream属于不同规范实现，互相调用方法时会触发类型校验失败。同时你完全不需要额外引入TransformStream做中转，转换后的Web ReadableStream可以直接作为Response的响应体使用。

2. protocol属性读取错误 #

ytdl-core是面向Node.js环境开发的包，强依赖Node.js原生的http、https、url等核心模块，Cloudflare Worker属于Web Worker运行环境，默认不提供这些Node.js专属API，代码运行到请求逻辑时就会因为缺少依赖对象报错。

3. 无响应报错 #

前面两个错误触发了未捕获的异常，导致请求处理逻辑中断，Response一直没有正常返回，触发了Cloudflare Worker的无响应检测机制。

修复步骤 #

第一步：精简流处理逻辑，移除冗余的Polyfill #

首先删掉webpack配置里的web-streams-polyfill引入，Cloudflare Worker原生支持Web Streams API，不需要额外Polyfill。然后修改Worker的流返回逻辑：

const handleRequest = async (request) => {
  const url = new URL(request.url);
  const videoID = url.searchParams.get("v");
  if (typeof videoID === "string") {
    const nodeStream = getAudio(videoID);
    const webStream = nodeToWebStream(nodeStream);
    // 直接返回转换后的Web Stream即可
    return new Response(webStream, {
      headers: {
        "Content-Type": "audio/mpeg"
      }
    });
  }
  return new Response("Hello World");
};

第二步：补充Node.js核心模块的Polyfill #

修改webpack配置，添加ytdl-core依赖的Node.js核心模块的浏览器Polyfill：

const webpack = require("webpack");

module.exports = {
  target: "webworker",
  entry: "./index.js",
  resolve: {
    fallback: {
      "http": require.resolve("stream-http"),
      "https": require.resolve("https-browserify"),
      "stream": require.resolve("stream-browserify"),
      "util": require.resolve("util/"),
      "url": require.resolve("url/")
    }
  },
  plugins: [
    new webpack.ProvidePlugin({
      process: "process/browser",
      Buffer: ["buffer", "Buffer"],
      ytdl: "ytdl-core",
      nodeToWebStream: "readable-stream-node-to-web",
    }),
  ],
};

安装新增的依赖包：

npm install stream-http https-browserify stream-browserify util url process buffer

第三步：补充全局错误捕获 #

避免未处理的异常导致Worker无响应：

const handleRequest = async (request) => {
  try {
    const url = new URL(request.url);
    const videoID = url.searchParams.get("v");
    if (typeof videoID === "string") {
      const nodeStream = getAudio(videoID);
      const webStream = nodeToWebStream(nodeStream);
      return new Response(webStream, {
        headers: {
          "Content-Type": "audio/mpeg"
        }
      });
    }
    return new Response("Hello World");
  } catch (e) {
    return new Response(`服务异常：${e.message}`, { status: 500 });
  }
};

注意事项 #

如果完成以上修改后仍然存在兼容性问题，说明ytdl-core的内部逻辑和Worker环境适配度较低，可以考虑更换为适配Worker环境的YouTube解析库，或者直接解析YouTube原生接口获取音频地址后做代理转发。

内容的提问来源于stack exchange，提问作者A Rogue Otaku