您现在的位置是：首页>文档内容页

文档详情

初识webrtc

webRTC

doramart 2017-11-01 17:26:01 技巧226355

WebRTC，名称源自网页实时通信（Web Real-Time Communication）的缩写，是一个支持网页浏览器进行实时语音对话或视频对话的技术。

WebRTC，名称源自网页实时通信（Web Real-Time Communication）的缩写，是一个支持网页浏览器进行实时语音对话或视频对话的技术，是谷歌2010年以6820万美元收购Global IP Solutions公司而获得的一项技术。2011年5月开放了工程的源代码，在行业内得到了广泛的支持和应用，成为下一代视频通话的标准。

WebRTC 技术带来的便利是，不需要native(ios或android)支持，直接通过浏览器就可以进行视频语音通信，这在直播或者视频直连、文字通信等方面意义重大。

WebRTC 目前已经是比较成熟的技术，网上也有很多开源项目，近期研究了下手机端与pc端的点对点视频直连，实现原理如图：

实现视频直连需要以下几个要素：

1、模拟PC端

2、模拟手机端

3、建立websocket服务

4、使用coturn服务做中转（我这里模拟是在同一网段，这部分可以暂时忽略）

实现过程中，为了方便起见，我用了一个比较好的webrtc库 PeerJs（http://peerjs.com/）。PeerJS 提供了前端处理WebSocket链接的相关接口，另外提供了配套的Peerjs server，来支持服务端，基于nodejs，非常方便（https://github.com/peers/peerjs-server）

实现过程：

1、利用PeerJS server开启 websocket 服务。

var fs = require('fs');var PeerServer = require('peer').PeerServer;var server = PeerServer({
  port: 9000,
  ssl: {
    key: fs.readFileSync('/path/to/your/ssl/key/here.key'),
    cert: fs.readFileSync('/path/to/your/ssl/certificate/here.crt')
  }
});

2、集成express

var express = require('express');
var app = express();
var ExpressPeerServer = require('peer').ExpressPeerServer;

app.get('/', function(req, res, next) { res.send('Hello world!'); });

var server = app.listen(9000);

var options = {
    debug: true
}

app.use('/api', ExpressPeerServer(server, options));

// OR

var server = require('http').createServer(app);

app.use('/peerjs', ExpressPeerServer(server, options));

server.listen(9000);

需要注意的是，https的证书本地可以自己通过OpenSSL创建一下，比较简单。

3、模拟PC端(index.html)

<!doctype html>
<html lang="zh-CN">

<head>
<meta charset="UTF-8">
<meta name="viewport" content="width=device-width, user-scalable=no, initial-scale=1.0, maximum-scale=1.0, minimum-scale=1.0">
<meta http-equiv="X-UA-Compatible" content="ie=edge">
<title>Document</title>
<script src="js/peer.js"></script>
</head>

<body>
<input type="text" id="message">
<input type="button" value="发送" id="submit">
<div id="message-list"></div>
<video id="B1" autoplay></video>

<script>
navigator.getUserMedia = navigator.getUserMedia ||
navigator.webkitGetUserMedia ||
navigator.mozGetUserMedia ||
navigator.msGetUserMedia;

var video = document.querySelector("video");
var localStream,
peer = new Peer('B1', { host: '192.168.43.212', port: 4433, secure: true, path: '/api', debug: 3 });

// emitted when connected server.
peer.on('open', function (id) {
console.log('My peer ID is: ', id);
});

peer.on('connection', function (conn) {
console.info('连接来了：', conn.peer);
document.getElementById('submit').onclick = function () {
conn.send(document.getElementById('message').value || '空白信息');
};
console.info('开始创建视频流...');
navigator.getUserMedia({
video: true,
audio: false
}, function (stream) {
localStream = stream;
peer.call('B2', stream);
}, function (err) {
console.info('创建视频流失败。。。');
});

conn.on('data', function (data) {
console.info('来自%s: %s', conn.peer, data);
document.getElementById('message-list').appendChild(document.createElement('p').appendChild(document.createTextNode(data)));
conn.send(conn.peer + ', 我已经收到你的信息：' + data);
});
});

peer.on('call', function (call) {
console.info('B2发视频来了', call);

call.answer(localStream);
call.on('stream', function (stream) {
console.info('来自B2的视频流。。。');
video.src = window.URL.createObjectURL(stream);
});
});

peer.on('error', function (err) {
console.info('发生错误：', err);
});

</script>
</body>

</html>

4、模拟手机端：(video.html)

<!doctype html>
<html lang="zh-CN">

<head>
<meta charset="UTF-8">
<meta name="viewport" content="width=device-width, user-scalable=no, initial-scale=1.0, maximum-scale=1.0, minimum-scale=1.0">
<meta http-equiv="X-UA-Compatible" content="ie=edge">
<title>Document</title>
<script src="js/peer.js"></script>
</head>

<body>
<input type="text" id="message">
<input type="button" value="发送" id="submit">
<div id="message-list"></div>
<video id="remote" autoplay></video>

<script>
navigator.getUserMedia = navigator.getUserMedia ||
navigator.webkitGetUserMedia ||
navigator.mozGetUserMedia ||
navigator.msGetUserMedia;

var video = document.getElementById("remote"),
local = document.getElementById('local');
var localStream,
peer,
remoteId = 'B1';

navigator.getUserMedia({
video: true,
audio: false
}, function (stream) {
console.info('创建视频流成功。', stream);
localStream = stream;
//        local.src = window.URL.createObjectURL(stream);
peer = new Peer('B2', { host: '192.168.43.212', port: 4433, secure: true, path: '/api', debug: 3 });

peer.on('open', function (id) {
var connection = peer.connect(remoteId);
console.log('My peer ID is: ', id, connection);

connection.on('open', function () {
document.getElementById('submit').onclick = function () {
connection.send(document.getElementById('message').value || '空白信息');
};
connection.send('hello world...');
});

connection.on('data', function (message) {
console.info('来自%s的%s', remoteId, message);
document.getElementById('message-list').appendChild(document.createElement('p').appendChild(document.createTextNode(message)));
});

connection.on('err', function (err) {
console.info('来自%s的错误信息：', remoteId, err);
});

connection.on('close', function () {
console.info('与%断开连接');
});
});

peer.on('call', function (call) {
console.info('我的视频流：', localStream);
call.answer(localStream);

peer.call('B1', localStream);
call.on('stream', function (stream) {
console.info('来自B1的视频流。。。', call);
video.src = window.URL.createObjectURL(stream);
});


});

peer.on('connection', function (conn) {
console.info('连接来了：', conn);
});
peer.on('error', function (err) {
console.info(err);
});

}, function (err) {
console.info('创建视频流失败。。。', err);
});

</script>
</body>

</html>

注意：代码中的