12.12超低延迟直播 选购

const peerConnection = new RTCPeerConnection();

// 添加视频流
navigator.mediaDevices.getUserMedia({ video: true, audio: true })
  .then(stream => {
    stream.getTracks().forEach(track => peerConnection.addTrack(track, stream));
  });

// 设置ICE候选者
peerConnection.onicecandidate = event => {
  if (event.candidate) {
    // 发送ICE候选者到服务器
  }
};

// 接收远程流
peerConnection.ontrack = event => {
  const remoteVideo = document.getElementById('remoteVideo');
  remoteVideo.srcObject = event.streams[0];
};

// 创建Offer并发送
peerConnection.createOffer()
  .then(offer => peerConnection.setLocalDescription(offer))
  .then(() => {
    // 发送Offer到服务器
  });

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

const peerConnection = new RTCPeerConnection();

peerConnection.onicecandidate = event => {
  if (event.candidate) {
    // 将ICE候选者发送给前端
  }
};

// 接收Offer并创建Answer
app.post('/offer', async (req, res) => {
  const offer = new RTCSessionDescription(req.body.offer);
  await peerConnection.setRemoteDescription(offer);

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

  res.json({ answer: peerConnection.localDescription });
});