WebRTC с подключением 3 пользователей

Question

Я использую исходный код от WebRTC Samples, чтобы подключиться к 3 пользователям с помощью топологии сетки.

Однако мой код не работает, поскольку я думал, что это будет так. Я думаю, что я застрял при вызове функции iceCallBack# (# относится к числу 1, 2, 3), потому что результат вывода совпадает с исходным. Он может подключать только двух пользователей.

Я не знаю, как это исправить.

Вот некоторые из моего кода JavaScript, что я работаю на:

var audio2 = document.querySelector('audio#audio2'); 
 
    var audio3 = document.querySelector('audio#audio3'); 
 
    var pc1; 
 
    var pc2; 
 
    var pc3; 
 

 
    function call() { 
 
     callButton.disabled = true; 
 
     codecSelector.disabled = true; 
 
     trace('Starting call'); 
 
     var servers = null; 
 
     var pcConstraints = { 
 
     'optional': [] 
 
     }; 
 
     pc1 = new RTCPeerConnection(servers, pcConstraints); 
 
     trace('Created local peer connection object pc1'); 
 
     pc1.onicecandidate = iceCallback1; 
 

 
     pc2 = new RTCPeerConnection(servers, pcConstraints); 
 
     trace('Created remote peer connection object pc2'); 
 
     pc2.onicecandidate = iceCallback2; 
 
     pc2.onaddstream = gotRemoteStream; 
 
     trace('Requesting local stream'); 
 

 
     pc3 = new RTCPeerConnection(servers, pcConstraints); 
 
     trace('Created remote peer connection object pc2'); 
 
     pc3.onicecandidate = iceCallback3; 
 
     pc3.onaddstream = gotRemoteStream2; 
 
     trace('Requesting local stream'); 
 

 
     navigator.mediaDevices.getUserMedia({ 
 
     audio: true, 
 
     video: false 
 
     }) 
 
     .then(gotStream) 
 
     .catch(function(e) { 
 
     alert('getUserMedia() error: ' + e.name); 
 
     }); 
 
    } 
 

 

 
    //Description of pc1 creating offer to pc2 
 
    function gotDescription1(desc) { 
 
     desc.sdp = forceChosenAudioCodec(desc.sdp); 
 
     trace('Offer from pc1 \n' + desc.sdp); 
 
     pc1.setLocalDescription(desc, function() { 
 
     pc2.setRemoteDescription(desc, function() { 
 
      pc2.createAnswer(gotDescription2, onCreateSessionDescriptionError); 
 
     }, onSetSessionDescriptionError); 
 
     }, onSetSessionDescriptionError); 
 
    } 
 

 
    //Description of pc1 creating offer to pc3 
 
    function gotDescription3(desc) { 
 
     desc.sdp = forceChosenAudioCodec(desc.sdp); 
 
     trace('Offer from pc1 \n' + desc.sdp); 
 
     pc1.setLocalDescription(desc, function() { 
 
     pc3.setRemoteDescription(desc, function() { 
 
      pc3.createAnswer(gotDescription4, onCreateSessionDescriptionError); //Must edit gotDescription4 
 
     }, onSetSessionDescriptionError); 
 
     }, onSetSessionDescriptionError); 
 
    } 
 

 
    //Creating answer from pc2 
 
    function gotDescription2(desc) { 
 
     desc.sdp = forceChosenAudioCodec(desc.sdp); 
 
     pc2.setLocalDescription(desc, function() { 
 
     trace('Answer from pc2 \n' + desc.sdp); 
 
     pc1.setRemoteDescription(desc, function() { 
 
     }, onSetSessionDescriptionError); 
 
     }, onSetSessionDescriptionError); 
 
    } 
 

 
    //Creating answer from pc3 
 
    function gotDescription4(desc) { 
 
     desc.sdp = forceChosenAudioCodec(desc.sdp); 
 
     pc3.setLocalDescription(desc, function() { 
 
     trace('Answer from pc2 \n' + desc.sdp); 
 
     pc1.setRemoteDescription(desc, function() { 
 
     }, onSetSessionDescriptionError); 
 
     }, onSetSessionDescriptionError); 
 
    } 
 

 
    function iceCallback1(event) { 
 
     if (event.candidate) { 
 
     pc2.addIceCandidate(new RTCIceCandidate(event.candidate), 
 
      onAddIceCandidateSuccess, onAddIceCandidateError); 
 
     pc3.addIceCandidate(new RTCIceCandidate(event.candidate), 
 
      onAddIceCandidateSuccess, onAddIceCandidateError); 
 
     trace('Local ICE candidate: \n' + event.candidate.candidate); 
 
     } 
 
    } 
 

 
    function iceCallback2(event) { 
 
     if (event.candidate) { 
 
     pc1.addIceCandidate(new RTCIceCandidate(event.candidate), 
 
      onAddIceCandidateSuccess, onAddIceCandidateError); 
 
     pc3.addIceCandidate(new RTCIceCandidate(event.candidate), 
 
      onAddIceCandidateSuccess, onAddIceCandidateError); 
 
     trace('Remote ICE candidate: \n ' + event.candidate.candidate); 
 
     } 
 
    } 
 

 
    function iceCallback3(event) { 
 
     if (event.candidate) { 
 
     pc1.addIceCandidate(new RTCIceCandidate(event.candidate), 
 
      onAddIceCandidateSuccess, onAddIceCandidateError); 
 
     pc2.addIceCandidate(new RTCIceCandidate(event.candidate), 
 
      onAddIceCandidateSuccess, onAddIceCandidateError); 
 
     trace('Remote ICE candidate: \n ' + event.candidate.candidate); 
 
     } 
 
    }

<div id="audio"> 
 
     <div> 
 
     <div class="label">Local audio:</div><audio id="audio1" autoplay controls muted></audio> 
 
     </div> 
 
     <div> 
 
     <div class="label">Remote audio2:</div><audio id="audio2" autoplay controls></audio> 
 
     </div> 
 
     <div> 
 
     <div class="label">Remote audio3:</div><audio id="audio3" autoplay controls></audio> 
 
     </div> 
 
</div>

Примечание: Я новичок с WebRTC. Я мог бы быть каким-то глупым, пожалуйста, простите меня.

Большое вам спасибо.

Answer 1

Сетка из 3 пользователей означает, что каждый пользователь устанавливает два соединения, по одному для каждого из двух других пользователей. В конце каждого клиента это два совершенно разных RTCPeerConnections, и вы не можете повторно использовать кандидатов между ними, так как каждый кандидат содержит номера портов, выделенные специально для носителя, и цель, к которой он должен быть отправлен.

Если вы знаете, как настроить одно соединение, вы знаете, как настроить два. Просто держите вещи раздельными.