没有时间线,它是异步的,但我会尝试解释,但有两个主要流程,SDP 的提议和回答流程以及 icecandidate 的流程。
流程1:SDP
第 1 步 - 提供同行:
在报价方面,创建一个 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(将开始收集 ICE 候选者)的 localDescription。然后使用信令服务器将报价发送给其他对等方。(我不会描述信令服务器,它只是将数据从另一个传递到另一个)。
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,STUN server,然后getUserMedia创建一个RTCPeerconnection,然后在回调中,将stream添加到RTCPeerConnection。对于 SDP 报价,将 setRemoteDescription 与 sdpOffer 一起使用。然后触发 createAnswer。在 createAnswer 的成功回调中,将 setLocalDescription 与参数一起使用,然后使用信令服务器将 answer sdp 发送到提供对等方。
//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 触发 onicecandidate 时,通过信号服务器将候选者发送到另一个对等点。当收到来自信令服务器的 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 候选者将彼此配对并找到对等的最佳方式时,他们将添加与 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);
});
});