用于拨打电话的 WebRTC 函数调用流程 [Android]

Question

我指的是并浏览了 AppRTCDemo 的源代码，它是 WebRTC 的演示应用程序。

我正在尝试的是：

1. 构建我自己的 WebRTC 应用程序，它将在 Android 设备上进行 AV 调用。
2. 替换现有https://apprtc.appspot.com/服务器和相关功能。

为了存档以上几点，我想了解 WebRTC 函数调用的基本流程和发出/接收调用的步骤（我需要调用并在那里流动的函数）。

我已经浏览了源代码并理解了一些东西，但是因为代码很难理解，而且没有任何文档。

如果有人提供任何示例或文档来解释拨打/接收 AV 呼叫的步骤（我们如何获取/设置 SDP，如何呈现本地/远程视频等），这将是非常有帮助的。

我看过这些帖子，非常有帮助：

1. WebRTC java服务器问题
2. https://www.webrtc-experiment.com/docs/WebRTC-PeerConnection.html

我能够构建和运行 AppRTCDemo 应用程序。

对此的任何帮助都会有很大帮助！

Answer 1

没有时间表，它是异步的，但我会尝试解释，但有两个主要流程，SDP 的提供和回答流程以及icecandidate 流程。

流程 1：SDP

第 1 步 - 提供同行：

在 offer 端，创建一个 RTCPeerconnection（以 stun、trun 服务器作为参数）。

    var STUN = {
        url:'stun:stun.l.google.com:19302'
    };

    var TURN = {
        url: 'turn:homeo@turn.bistri.com:80',
        credential: 'homeo'
    };

    var iceServers = {
        iceServers: [STUN, TURN]
    };

    var peer = new RTCPeerConnection(iceServers);

第 2 步 - 提供同行：

使用您的约束调用 getUserMedia。在成功回调中，使用 addStream 方法将流添加到 RTCPeerconnection。然后您可以通过对 Peerconnection 对象调用 createOffer 来创建报价。

    navigator.webkitGetUserMedia(
    {
      audio: false,
      video: {
        mandatory: {
          maxWidth: screen.width,
          maxHeight: screen.height,
          minFrameRate: 1,
          maxFrameRate: 25
        }
      }
    },
    gotStream, function(e){console.log("getUserMedia error: ", e);});

    function gotStream(stream){
      //If you want too see your own camera
      vid.src = webkitURL.createObjectURL(stream);

      peer.addStream(stream);

      peer.createOffer(onSdpSuccess, onSdpError);
    }

第 3 步 - 提供同行：

在createOffer的回调方法中，将参数（sdp offer）设置为RTCPeerConnection的localDescription（谁将开始收集ICE候选）。然后使用信令服务器将报价发送给另一个对等方。（我不会描述信令服务器，它只是将数据从另一个传递给另一个）。

    function onSdpSuccess(sdp) {
        console.log(sdp);
        peer.setLocalDescription(sdp);
        //I use socket.io for my signaling server
        socket.emit('offer',sdp);
    }

第 5 步 - 回答对等：

answer peer，每次收到offer，用TURN创建RTCPeerconnection，STUN服务器，然后getUserMedia，然后在回调中，把流加入RTCPeerConnection。对于 SDP 报价，将 setRemoteDescription 与 sdpOffer 一起使用。然后触发createAnswer。在 createAnswer 的成功回调中，使用带有参数的 setLocalDescription，然后使用信令服务器将应答 sdp 发送到 offer peer。

    //Receive by a socket.io socket
    //The callbacks are useless unless for tracking
    socket.on('offer', function (sdp) {
        peer.setRemoteDescription(new RTCSessionDescription(sdp), onSdpSuccess, onSdpError);

        peer.createAnswer(function (sdp) {
            peer.setLocalDescription(sdp);
            socket.emit('answer',sdp);
        }, onSdpError);

    }); 

第 7 步：提供同行

在 RTCPeerConnection 上接收 sdp 答案，setRemoteDescription。

    socket.on('answer', function (sdp) {
      peer.setRemoteDescription(new RTCSessionDescription(sdp), function(){console.log("Remote Description Success")}, function(){console.log("Remote Description Error")});
    }); 

流程 2 : ICECandidate

双方：

每次 RTCPeerConnection 触发一个候选者，通过信令服务器将候选者发送到另一个对等点。当收到来自信令服务器的 icecandidate 时，只需使用 addIceCandidate(New RTCIceCandidate(obj)) 将其添加到 RTCPeerConnection

    peer.onicecandidate = function (event) {
      console.log("New Candidate");
      console.log(event.candidate);

      socket.emit('candidate',event.candidate);
    };

    socket.on('candidate', function (candidate) {
      console.log("New Remote Candidate");
      console.log(candidate);

      peer.addIceCandidate(new RTCIceCandidate({
          sdpMLineIndex: candidate.sdpMLineIndex,
          candidate: candidate.candidate
      }));
    }); 

最后 ：

如果上面的两个流程运行良好，请在每个 RTCPeerConnection 上使用 onaddstream 事件。当 ICE Candidates 将彼此配对并找到对等的最佳方式时，他们将添加与 SDP 协商的流，该流将通过对等连接。因此，在这种情况下，您需要将流添加到例如视频标签中，这很好。

    peer.onaddstream = function (event) {
      vid.src = webkitURL.createObjectURL(event.stream);
      console.log("New Stream");
      console.log(event.stream);
    };

我将在明天编辑一些我认为有助于理解我在说什么的代码。如果有问题去吧。

这是我的信令服务器：

var app = require('express')();
var server = require('http').Server(app);
var io = require('socket.io')(server);

server.listen(3000);

app.get('/', function (req, res) {
  res.send('The cake is a lie');
});

io.on('connection', function (socket) {

  console.log('NEW CONNECTION');

  socket.on('offer', function (data) {
    console.log(data);
    socket.broadcast.emit("offer",data);
  });

  socket.on('answer', function (data) {
    console.log(data);
    socket.broadcast.emit("answer",data);
  });

  socket.on('candidate', function (data) {
    console.log(data);
    socket.broadcast.emit("candidate",data);
  });

});