RTCPeerConnection api是每个浏览器之间点对点连接的核心,RTCPeerConnection是WebRTC组件,用于处理对等体之间流数据的稳定和有效通信。
RTCPeerConnection可以保护Web开发人员免受潜伏在其中的无数复杂性的影响。WebRTC使用的编解码器和协议可以进行大量工作,即使在不可靠的网络上也可以进行实时通信:
// 创建实例
let pc = RTCPeerConnection(serverConfig);
根据你是发起者还是被发起对象,在连接的每一边会使用稍微不同的方式使用RtcPeerConnection对象。
serverConfigconfig配置参数中包含iceServers参数。它是包含有关STUN和TURN服务器的信息的URL对象数组,在查找ICE候选时使用。可以在code.google.com找到可用的公共STUN服务器的列表。
现实中,无论你的应用如何见到那,webRTC都需要服务器,因为:
换句话说,WebRTC需要四种类型的服务器端功能:
ICE是用于连接对等体的框架,例如两个视频聊天客户端。最初,ICE尝试通过UDP 直接连接对等端,以尽可能低的延迟。在此过程中,STUN服务器只有一个任务:使NAT后面的对等体能够找到其公共地址和端口。
下面是调用流程:
1.获取本地媒体设备成功之后,创建一个新的RTCPeerConnection对象,初始化将本地音视频轨道加入到RTCPeerConnection
function createConn(stream) {
localStream = stream
// 显示本地视频流
localVideo.srcObject = stream;
//谷歌公共stun服务器
let serverConfig = {
"iceServers": [
{ "urls": ["turn:192.168.1.133:3478"],
"username": "webrtc",
"credential": "webrtc"
}
]
};
// 呼叫者
let localPeer = new RTCPeerConnection(serverConfig)
// 被呼叫者
let remotePeer = new RTCPeerConnection(serverConfig)
// 设置媒体流监听,将本地流添加到RTCPeerConnection对象
localStream.getTracks().forEach((track) => {
localPeer.addTrack(track, localStream);
});
localPeer.addStream(stream)
}
2.注册onicecandidate处理程序,并监听获取自己的ICE协商信息,它将任何ICE候选发送给其他对等方
function createConn(stream) {
...
// 当获得到自己的公网地址后,发送给其它客户端
localPeer.onicecandidate = function(event) {
console.log('I got my icecandidate info')
if (event.candidate) {
console.log(event.candidate.candidate)
}
socket.emit('onicecandidate', event.candidate);
}
// 如果监测到本地媒体流连接到本地,将其绑定到一个video标签上输出
localPeer.ontrack = function(e) {
// 因为媒体流是一个数组
if (remoteVideo.srcObject !== e.streams[0]) {
remoteVideo.srcObject = e.streams[0];
console.log('received remote stream');
}
};
}
3.提前注册消息处理程序。信令服务器还应该有一个处理来自远程计算机的消息处理程序。如果消息包含RTCSessionDescription对象,则应该使用RTCSessionDescription()方法将其添加到RTCPeerConnection对象。如果消息包含RTCIceCandidate对象,则应该使用addIceCandidate()方法将其添加到RTCPeerConnection对象。
消息处理程序会根据谁是呼叫方和被呼叫方被调用。
//呼叫方收到对方回复的SDP时调用的消息处理程序
localPeer.setRemoteDescription(new RTCSessionDescription(answer));
//被呼叫方收到对方发送的SOP时调用的消息处理程序
localPeer.addIceCandidate(new RTCIceCandidate(candidate));
4.拨通对方,发送自己的SDP信息,开始提供/回答协商过程,这是呼叫者的流量不同于被呼叫者的唯一步骤。呼叫者使用createoffer( )方法开始协商,并注册一个收到RTCSessiondescription对象的回调。然后这个回调应该使用setlocaldescription( )将这个rtcsessiondescription对象添加到rtcpeerconnection对象中。最后,调用者应该使用信令服务器将这个rtcsessiondescription发送到远程计算机。另一方面,被呼叫者,在createanswer()方法中注册相同的回调。请注意,只有在从调用者收到通知后,才会启动流。
//当本地开始拨打对方的时候,发送自己的SDP信息
const offerOptions = {
offerToReceiveAudio: 1,
offerToReceiveVideo: 1
};
function call() {
console.log('Starting call');
try {
console.log('localPeerConnection createOffer start');
const offer = await pc1.createOffer(offerOptions);
console.log(offer);
localPeer.setLocalDescription(offer)
socket.emit('offer', offer);
} catch (e) {
console.log(`Failed to create session description: ${e.toString()}`);
}
}
// 当本地收到对方的拨号通知时 收到对方的SDP信息,然后生成回复SDP信息
function handleOffer(offer, name) {
connectedUser = name;
console.log("I got offer: ");
localPeer.setRemoteDescription(new RTCSessionDescription(offer));
//create an answer to an offer
localPeer.createAnswer(function(answer) {
localPeer.setLocalDescription(answer);
console.log("I will reply a answer")
send({
type: "answer",
answer: answer
});
}, function(error) {
alert("Error when creating an answer");
});
};
// 当拨号方收到对方回复的SDP后,设置到连接中,调用消息处理程序
socket.on('answer', (desc) => {
console.log("I got answer: ", desc.sdp);
localPeerConnection.setRemoteDescription(desc);
})
在前面的章节中,已经对WebRTC相关的重要知识点进行了介绍,包括涉及的网络协议、会话描述协议、如何进行网络穿透等,剩下的就是WebRTC的API了。WebRTC通信相关的API非常多,主要完成了如下功能:
WebRTC API包括媒体捕获、音频视频的编码和解码、传输层和会话管理。getUserMedia():捕获音频和视频。MediaRecorder:录制音频和视频。RTCPeerConnection:在用户之间传输音频和视频。RTCDataChannel:用户之间的流数据。
目的 帮助自己了解webrtc 实现端对端通信,WebRTC(Web Real-Time Communication) 网页即时通信 ,是一个支持网页浏览器进行实时语音、视频对话的API。
这是 MDN 上对 WebRTC 的描述,初次接触时无法理解 WebRTC 为什么要和 WebSocket 搭配,明明说的很清楚 不借助中间媒介 ,那 WebSocket 充当的是什么角色?整个 WebRTC 通话建立的流程又是怎样的?
本文介绍如何基于WebRTC快速实现一个简单的实时音视频通话。在开始之前,您可以先了解一些实时音视频推拉流相关的基础概念:流:一组按指定编码格式封装的音视频数据内容。
内容以共享、参考、研究为目的,不存在任何商业目的。其版权属原作者所有,如有侵权或违规,请与小编联系!情况属实本人将予以删除!