p2p流媒体 js

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

// 监听ICE候选事件
peerConnection.onicecandidate = event => {
  if (event.candidate) {
    // 发送候选到远程对等体
  }
};

// 监听数据通道事件
peerConnection.ondatachannel = event => {
  const receiveChannel = event.channel;
  receiveChannel.onmessage = event => {
    console.log('Received message:', event.data);
  };
};

// 创建数据通道
const sendChannel = peerConnection.createDataChannel('sendDataChannel');
sendChannel.onopen = () => {
  sendChannel.send('Hello from P2P!');
};

// 创建Offer
peerConnection.createOffer().then(offer => {
  return peerConnection.setLocalDescription(offer);
}).then(() => {
  // 发送Offer到远程对等体
}).catch(e => console.error('Error creating offer:', e));

// 处理远程描述
peerConnection.setRemoteDescription(new RTCSessionDescription(remoteOffer)).then(() => {
  return peerConnection.createAnswer();
}).then(answer => {
  return peerConnection.setLocalDescription(answer);
}).then(() => {
  // 发送Answer到远程对等体
}).catch(e => console.error('Error setting remote description:', e));