如何用Node.js实现多音频后台自动播放流式广播（电台场景）

嘿，这个需求太贴合电台场景了！我之前做过类似的项目，给你梳理下Node.js实现的核心思路和好用的工具，帮你快速落地～

首先得明确整个流程：后台自动按顺序播放多音频，把音频转换成适合实时传输的流，再通过WebSocket广播给所有连接的用户。下面分模块细说：

1. 音频处理：选对模块省大事 #

后台要处理音频的格式转换、流式输出，推荐这几个实用模块：

• fluent-ffmpeg：全能型音频处理工具，能把MP3、WAV等格式转成Opus（最适合实时传输的音频格式，体积小延迟低），还能拼接音频、调整码率。
• ws：Node.js生态里最流行的WebSocket库，搭建广播服务器超方便。
• 要是需要更轻量的音频流处理，audio-stream也可以试试，不过fluent-ffmpeg的灵活性更高。

举个快速生成Opus流的例子：

const ffmpeg = require('fluent-ffmpeg');

function getAudioStream(filePath) {
  return ffmpeg(filePath)
    .audioCodec('libopus')
    .format('opus')
    .on('error', err => console.log('音频处理出错:', err))
    .pipe();
}

2. WebSocket广播：维护客户端列表 #

用ws搭建服务器，要维护所有在线的客户端连接，然后把音频流的每一块数据广播给所有人。注意音频是二进制数据，发送时要指定binary: true。

示例代码：

const WebSocket = require('ws');
const wss = new WebSocket.Server({ port: 8080 });

// 存储所有活跃的客户端连接
const connectedClients = new Set();

wss.on('connection', ws => {
  console.log('新用户加入电台');
  connectedClients.add(ws);

  // 处理客户端断开
  ws.on('close', () => {
    console.log('用户离开电台');
    connectedClients.delete(ws);
  });

  // 处理错误
  ws.on('error', err => {
    console.error('WebSocket连接出错:', err);
    connectedClients.delete(ws);
  });
});

// 广播音频块的工具函数
function broadcastAudio(chunk) {
  connectedClients.forEach(client => {
    if (client.readyState === WebSocket.OPEN) {
      client.send(chunk, { binary: true });
    }
  });
}

3. 多音频自动播放：循环/顺序切换 #

要实现后台自动播放下一首，监听当前音频流的end事件，或者用stream.pipeline来处理流结束后的逻辑，自动切换到下一个音频文件。

示例：

const { pipeline } = require('stream/promises');
const audioPlaylist = ['song1.mp3', 'song2.mp3', 'song3.mp3']; // 你的音频列表
let currentTrackIndex = 0;

async function playNextTrack() {
  // 循环播放
  if (currentTrackIndex >= audioPlaylist.length) {
    currentTrackIndex = 0;
  }
  const currentTrack = audioPlaylist[currentTrackIndex];
  currentTrackIndex++;

  try {
    const audioStream = getAudioStream(currentTrack);
    // 每收到一块音频数据就广播
    audioStream.on('data', chunk => broadcastAudio(chunk));
    // 等待当前音频流处理完成
    await pipeline(audioStream, require('fs').createWriteStream('/dev/null'));
    // 播放下一首
    await playNextTrack();
  } catch (err) {
    console.error(`播放${currentTrack}出错:`, err);
    // 出错了也继续下一首
    await playNextTrack();
  }
}

// 启动电台
playNextTrack();

4. 客户端收听：用Web Audio API处理流 #

客户端要接收WebSocket传来的二进制音频数据，用MediaSource API来拼接流式数据，然后用HTML5的Audio元素播放。

前端示例代码：

const ws = new WebSocket('ws://localhost:8080');
const mediaSource = new MediaSource();
const audioPlayer = new Audio();

audioPlayer.src = URL.createObjectURL(mediaSource);
let sourceBuffer;

// 媒体源就绪后创建缓冲区
mediaSource.addEventListener('sourceopen', () => {
  sourceBuffer = mediaSource.addSourceBuffer('audio/opus; codecs=opus');
});

ws.binaryType = 'arraybuffer';
ws.onmessage = event => {
  // 缓冲区没在更新的时候再添加新数据
  if (!sourceBuffer.updating) {
    sourceBuffer.appendBuffer(event.data);
  }
};

// 自动播放（注意浏览器的自动播放策略）
audioPlayer.play().catch(err => console.error('播放失败:', err));

• 音频格式选Opus：比MP3体积小一半以上，延迟更低，完美适配实时广播场景。
• 客户端同步：因为是广播，所有用户收到的音频块是一样的，只要WebSocket连接稳定，同步性基本没问题，不用额外做时间戳对齐。
• 错误处理：要处理音频文件不存在、WebSocket断开、流出错等情况，保证电台能持续运行。
• 性能优化：如果用户量很大，可以用Node.js集群模式扩展WebSocket服务器，或者用Redis来做跨进程的广播。

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