如何在 Node 中代理媒体流？

Question

我希望能够将远程 icecast 流代理到客户端。过去几天我一直在摆弄很多东西，但无济于事。

用例：

能够从<audio> 标记src 中提取分析器数据，而不会遇到CORS 问题。

到目前为止我的解决方案

为了解决阻止我直接从<audio> 的源中创建杠杆声音数据的 CORS 问题，我尝试编写一个微型代理，它将请求通过管道传输到特定流并返回任何静态数据其他情况。 这是我的代码：

require('dotenv').config();
const http = require('http');

const express = require('express');

const app = express();

const PORT = process.env.PORT || 4000;

let target = 'http://direct.fipradio.fr/live/fip-midfi.mp3';
// figure out 'real' target if the server returns a 302 (redirect)
http.get(target, resp => {
  if(resp.statusCode == 302) {
    target = resp.headers.location;
  }
});

app.use(express.static('dist'));

app.get('/api', (req, res) => {
  http.get(target, audioFile => {
    res.set(audioFile.headers);

    audioFile.addListener('data', (chunk) => {
      res.write(chunk);
    });
    audioFile.addListener('end', () => {
      res.end();
    });
  }).on('error', err => {
    console.error(err);
  });
});

app.listen(PORT);

问题

客户端收到来自代理的响应，但这会停止到 60kb 的数据，并且没有收到后续块，尽管代理已收到：

欢迎提出任何建议！

Answer 1

我找到了解决方案，使用流管道。

const app = express();

const PORT = process.env.PORT || 4000;

let target = 'http://direct.fipradio.fr/live/fip-midfi.mp3';
// figure out 'real' target if the server returns a 302 (redirect)
http.get(target, resp => {
  if(resp.statusCode == 302) {
    target = resp.headers.location;
  }
});

app.use(express.static('dist'));

app.get('/api', (req, res) => {
  req.pipe(request.get(target)).pipe(res);
});

app.listen(PORT);