大规模音视频直播 双12促销活动

const { RTCPeerConnection, RTCSessionDescription } = require('wrtc');
const express = require('express');
const app = express();

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

const peerConnection = new RTCPeerConnection({
  iceServers: [{ urls: 'stun:stun.l.google.com:19302' }]
});

peerConnection.onicecandidate = event => {
  if (event.candidate) {
    // Send the candidate to the signaling server
  }
};

peerConnection.ontrack = event => {
  const remoteVideo = document.getElementById('remoteVideo');
  remoteVideo.srcObject = event.streams[0];
};

app.get('/offer', async (req, res) => {
  const offer = new RTCSessionDescription(req.body);
  await peerConnection.setRemoteDescription(offer);

  const answer = await peerConnection.createAnswer();
  await peerConnection.setLocalDescription(answer);

  res.json(peerConnection.localDescription);
});

app.listen(3000, () => {
  console.log('Server is running on port 3000');
});