NodeJS Express服务器返回PassThrough流时出错的解决咨询

你完全不需要更换框架，Express本身就支持返回Stream对象，只是你用错了方法而已。

问题根源 #

你当前代码里用了res.write(createPassThrough())，但res.write()方法的参数只能是字符串或者Buffer实例，不能直接传入Stream对象，这就是触发报错的原因。

正确实现方案 #

Express的响应对象res本身就是一个可写流（Writable Stream），所以你只需要把PassThrough流pipe到res上，或者直接把流作为响应返回（Express会自动帮你完成pipe操作）。

下面提供两种可行的写法：

写法1：使用pipe方法手动关联流

const { PassThrough } = require('stream');
const createPassThrough = () => {
  return PassThrough();
};

app.get('/stream', (req, res) => {
  res.writeHead(200, {
    'Content-Type': 'audio/mpeg',
    'Transfer-Encoding': 'chunked'
  });
  // 将PassThrough流关联到响应对象
  createPassThrough().pipe(res);
});

写法2：直接返回流（Express自动处理）

Express支持直接把Stream对象作为响应返回，它会自动处理流的传输逻辑，如果需要自定义响应头，提前设置好即可：

const { PassThrough } = require('stream');
const createPassThrough = () => {
  return PassThrough();
};

app.get('/stream', (req, res) => {
  res.set({
    'Content-Type': 'audio/mpeg',
    'Transfer-Encoding': 'chunked'
  });
  // 直接返回PassThrough流
  return createPassThrough();
});

补充：向PassThrough流写入数据 #

如果需要动态向PassThrough流中写入内容（比如生成音频数据），可以在关联流之前或之后进行操作，记得完成后调用end()：

const stream = createPassThrough();
// 模拟写入音频数据
stream.write(Buffer.from('sample audio chunk'));
// 模拟延迟后结束流
setTimeout(() => stream.end(), 3000);
stream.pipe(res);

这样就能正常返回PassThrough流作为HTTP响应了，完全不需要切换到Hapi.js。

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