去年TSINGSEE青犀视频研发团队基于WEBRTC架构开了网页音视频通话平台EasyRTC,EasyRTC支持微信小程序、H5页面、APP、PC客户端等接入方式之间互通,快速从零开始搭建实时音视频通信;支持多人至百万人视频通话,满足语音视频社交。
如果大家对EasyRTC感兴趣,可以联系我们进行了解或试用。今年我们仍然没有停止对WEBRTC技术的探索。本文和大家分享一下通过webrtc实现局域网进行音视频连接的步骤。
1、首先要创建服务代码,来确保服务器启动
const Koa = require('koa');
const path = require('path');
const koaSend = require('koa-send');
const static = require('koa-static');
const socket = require('koa-socket');
const users = {}; // 保存用户
const sockS = {}; // 保存客户端对应的socket
const io = new socket({
ioOptions: {
pingTimeout: 10000,
pingInterval: 5000,
}
});
const https = require("https");
const fs = require("fs");
// 创建一个Koa对象表示web app本身:
const app = new Koa();
// socket注入应用
io.attach(app);
app.use(static(
path.join( __dirname, './public')
));
// 对于任何请求,app将调用该异步函数处理请求:
app.use(async (ctx, next) => {
if (!/./.test(ctx.request.url)) {
await koaSend(
ctx,
'index.html',
{
root: path.join(__dirname, './'),
maxage: 1000 * 60 * 60 * 24 * 7,
gzip: true,
} // eslint-disable-line
);
} else {
await next();
}
});
// io.on('join', ctx=>{ // event data socket.id
// });
app._io.on('connection', sock => {
sock.on('join', data=>{
console.log("join:", data);
sock.join(data.roomid, () => {
if (!users[data.roomid]) {
users[data.roomid] = [];
}
let obj = {
account: data.account,
id: sock.id
};
let arr = users[data.roomid].filter(v => v.account === data.account);
if (!arr.length) {
users[data.roomid].push(obj);
}
sockS[data.account] = sock;
app._io.in(data.roomid).emit('joined', users[data.roomid], data.account, sock.id); // 发给房间内所有人
// sock.to(data.roomid).emit('joined',data.account);
});
});
sock.on('offer', data=>{
console.log('offer', data);
sock.to(data.roomid).emit('offer',data);
});
sock.on('answer', data=>{
console.log('answer', data);
sock.to(data.roomid).emit('answer',data);
});
sock.on('__ice_candidate', data=>{
console.log('__ice_candidate', data);
sock.to(data.roomid).emit('__ice_candidate',data);
});
// 1 v 1
sock.on('apply', data=>{ // 转发申请
// console.log("apply:", data);
sockS[data.account].emit('apply', data);
});
sock.on('reply', data=>{ // 转发回复
console.log("reply:", data);
sockS[data.account].emit('reply', data);
});
sock.on('1v1answer', data=>{ // 转发 answer
sockS[data.account].emit('1v1answer', data);
});
sock.on('1v1ICE', data=>{ // 转发 ICE
sockS[data.account].emit('1v1ICE', data);
});
sock.on('1v1offer', data=>{ // 转发 Offer
sockS[data.account].emit('1v1offer', data);
});
sock.on('1v1hangup', data=>{ // 转发 hangup
sockS[data.account].emit('1v1hangup', data);
});
});
app._io.on('disconnect', (sock) => {
for (let k in users) {
users[k] = users[k].filter(v => v.id !== sock.id);
}
console.log(`disconnect id => ${users}`);
});
// 在端口3001监听:
let port = 3001;
app.listen(port, _ => {
console.log('app started at port ...' + port);
});
2、在进行音视频通信是,必修要本地端口或者https服务。
(1)网上下载OpenSSL软件
(2)创建后缀名(.Key和.cert)证书;
查看网址教程:https://www.cnblogs.com/tugenhua0707/p/10927722.html
(3)在js服务把证书添加进去
const options = {
key: fs.readFileSync("./server.key", "utf8"),
cert: fs.readFileSync("./server.cert", "utf8")
};
let server = https.createServer(options, app.callback()).listen(3002);
app._io.listen(server);
3、客户端代码采用VUE,如下(重要部分代码):
在线用户:{{userList.length}}
{{v.account}}
{{v.account === account ? 'me' : ''}}
{{v.account === isCall ? 'calling' : ''}}
呼叫 {{v.account}}
{{account}}
{{isCall}}
说明
首先必须启动服务端建立连接,在通过呼叫对方id进行识别;建立PeerConnection视频连接,并把SDP的ICE候选者传递candidate给远程对等体
页面更新:2024-02-08
本站资料均由网友自行发布提供,仅用于学习交流。如有版权问题,请与我联系,QQ:4156828
© CopyRight 2020-2024 All Rights Reserved. Powered By 71396.com 闽ICP备11008920号-4
闽公网安备35020302034903号