用webrtc和websocket 进行推流到rtmp例子

这里提供一种使用 WebRTC 和 WebSocket 推流到 RTMP 的示例流程：

1. 在客户端使用 WebRTC 获取音视频流。

2. 将 WebRTC 获取的音视频流通过 WebSocket 传输到服务器。

3. 在服务器上使用 FFmpeg 将接收到的音视频流推送到 RTMP 服务器。

下面是示例代码：

客户端代码（使用 WebRTC 获取音视频流并通过 WebSocket 传输）：

// 获取本地音视频流
navigator.mediaDevices.getUserMedia({ audio: true, video: true })
  .then(stream => {
    // 连接 WebSocket 服务器
    const socket = new WebSocket('ws://localhost:8080');

    // 发送音视频流到 WebSocket 服务器
    const mediaRecorder = new MediaRecorder(stream);
    mediaRecorder.ondataavailable = event => {
      if (event.data && event.data.size > 0) {
        socket.send(event.data);
      }
    };
    mediaRecorder.start(1000);
  })
  .catch(error => {
    console.error(error);
  });

服务端代码（使用 Node.js 和 FFmpeg 推流到 RTMP 服务器）：

const WebSocket = require('ws');
const childProcess = require('child_process');

// 连接 WebSocket 服务器
const wss = new WebSocket.Server({ port: 8080 });
wss.on('connection', ws => {
  console.log('WebSocket connected');

  // 使用 FFmpeg 推流到 RTMP 服务器
  const ffmpeg = childProcess.spawn('ffmpeg', [
    '-f', 'webm',
    '-i', 'pipe:0',
    '-c:a', 'aac',
    '-b:a', '64k',
    '-c:v', 'libx264',
    '-b:v', '1000k',
    '-preset', 'ultrafast',
    '-f', 'flv',
    'rtmp://localhost/live/stream'
  ]);
  ffmpeg.on('close', (code, signal) => {
    console.log(`FFmpeg process closed with code ${code} and signal ${signal}`);
  });
  ffmpeg.stdout.on('data', data => {
    console.log(`FFmpeg stdout: ${data}`);
  });
  ffmpeg.stderr.on('data', data => {
    console.error(`FFmpeg stderr: ${data}`);
  });

  // 接收从 WebSocket 服务器传输过来的音视频流，并将其写入 FFmpeg 的 stdin 中
  ws.on('message', message => {
    ffmpeg.stdin.write(message);
  });
});

这是一个简单的示例，实际应用中需要考虑更多的方面，例如优化音视频编码参数、处理网络异常等。