websocket 局域网 webrtc 一对一 多对多 视频通话 的示例

基本介绍

WebRTC(Web Real-Time Communications)是一项实时通讯技术,它允许网络应用或者站点,在不借助中间媒介的情况下,建立浏览器之间点对点(Peer-to-Peer)的连接,实现视频流和(或)音频流或者其他任意数据的传输。WebRTC 包含的这些标准使用户在无需安装任何插件或者第三方的软件的情况下,创建点对点(Peer-to-Peer)的数据分享和电话会议成为可能。
请浏览 MDN文档 WebRTC API 中文指南 了解WebRTC

使用websocket实现 WebRTC 建立连接时的信令服务,即交换传递 SDP和ICE两种数据,SDP分为Offer和Answer两类数据。
实现了一对一视频通话、共享桌面、多对多 监控页面、挂断后保存视频到本地 等功能。

效果:

在这里插入图片描述

局域网测试 一对一 视频 40-80ms延迟:
在这里插入图片描述

多对多 监控页
在这里插入图片描述

异常问题

1.http协议下安全性原因导致无法调用摄像头和麦克风
chrome://flags/ 配置安全策略 或者 配置本地的https环境
在这里插入图片描述
2. 开启了防火墙,webRTC连接失败,
windows防火墙-高级设置-入站规则-新建规则-端口 ,udp
UDP: 32355-65535 放行
方便测试 直接关闭防火墙也行
3. 录制webm视频 没有时间轴,使用fix-webm-duration js解决。

demo代码如下

一对一 通话页面

<!DOCTYPE>
<html><head><meta charset="UTF-8"><title>WebRTC + WebSocket</title><meta name="viewport" content="width=device-width,initial-scale=1.0,user-scalable=no"><style>html,body {margin: 0;padding: 0;}#main {position: absolute;width: 100%;height: 100%;}#localVideo {position: absolute;background: #757474;top: 10px;right: 10px;width: 200px;/* height: 150px; */z-index: 2;}#remoteVideo {position: absolute;top: 0px;left: 0px;width: 100%;height: 100%;background: #222;}#buttons {z-index: 3;bottom: 20px;left: 20px;position: absolute;}input {border: 1px solid #ccc;padding: 7px 0px;border-radius: 5px;padding-left: 5px;margin-bottom: 5px;}input :focus {border-color: #66afe9;outline: 0;-webkit-box-shadow: inset 0 1px 1px rgba(0, 0, 0, .075), 0 0 8px rgba(102, 175, 233, .6);box-shadow: inset 0 1px 1px rgba(0, 0, 0, .075), 0 0 8px rgba(102, 175, 233, .6)}#call {width: 70px;height: 35px;background-color: #00BB00;border: none;color: white;border-radius: 5px;}#hangup {width: 70px;height: 35px;background-color: #FF5151;border: none;color: white;border-radius: 5px;}button {width: 70px;height: 35px;margin: 6px;background-color: #6de73d;border: none;color: white;border-radius: 5px;}</style>
</head><body><div id="main"><video id="remoteVideo" playsinline autoplay></video><video id="localVideo" playsinline autoplay muted></video><div id="buttons"><input id="myid" readonly /><br /><input id="toUser" placeholder="输入在线好友账号" /><br /><button id="call" onclick="call(true)">视频通话</button><button id="deskcall" onclick="call(false)">分享桌面</button><br /><button id="hangup">挂断</button></div></div>
</body>
<!--<script src="/js/adapter-2021.js" type="text/javascript"></script>-->
<script src="./fix-webm-duration.js" type="text/javascript"></script>
<script type="text/javascript">function generateRandomLetters(length) {let result = '';const characters = 'abcdefghijklmnopqrstuvwxyz'; // 字母表for (let i = 0; i < length; i++) {const randomIndex = Math.floor(Math.random() * characters.length);const randomLetter = characters[randomIndex];result += randomLetter;}return result;}let username = generateRandomLetters(2);document.getElementById('myid').value = username;let localVideo = document.getElementById('localVideo');let remoteVideo = document.getElementById('remoteVideo');let websocket = null;let peer = {};let candidate = null;let stream = null;/* WebSocket */function WebSocketInit() {//判断当前浏览器是否支持WebSocketif ('WebSocket' in window) {websocket = new WebSocket("ws://192.168.31.14:8181/webrtc/" + username);} else {alert("当前浏览器不支持WebSocket!");}//连接发生错误的回调方法websocket.onerror = function (e) {alert("WebSocket连接发生错误!");};//连接关闭的回调方法websocket.onclose = function () {console.error("WebSocket连接关闭");};//连接成功建立的回调方法websocket.onopen = function () {console.log("WebSocket连接成功");};//接收到消息的回调方法websocket.onmessage = async function (event) {let { type, fromUser, toUser, msg, sdp, iceCandidate } = JSON.parse(event.data.replace(/\n/g, "\\n").replace(/\r/g, "\\r"));console.log(type, fromUser, toUser);if (type === 'hangup') {console.log(msg);document.getElementById('hangup').click();return;}if (type === 'call_start') {document.getElementById('hangup').click();let msg = "0"if (confirm(fromUser + "发起视频通话,确定接听吗") == true) {document.getElementById('toUser').value = fromUser;WebRTCInit(fromUser);msg = "1"document.getElementById('toUser').style.visibility = 'hidden';document.getElementById('myid').style.visibility = 'hidden';}websocket.send(JSON.stringify({type: "call_back",toUser: fromUser,fromUser: username,msg: msg}));return;}if (type === 'call_back') {if (msg === "1") {console.log(document.getElementById('toUser').value + "同意视频通话");await getVideo(callType);console.log(peer, fromUser)stream.getTracks().forEach(track => {peer[fromUser].addTrack(track, stream);});let offer = await peer[fromUser].createOffer();await peer[fromUser].setLocalDescription(offer);let newOffer = offer.toJSON();newOffer["fromUser"] = username;newOffer["toUser"] = document.getElementById('toUser').value;websocket.send(JSON.stringify(newOffer));} else if (msg === "0") {alert(document.getElementById('toUser').value + "拒绝视频通话");document.getElementById('hangup').click();} else {alert(msg);document.getElementById('hangup').click();}return;}if (type === 'offer') {await getVideo(callType);console.log(peer, fromUser, stream)stream.getTracks().forEach(track => {peer[fromUser].addTrack(track, stream);});await peer[fromUser].setRemoteDescription(new RTCSessionDescription({ type, sdp }));let answer = await peer[fromUser].createAnswer();newAnswer = answer.toJSON();newAnswer["fromUser"] = username;newAnswer["toUser"] = fromUser;websocket.send(JSON.stringify(newAnswer));await peer[fromUser].setLocalDescription(newAnswer);return;}if (type === 'answer') {peer[fromUser].setRemoteDescription(new RTCSessionDescription({ type, sdp }));return;}if (type === '_ice') {peer[fromUser].addIceCandidate(iceCandidate);return;}if (type === 'getStream') {WebRTCInit(fromUser);stream.getTracks().forEach(track => {peer[fromUser].addTrack(track, stream);});let offer = await peer[fromUser].createOffer();await peer[fromUser].setLocalDescription(offer);let newOffer = offer.toJSON();newOffer["fromUser"] = username;newOffer["toUser"] = fromUser;websocket.send(JSON.stringify(newOffer));}}}async function getVideo(callType) {if (stream == null) {if (callType) {//创建本地视频并发送offerstream = await navigator.mediaDevices.getUserMedia({// video: {//     // width: 2560, height: 1440,//     // width: 1920, height: 1080,//     width: 1280, height: 720,//     // width: 640, height: 480,//     // 强制后置//     // facingMode: { exact: "environment" },//     // 前置 如果有的话//     facingMode: "user",//     // 受限带宽传输时,采用低帧率//     frameRate: { ideal: 15, max: 25 }// },video: true,audio: true})} else {stream = await navigator.mediaDevices.getDisplayMedia({ video: true })}startRecorder(stream);localVideo.srcObject = stream;}}/* WebRTC */function WebRTCInit(userId) {if (peer[userId]) {peer[userId].close();}const p = new RTCPeerConnection();//icep.onicecandidate = function (e) {if (e.candidate) {websocket.send(JSON.stringify({type: '_ice',toUser: userId,fromUser: username,iceCandidate: e.candidate}));}};//trackp.ontrack = function (e) {if (e && e.streams) {remoteVideo.srcObject = e.streams[0];}};peer[userId] = p;console.log(peer)}// let callType = true;function call(ct) {let toUser = document.getElementById('toUser').value;if (!toUser) {alert("请先指定好友账号,再发起视频通话!");return;}callType = ct;document.getElementById('toUser').style.visibility = 'hidden';document.getElementById('myid').style.visibility = 'hidden';if (!peer[toUser]) {WebRTCInit(toUser);}websocket.send(JSON.stringify({type: "call_start",fromUser: username,toUser: toUser,}));}/* 按钮事件 */function ButtonFunInit() {//挂断document.getElementById('hangup').onclick = function (e) {document.getElementById('toUser').style.visibility = 'unset';document.getElementById('myid').style.visibility = 'unset';stream.getTracks().forEach(track => {track.stop();});stream = null;// 停止录像mediaRecorder.stop();if (remoteVideo.srcObject) {//挂断同时,通知对方websocket.send(JSON.stringify({type: "hangup",fromUser: username,toUser: document.getElementById('toUser').value,}));}Object.values(peer).forEach(peer => peer.close())peer = {};localVideo.srcObject = null;remoteVideo.srcObject = null;}}WebSocketInit();ButtonFunInit();// 录制视频let mediaRecorder;let recordedBlobs = [];let startTime = 0;function startRecorder(stream) {mediaRecorder = new MediaRecorder(stream);// 录制开始时触发mediaRecorder.onstart = () => {recordedBlobs = [];};// 录制过程中触发mediaRecorder.ondataavailable = event => {if (event.data && event.data.size > 0) {recordedBlobs.push(event.data);}};// 录制结束时触发mediaRecorder.onstop = () => {console.log(recordedBlobs[0].type);const blob = new Blob(recordedBlobs, { type: 'video/webm' });ysFixWebmDuration(blob, Date.now() - startTime, function (fixedBlob) {const url = window.URL.createObjectURL(fixedBlob);const a = document.createElement('a');const filename = 'recorded-video.webm';a.style.display = 'none';a.href = url;a.download = filename;document.body.appendChild(a);a.click();window.URL.revokeObjectURL(url);});};mediaRecorder.start();startTime = Date.now();}</script></html>

fix-webm-duration.js

(function (name, definition) {if (typeof define === "function" && define.amd) {// RequireJS / AMDdefine(definition);} else if (typeof module !== "undefined" && module.exports) {// CommonJS / Node.jsmodule.exports = definition();} else {// Direct includewindow.ysFixWebmDuration = definition();}
})("fix-webm-duration", function () {/** This is the list of possible WEBM file sections by their IDs.* Possible types: Container, Binary, Uint, Int, String, Float, Date*/var sections = {0xa45dfa3: { name: "EBML", type: "Container" },0x286: { name: "EBMLVersion", type: "Uint" },0x2f7: { name: "EBMLReadVersion", type: "Uint" },0x2f2: { name: "EBMLMaxIDLength", type: "Uint" },0x2f3: { name: "EBMLMaxSizeLength", type: "Uint" },0x282: { name: "DocType", type: "String" },0x287: { name: "DocTypeVersion", type: "Uint" },0x285: { name: "DocTypeReadVersion", type: "Uint" },0x6c: { name: "Void", type: "Binary" },0x3f: { name: "CRC-32", type: "Binary" },0xb538667: { name: "SignatureSlot", type: "Container" },0x3e8a: { name: "SignatureAlgo", type: "Uint" },0x3e9a: { name: "SignatureHash", type: "Uint" },0x3ea5: { name: "SignaturePublicKey", type: "Binary" },0x3eb5: { name: "Signature", type: "Binary" },0x3e5b: { name: "SignatureElements", type: "Container" },0x3e7b: { name: "SignatureElementList", type: "Container" },0x2532: { name: "SignedElement", type: "Binary" },0x8538067: { name: "Segment", type: "Container" },0x14d9b74: { name: "SeekHead", type: "Container" },0xdbb: { name: "Seek", type: "Container" },0x13ab: { name: "SeekID", type: "Binary" },0x13ac: { name: "SeekPosition", type: "Uint" },0x549a966: { name: "Info", type: "Container" },0x33a4: { name: "SegmentUID", type: "Binary" },0x3384: { name: "SegmentFilename", type: "String" },0x1cb923: { name: "PrevUID", type: "Binary" },0x1c83ab: { name: "PrevFilename", type: "String" },0x1eb923: { name: "NextUID", type: "Binary" },0x1e83bb: { name: "NextFilename", type: "String" },0x444: { name: "SegmentFamily", type: "Binary" },0x2924: { name: "ChapterTranslate", type: "Container" },0x29fc: { name: "ChapterTranslateEditionUID", type: "Uint" },0x29bf: { name: "ChapterTranslateCodec", type: "Uint" },0x29a5: { name: "ChapterTranslateID", type: "Binary" },0xad7b1: { name: "TimecodeScale", type: "Uint" },0x489: { name: "Duration", type: "Float" },0x461: { name: "DateUTC", type: "Date" },0x3ba9: { name: "Title", type: "String" },0xd80: { name: "MuxingApp", type: "String" },0x1741: { name: "WritingApp", type: "String" },// 0xf43b675: { name: 'Cluster', type: 'Container' },0x67: { name: "Timecode", type: "Uint" },0x1854: { name: "SilentTracks", type: "Container" },0x18d7: { name: "SilentTrackNumber", type: "Uint" },0x27: { name: "Position", type: "Uint" },0x2b: { name: "PrevSize", type: "Uint" },0x23: { name: "SimpleBlock", type: "Binary" },0x20: { name: "BlockGroup", type: "Container" },0x21: { name: "Block", type: "Binary" },0x22: { name: "BlockVirtual", type: "Binary" },0x35a1: { name: "BlockAdditions", type: "Container" },0x26: { name: "BlockMore", type: "Container" },0x6e: { name: "BlockAddID", type: "Uint" },0x25: { name: "BlockAdditional", type: "Binary" },0x1b: { name: "BlockDuration", type: "Uint" },0x7a: { name: "ReferencePriority", type: "Uint" },0x7b: { name: "ReferenceBlock", type: "Int" },0x7d: { name: "ReferenceVirtual", type: "Int" },0x24: { name: "CodecState", type: "Binary" },0x35a2: { name: "DiscardPadding", type: "Int" },0xe: { name: "Slices", type: "Container" },0x68: { name: "TimeSlice", type: "Container" },0x4c: { name: "LaceNumber", type: "Uint" },0x4d: { name: "FrameNumber", type: "Uint" },0x4b: { name: "BlockAdditionID", type: "Uint" },0x4e: { name: "Delay", type: "Uint" },0x4f: { name: "SliceDuration", type: "Uint" },0x48: { name: "ReferenceFrame", type: "Container" },0x49: { name: "ReferenceOffset", type: "Uint" },0x4a: { name: "ReferenceTimeCode", type: "Uint" },0x2f: { name: "EncryptedBlock", type: "Binary" },0x654ae6b: { name: "Tracks", type: "Container" },0x2e: { name: "TrackEntry", type: "Container" },0x57: { name: "TrackNumber", type: "Uint" },0x33c5: { name: "TrackUID", type: "Uint" },0x3: { name: "TrackType", type: "Uint" },0x39: { name: "FlagEnabled", type: "Uint" },0x8: { name: "FlagDefault", type: "Uint" },0x15aa: { name: "FlagForced", type: "Uint" },0x1c: { name: "FlagLacing", type: "Uint" },0x2de7: { name: "MinCache", type: "Uint" },0x2df8: { name: "MaxCache", type: "Uint" },0x3e383: { name: "DefaultDuration", type: "Uint" },0x34e7a: { name: "DefaultDecodedFieldDuration", type: "Uint" },0x3314f: { name: "TrackTimecodeScale", type: "Float" },0x137f: { name: "TrackOffset", type: "Int" },0x15ee: { name: "MaxBlockAdditionID", type: "Uint" },0x136e: { name: "Name", type: "String" },0x2b59c: { name: "Language", type: "String" },0x6: { name: "CodecID", type: "String" },0x23a2: { name: "CodecPrivate", type: "Binary" },0x58688: { name: "CodecName", type: "String" },0x3446: { name: "AttachmentLink", type: "Uint" },0x1a9697: { name: "CodecSettings", type: "String" },0x1b4040: { name: "CodecInfoURL", type: "String" },0x6b240: { name: "CodecDownloadURL", type: "String" },0x2a: { name: "CodecDecodeAll", type: "Uint" },0x2fab: { name: "TrackOverlay", type: "Uint" },0x16aa: { name: "CodecDelay", type: "Uint" },0x16bb: { name: "SeekPreRoll", type: "Uint" },0x2624: { name: "TrackTranslate", type: "Container" },0x26fc: { name: "TrackTranslateEditionUID", type: "Uint" },0x26bf: { name: "TrackTranslateCodec", type: "Uint" },0x26a5: { name: "TrackTranslateTrackID", type: "Binary" },0x60: { name: "Video", type: "Container" },0x1a: { name: "FlagInterlaced", type: "Uint" },0x13b8: { name: "StereoMode", type: "Uint" },0x13c0: { name: "AlphaMode", type: "Uint" },0x13b9: { name: "OldStereoMode", type: "Uint" },0x30: { name: "PixelWidth", type: "Uint" },0x3a: { name: "PixelHeight", type: "Uint" },0x14aa: { name: "PixelCropBottom", type: "Uint" },0x14bb: { name: "PixelCropTop", type: "Uint" },0x14cc: { name: "PixelCropLeft", type: "Uint" },0x14dd: { name: "PixelCropRight", type: "Uint" },0x14b0: { name: "DisplayWidth", type: "Uint" },0x14ba: { name: "DisplayHeight", type: "Uint" },0x14b2: { name: "DisplayUnit", type: "Uint" },0x14b3: { name: "AspectRatioType", type: "Uint" },0xeb524: { name: "ColourSpace", type: "Binary" },0xfb523: { name: "GammaValue", type: "Float" },0x383e3: { name: "FrameRate", type: "Float" },0x61: { name: "Audio", type: "Container" },0x35: { name: "SamplingFrequency", type: "Float" },0x38b5: { name: "OutputSamplingFrequency", type: "Float" },0x1f: { name: "Channels", type: "Uint" },0x3d7b: { name: "ChannelPositions", type: "Binary" },0x2264: { name: "BitDepth", type: "Uint" },0x62: { name: "TrackOperation", type: "Container" },0x63: { name: "TrackCombinePlanes", type: "Container" },0x64: { name: "TrackPlane", type: "Container" },0x65: { name: "TrackPlaneUID", type: "Uint" },0x66: { name: "TrackPlaneType", type: "Uint" },0x69: { name: "TrackJoinBlocks", type: "Container" },0x6d: { name: "TrackJoinUID", type: "Uint" },0x40: { name: "TrickTrackUID", type: "Uint" },0x41: { name: "TrickTrackSegmentUID", type: "Binary" },0x46: { name: "TrickTrackFlag", type: "Uint" },0x47: { name: "TrickMasterTrackUID", type: "Uint" },0x44: { name: "TrickMasterTrackSegmentUID", type: "Binary" },0x2d80: { name: "ContentEncodings", type: "Container" },0x2240: { name: "ContentEncoding", type: "Container" },0x1031: { name: "ContentEncodingOrder", type: "Uint" },0x1032: { name: "ContentEncodingScope", type: "Uint" },0x1033: { name: "ContentEncodingType", type: "Uint" },0x1034: { name: "ContentCompression", type: "Container" },0x254: { name: "ContentCompAlgo", type: "Uint" },0x255: { name: "ContentCompSettings", type: "Binary" },0x1035: { name: "ContentEncryption", type: "Container" },0x7e1: { name: "ContentEncAlgo", type: "Uint" },0x7e2: { name: "ContentEncKeyID", type: "Binary" },0x7e3: { name: "ContentSignature", type: "Binary" },0x7e4: { name: "ContentSigKeyID", type: "Binary" },0x7e5: { name: "ContentSigAlgo", type: "Uint" },0x7e6: { name: "ContentSigHashAlgo", type: "Uint" },0xc53bb6b: { name: "Cues", type: "Container" },0x3b: { name: "CuePoint", type: "Container" },0x33: { name: "CueTime", type: "Uint" },0x37: { name: "CueTrackPositions", type: "Container" },0x77: { name: "CueTrack", type: "Uint" },0x71: { name: "CueClusterPosition", type: "Uint" },0x70: { name: "CueRelativePosition", type: "Uint" },0x32: { name: "CueDuration", type: "Uint" },0x1378: { name: "CueBlockNumber", type: "Uint" },0x6a: { name: "CueCodecState", type: "Uint" },0x5b: { name: "CueReference", type: "Container" },0x16: { name: "CueRefTime", type: "Uint" },0x17: { name: "CueRefCluster", type: "Uint" },0x135f: { name: "CueRefNumber", type: "Uint" },0x6b: { name: "CueRefCodecState", type: "Uint" },0x941a469: { name: "Attachments", type: "Container" },0x21a7: { name: "AttachedFile", type: "Container" },0x67e: { name: "FileDescription", type: "String" },0x66e: { name: "FileName", type: "String" },0x660: { name: "FileMimeType", type: "String" },0x65c: { name: "FileData", type: "Binary" },0x6ae: { name: "FileUID", type: "Uint" },0x675: { name: "FileReferral", type: "Binary" },0x661: { name: "FileUsedStartTime", type: "Uint" },0x662: { name: "FileUsedEndTime", type: "Uint" },0x43a770: { name: "Chapters", type: "Container" },0x5b9: { name: "EditionEntry", type: "Container" },0x5bc: { name: "EditionUID", type: "Uint" },0x5bd: { name: "EditionFlagHidden", type: "Uint" },0x5db: { name: "EditionFlagDefault", type: "Uint" },0x5dd: { name: "EditionFlagOrdered", type: "Uint" },0x36: { name: "ChapterAtom", type: "Container" },0x33c4: { name: "ChapterUID", type: "Uint" },0x1654: { name: "ChapterStringUID", type: "String" },0x11: { name: "ChapterTimeStart", type: "Uint" },0x12: { name: "ChapterTimeEnd", type: "Uint" },0x18: { name: "ChapterFlagHidden", type: "Uint" },0x598: { name: "ChapterFlagEnabled", type: "Uint" },0x2e67: { name: "ChapterSegmentUID", type: "Binary" },0x2ebc: { name: "ChapterSegmentEditionUID", type: "Uint" },0x23c3: { name: "ChapterPhysicalEquiv", type: "Uint" },0xf: { name: "ChapterTrack", type: "Container" },0x9: { name: "ChapterTrackNumber", type: "Uint" },0x0: { name: "ChapterDisplay", type: "Container" },0x5: { name: "ChapString", type: "String" },0x37c: { name: "ChapLanguage", type: "String" },0x37e: { name: "ChapCountry", type: "String" },0x2944: { name: "ChapProcess", type: "Container" },0x2955: { name: "ChapProcessCodecID", type: "Uint" },0x50d: { name: "ChapProcessPrivate", type: "Binary" },0x2911: { name: "ChapProcessCommand", type: "Container" },0x2922: { name: "ChapProcessTime", type: "Uint" },0x2933: { name: "ChapProcessData", type: "Binary" },0x254c367: { name: "Tags", type: "Container" },0x3373: { name: "Tag", type: "Container" },0x23c0: { name: "Targets", type: "Container" },0x28ca: { name: "TargetTypeValue", type: "Uint" },0x23ca: { name: "TargetType", type: "String" },0x23c5: { name: "TagTrackUID", type: "Uint" },0x23c9: { name: "TagEditionUID", type: "Uint" },0x23c4: { name: "TagChapterUID", type: "Uint" },0x23c6: { name: "TagAttachmentUID", type: "Uint" },0x27c8: { name: "SimpleTag", type: "Container" },0x5a3: { name: "TagName", type: "String" },0x47a: { name: "TagLanguage", type: "String" },0x484: { name: "TagDefault", type: "Uint" },0x487: { name: "TagString", type: "String" },0x485: { name: "TagBinary", type: "Binary" },};function doInherit(newClass, baseClass) {newClass.prototype = Object.create(baseClass.prototype);newClass.prototype.constructor = newClass;}function WebmBase(name, type) {this.name = name || "Unknown";this.type = type || "Unknown";}WebmBase.prototype.updateBySource = function () {};WebmBase.prototype.setSource = function (source) {this.source = source;this.updateBySource();};WebmBase.prototype.updateByData = function () {};WebmBase.prototype.setData = function (data) {this.data = data;this.updateByData();};function WebmUint(name, type) {WebmBase.call(this, name, type || "Uint");}doInherit(WebmUint, WebmBase);function padHex(hex) {return hex.length % 2 === 1 ? "0" + hex : hex;}WebmUint.prototype.updateBySource = function () {// use hex representation of a number instead of number valuethis.data = "";for (var i = 0; i < this.source.length; i++) {var hex = this.source[i].toString(16);this.data += padHex(hex);}};WebmUint.prototype.updateByData = function () {var length = this.data.length / 2;this.source = new Uint8Array(length);for (var i = 0; i < length; i++) {var hex = this.data.substr(i * 2, 2);this.source[i] = parseInt(hex, 16);}};WebmUint.prototype.getValue = function () {return parseInt(this.data, 16);};WebmUint.prototype.setValue = function (value) {this.setData(padHex(value.toString(16)));};function WebmFloat(name, type) {WebmBase.call(this, name, type || "Float");}doInherit(WebmFloat, WebmBase);WebmFloat.prototype.getFloatArrayType = function () {return this.source && this.source.length === 4? Float32Array: Float64Array;};WebmFloat.prototype.updateBySource = function () {var byteArray = this.source.reverse();var floatArrayType = this.getFloatArrayType();var floatArray = new floatArrayType(byteArray.buffer);this.data = floatArray[0];};WebmFloat.prototype.updateByData = function () {var floatArrayType = this.getFloatArrayType();var floatArray = new floatArrayType([this.data]);var byteArray = new Uint8Array(floatArray.buffer);this.source = byteArray.reverse();};WebmFloat.prototype.getValue = function () {return this.data;};WebmFloat.prototype.setValue = function (value) {this.setData(value);};function WebmContainer(name, type) {WebmBase.call(this, name, type || "Container");}doInherit(WebmContainer, WebmBase);WebmContainer.prototype.readByte = function () {return this.source[this.offset++];};WebmContainer.prototype.readUint = function () {var firstByte = this.readByte();var bytes = 8 - firstByte.toString(2).length;var value = firstByte - (1 << (7 - bytes));for (var i = 0; i < bytes; i++) {// don't use bit operators to support x86value *= 256;value += this.readByte();}return value;};WebmContainer.prototype.updateBySource = function () {this.data = [];for (this.offset = 0; this.offset < this.source.length; this.offset = end) {var id = this.readUint();var len = this.readUint();var end = Math.min(this.offset + len, this.source.length);var data = this.source.slice(this.offset, end);var info = sections[id] || { name: "Unknown", type: "Unknown" };var ctr = WebmBase;switch (info.type) {case "Container":ctr = WebmContainer;break;case "Uint":ctr = WebmUint;break;case "Float":ctr = WebmFloat;break;}var section = new ctr(info.name, info.type);section.setSource(data);this.data.push({id: id,idHex: id.toString(16),data: section,});}};WebmContainer.prototype.writeUint = function (x, draft) {for (var bytes = 1, flag = 0x80;x >= flag && bytes < 8;bytes++, flag *= 0x80) {}if (!draft) {var value = flag + x;for (var i = bytes - 1; i >= 0; i--) {// don't use bit operators to support x86var c = value % 256;this.source[this.offset + i] = c;value = (value - c) / 256;}}this.offset += bytes;};WebmContainer.prototype.writeSections = function (draft) {this.offset = 0;for (var i = 0; i < this.data.length; i++) {var section = this.data[i],content = section.data.source,contentLength = content.length;this.writeUint(section.id, draft);this.writeUint(contentLength, draft);if (!draft) {this.source.set(content, this.offset);}this.offset += contentLength;}return this.offset;};WebmContainer.prototype.updateByData = function () {// run without accessing this.source to determine total length - need to know it to create Uint8Arrayvar length = this.writeSections("draft");this.source = new Uint8Array(length);// now really write datathis.writeSections();};WebmContainer.prototype.getSectionById = function (id) {for (var i = 0; i < this.data.length; i++) {var section = this.data[i];if (section.id === id) {return section.data;}}return null;};function WebmFile(source) {WebmContainer.call(this, "File", "File");this.setSource(source);}doInherit(WebmFile, WebmContainer);WebmFile.prototype.fixDuration = function (duration, options) {var logger = options && options.logger;if (logger === undefined) {logger = function (message) {console.log(message);};} else if (!logger) {logger = function () {};}var segmentSection = this.getSectionById(0x8538067);if (!segmentSection) {logger("[fix-webm-duration] Segment section is missing");return false;}var infoSection = segmentSection.getSectionById(0x549a966);if (!infoSection) {logger("[fix-webm-duration] Info section is missing");return false;}var timeScaleSection = infoSection.getSectionById(0xad7b1);if (!timeScaleSection) {logger("[fix-webm-duration] TimecodeScale section is missing");return false;}var durationSection = infoSection.getSectionById(0x489);if (durationSection) {if (durationSection.getValue() <= 0) {logger("[fix-webm-duration] Duration section is present, but the value is empty");durationSection.setValue(duration);} else {logger("[fix-webm-duration] Duration section is present");return false;}} else {logger("[fix-webm-duration] Duration section is missing");// append Duration sectiondurationSection = new WebmFloat("Duration", "Float");durationSection.setValue(duration);infoSection.data.push({id: 0x489,data: durationSection,});}// set default time scale to 1 millisecond (1000000 nanoseconds)timeScaleSection.setValue(1000000);infoSection.updateByData();segmentSection.updateByData();this.updateByData();return true;};WebmFile.prototype.toBlob = function (mimeType) {return new Blob([this.source.buffer], { type: mimeType || "video/webm" });};function fixWebmDuration(blob, duration, callback, options) {// The callback may be omitted - then the third argument is optionsif (typeof callback === "object") {options = callback;callback = undefined;}if (!callback) {return new Promise(function (resolve) {fixWebmDuration(blob, duration, resolve, options);});}try {var reader = new FileReader();reader.onloadend = function () {try {var file = new WebmFile(new Uint8Array(reader.result));if (file.fixDuration(duration, options)) {blob = file.toBlob(blob.type);}} catch (ex) {// ignore}callback(blob);};reader.readAsArrayBuffer(blob);} catch (ex) {callback(blob);}}// Support AMD import defaultfixWebmDuration.default = fixWebmDuration;return fixWebmDuration;
});

多对多 监控页面

<!DOCTYPE>
<html><head><meta charset="UTF-8"><title>WebRTC + WebSocket</title><meta name="viewport" content="width=device-width,initial-scale=1.0,user-scalable=no"><style>html,body {margin: 0;padding: 0;background: #222;}#main {position: absolute;width: 100%;height: 100%;}video {margin: 5px;width: 300px;}#buttons {z-index: 3;bottom: 20px;left: 20px;position: absolute;}input {border: 1px solid #ccc;padding: 7px 0px;border-radius: 5px;padding-left: 5px;margin-bottom: 5px;}input :focus {border-color: #66afe9;outline: 0;-webkit-box-shadow: inset 0 1px 1px rgba(0, 0, 0, .075), 0 0 8px rgba(102, 175, 233, .6);box-shadow: inset 0 1px 1px rgba(0, 0, 0, .075), 0 0 8px rgba(102, 175, 233, .6)}#call {width: 70px;height: 35px;background-color: #00BB00;border: none;color: white;border-radius: 5px;}#hangup {width: 70px;height: 35px;background-color: #FF5151;border: none;color: white;border-radius: 5px;}button {width: 70px;height: 35px;margin: 6px;background-color: #6de73d;border: none;color: white;border-radius: 5px;}</style>
</head><body><div id="main"><div id="buttons"><input id="myid" readonly /><br /><input id="toUser" placeholder="用户1" /><br /><button id="call" onclick="getStream()">获取流</button></div></div>
</body>
<!-- 可引可不引 -->
<script type="text/javascript" th:inline="javascript">function generateRandomLetters(length) {let result = '';const characters = 'abcdefghijklmnopqrstuvwxyz'; // 字母表for (let i = 0; i < length; i++) {const randomIndex = Math.floor(Math.random() * characters.length);const randomLetter = characters[randomIndex];result += randomLetter;}return result;}let username = generateRandomLetters(3);document.getElementById('myid').value = username;let websocket = null;let peer = {};let candidate = null;/* WebSocket */function WebSocketInit() {//判断当前浏览器是否支持WebSocketif ('WebSocket' in window) {websocket = new WebSocket("ws://192.168.31.14:8181/webrtc/" + username);} else {alert("当前浏览器不支持WebSocket!");}//连接发生错误的回调方法websocket.onerror = function (e) {alert("WebSocket连接发生错误!");};//连接关闭的回调方法websocket.onclose = function () {console.error("WebSocket连接关闭");};//连接成功建立的回调方法websocket.onopen = function () {console.log("WebSocket连接成功");};//接收到消息的回调方法websocket.onmessage = async function (event) {let { type, fromUser, toUser, msg, sdp, iceCandidate } = JSON.parse(event.data.replace(/\n/g, "\\n").replace(/\r/g, "\\r"));console.log(type, fromUser, toUser);if (type === 'call_back') {if (msg === "1") {} else if (msg === "0") {} else {peer[fromUser].close();document.getElementById(fromUser).remove()alert(msg);}return;}if (type === 'offer') {// let stream = await navigator.mediaDevices.getUserMedia({ video: true, audio: true })// localVideo.srcObject = stream;// stream.getTracks().forEach(track => {//     peer[fromUser].addTrack(track, stream);// });console.log("管理员收到", fromUser, peer)await peer[fromUser].setRemoteDescription(new RTCSessionDescription({ type, sdp }));let answer = await peer[fromUser].createAnswer();newAnswer = answer.toJSON();newAnswer["fromUser"] = username;newAnswer["toUser"] = fromUser;websocket.send(JSON.stringify(newAnswer));await peer[fromUser].setLocalDescription(newAnswer);return;}if (type === 'answer') {peer[fromUser].setRemoteDescription(new RTCSessionDescription({ type, sdp }));return;}if (type === '_ice') {peer[fromUser].addIceCandidate(iceCandidate);return;}}}WebSocketInit();/* WebRTC */function WebRTCInit(userId) {if (peer[userId]) {peer[userId].close();}const p = new RTCPeerConnection();//icep.onicecandidate = function (e) {if (e.candidate) {websocket.send(JSON.stringify({type: '_ice',toUser: userId,fromUser: username,iceCandidate: e.candidate}));}};// 创建video元素const videoElement = document.createElement('video');videoElement.id = userId;videoElement.setAttribute('playsinline', '');videoElement.setAttribute('autoplay', '');videoElement.setAttribute('controls', '');// 将video元素添加到DOM中document.body.appendChild(videoElement);//trackp.ontrack = function (e) {if (e && e.streams) {console.log(e);videoElement.srcObject = e.streams[0];}};peer[userId] = p;}async function getStream() {let toUser = document.getElementById('toUser').value;WebRTCInit(toUser);websocket.send(JSON.stringify({type: 'getStream',toUser: toUser,fromUser: username}));}</script></html>

websocket java代码

import com.fasterxml.jackson.databind.DeserializationFeature;
import com.fasterxml.jackson.databind.ObjectMapper;
import jakarta.websocket.*;
import jakarta.websocket.server.PathParam;
import jakarta.websocket.server.ServerEndpoint;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;import java.text.SimpleDateFormat;
import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;/*** WebRTC + WebSocket*/
@Slf4j
@Component
@ServerEndpoint(value = "/webrtc/{username}")
public class WebRtcWSServer {/*** 连接集合*/private static final Map<String, Session> sessionMap = new ConcurrentHashMap<>();/*** 连接建立成功调用的方法*/@OnOpenpublic void onOpen(Session session, @PathParam("username") String username, @PathParam("publicKey") String publicKey) {sessionMap.put(username, session);}/*** 连接关闭调用的方法*/@OnClosepublic void onClose(Session session) {for (Map.Entry<String, Session> entry : sessionMap.entrySet()) {if (entry.getValue() == session) {sessionMap.remove(entry.getKey());break;}}}/*** 发生错误时调用*/@OnErrorpublic void onError(Session session, Throwable error) {error.printStackTrace();}/*** 服务器接收到客户端消息时调用的方法*/@OnMessagepublic void onMessage(String message, Session session) {try{//jacksonObjectMapper mapper = new ObjectMapper();mapper.setDateFormat(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"));mapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);//JSON字符串转 HashMapHashMap hashMap = mapper.readValue(message, HashMap.class);//消息类型String type = (String) hashMap.get("type");//to userString toUser = (String) hashMap.get("toUser");Session toUserSession = sessionMap.get(toUser);String fromUser = (String) hashMap.get("fromUser");//msgString msg = (String) hashMap.get("msg");//sdpString sdp = (String) hashMap.get("sdp");//iceMap iceCandidate  = (Map) hashMap.get("iceCandidate");HashMap<String, Object> map = new HashMap<>();map.put("type",type);//呼叫的用户不在线if(toUserSession == null){toUserSession = session;map.put("type","call_back");map.put("fromUser",toUser);map.put("msg","Sorry,呼叫的用户不在线!");send(toUserSession,mapper.writeValueAsString(map));return;}map.put("fromUser",fromUser);map.put("toUser",toUser);//对方挂断if ("hangup".equals(type)) {map.put("fromUser",fromUser);map.put("msg","对方挂断!");}//视频通话请求if ("call_start".equals(type)) {map.put("fromUser",fromUser);map.put("msg","1");}//视频通话请求回应if ("call_back".equals(type)) {map.put("msg",msg);}//offerif ("offer".equals(type)) {map.put("fromUser",fromUser);map.put("toUser",toUser);map.put("sdp",sdp);}//answerif ("answer".equals(type)) {map.put("fromUser",fromUser);map.put("toUser",toUser);map.put("sdp",sdp);}//iceif ("_ice".equals(type)) {map.put("iceCandidate",iceCandidate);}//            getStreamif ("getStream".equals(type)) {map.put("fromUser",fromUser);map.put("toUser",toUser);}send(toUserSession,mapper.writeValueAsString(map));}catch(Exception e){e.printStackTrace();}}/*** 封装一个send方法,发送消息到前端*/private void send(Session session, String message) {try {System.out.println(message);session.getBasicRemote().sendText(message);} catch (Exception e) {e.printStackTrace();}}
}

springboot 相关依赖和配置

// 1.pom
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-websocket</artifactId>
</dependency>// 2.启用功能
@EnableWebSocket
public class CocoBootApplication3.config		
package com.coco.boot.config;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.socket.server.standard.ServerEndpointExporter;@Configuration
public class WebSocketConfig {@Beanpublic ServerEndpointExporter serverEndpointExporter() {return new ServerEndpointExporter();}
}

完结

实现多人通信,通过创建多个 RTCPeerConnection 对象来实现。
每个参与者都需要与其他参与者建立连接。每个参与者都维护一个 RTCPeerConnection 对象,分别与其他参与者进行连接。
参与者数量的增加,点对点连接的复杂性和网络带宽要求也会增加。

WebRTC 建立连接时,以下顺序执行:
1.创建本地 PeerConnection 对象:使用 RTCPeerConnection 构造函数创建本地的 PeerConnection 对象,该对象用于管理 WebRTC 连接。
2.添加本地媒体流:通过调用 getUserMedia 方法获取本地的音视频流,并将其添加到 PeerConnection 对象中。这样可以将本地的音视频数据发送给远程对等方。
3.创建和设置本地 SDP:使用 createOffer 方法创建本地的 Session Description Protocol (SDP),描述本地对等方的音视频设置和网络信息。然后,通过调用 setLocalDescription 方法将本地 SDP 设置为本地 PeerConnection 对象的本地描述。
4.发送本地 SDP:将本地 SDP 发送给远程对等方,可以使用信令服务器或其他通信方式发送。
5.接收远程 SDP:从远程对等方接收远程 SDP,可以通过信令服务器或其他通信方式接收。
6.设置远程 SDP:使用接收到的远程 SDP,调用 PeerConnection 对象的 setRemoteDescription 方法将其设置为远程描述。
7.创建和设置本地 ICE 候选项:使用 onicecandidate 事件监听 PeerConnection 对象的 ICE 候选项生成,在生成候选项后,通过信令服务器或其他通信方式将其发送给远程对等方。
8.接收和添加远程 ICE 候选项:从远程对等方接收到 ICE 候选项后,调用 addIceCandidate 方法将其添加到本地 PeerConnection 对象中。
9.连接建立:一旦本地和远程的 SDP 和 ICE 候选项都设置好并添加完毕,连接就会建立起来。此时,音视频流可以在本地和远程对等方之间进行传输。

主要参考:
WebRTC + WebSocket 实现视频通话
WebRTC穿透服务器防火墙配置问题
WebRTC音视频录制
WebRTC 多人视频聊天

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/787490.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

【算法刷题day14】Leetcode:144.二叉树的前序遍历、94.二叉树的中序遍历、145.二叉树的后序遍历

文章目录 二叉树递归遍历解题思路代码总结 二叉树的迭代遍历解题思路代码总结 二叉树的统一迭代法解题思路代码总结 草稿图网站 java的Deque 二叉树递归遍历 题目&#xff1a; 144.二叉树的前序遍历 94.二叉树的中序遍历 145.二叉树的后序遍历 解析&#xff1a;代码随想录解析…

mongodb的简单操作

文章目录 前言数据库的创建和删除集合的创建和删除文档的插入和查询异常处理更新数据局部修改符合条件的批量更新加操作 删除文档删除全部数据删除符合条件的数据 统计count统计有多少条数据统计特定条件有多少条数据 分页查询排序查询正则查询比较查询包含查询条件连接查询索引…

【文件操作API的使用】

1.概念 这对聪明的你们来说简直就是&#xff0c;对吗。 那什么是文件操作符&#xff0c;文件操作又有哪些步骤呢&#xff1f; 文件操作符通常用于指代在计算机编程中用于处理文件的特殊符号或标识符。在很多编程语言中&#xff0c;文件操作符被用于打开、关闭、读取和写入文件…

香港科技大学广州|数据科学与分析学域硕博招生宣讲会—天津大学专场

时间&#xff1a;2024年4月12日&#xff08;星期五&#xff09;14:00 地点&#xff1a;天津大学北洋园校区55楼B204 报名链接&#xff1a;https://www.wjx.top/vm/Q0cKTUI.aspx# 跨学科研究领域 *数据驱动的人工智能和机器学习 *统计学习和建模 工业和商业分析 *特定行业的数…

工艺品wordpress外贸主题

工艺品wordpress外贸主题 简约大气的wordpress外贸主题&#xff0c;适合做工艺品进出品外贸的公司官网使用。 https://www.jianzhanpress.com/?p5377

社交媒体市场:揭示Facebook的商业模式

在数字化时代&#xff0c;社交媒体已经成为人们生活中不可或缺的一部分。Facebook作为全球最大的社交媒体平台之一&#xff0c;其商业模式的运作方式对于了解社交媒体市场的发展趋势和影响力至关重要。本文将深入探讨Facebook的商业模式&#xff0c;剖析其运作机制&#xff0c;…

【Java面试题系列】基础篇

目录 基本常识标识符的命名规则八种基本数据类型的大小&#xff0c;以及他们的封装类3*0.10.3返回值是什么short s1 1; s1 s1 1;有什么错? short s1 1; s1 1;有什么错?简述&&与&的区别&#xff1f;简述break与continue、return的区别&#xff1f;Arrays类的…

微服务(基础篇-007-RabbitMQ部署指南)

目录 05-RabbitMQ快速入门--介绍和安装_哔哩哔哩_bilibilihttps://www.bilibili.com/video/BV1LQ4y127n4?p65&vd_source60a35a11f813c6dff0b76089e5e138cc 1.单机部署 1.1.下载镜像 1.2.安装MQ 2.集群部署 2.1.集群分类 2.2.设置网络 视频地址&#xff1a; 05-Rab…

项目:USB键盘和鼠标的复合设备

我们的复合设备使用一个物理设备就可以完成多个功能。 使用复合设备同时完成USB键盘和鼠标功能&#xff0c;它的主要实现方式有两种&#xff0c; 第一个就是我们将多个设备描述符合并成一个&#xff0c;这个相对比较简单&#xff0c;我们只要根据相应的报告描述符处理数据就可…

Red Hat配置本地yum源

Red Hat配置本地yum源 创建本地源文件夹 mkdir -p /mnt/cdrom挂载镜像文件至指定的目录 mount /dev/cdrom /mnt/cdrom备份本地源 cp -rf /etc/yum.repos.d /etc/yum.repos.d_$(date %Y%m%d_%H%M%S)删除默认原本地源 rm -rf /etc/yum.repos.d/*配置本地源&#xff0c;创建…

一文涵盖所有工作中遇到的redis操作,让你从此学会redis

一文涵盖所有工作中遇到的redis操作&#xff0c;让你从此学会redis 本文会从基础篇到进阶篇&#xff0c;逐步来讲解redis和springboot的整合&#xff0c;如何去操作&#xff0c;以及他的作用。让你学会使用redis&#xff0c;爱上使用redis。 介绍redis 首先我们来介绍一下re…

如何在Linux系统运行RStudio Server并实现无公网IP远程访问【内网穿透】

文章目录 推荐 前言1. 安装RStudio Server2. 本地访问3. Linux 安装cpolar4. 配置RStudio server公网访问地址5. 公网远程访问RStudio6. 固定RStudio公网地址 推荐 前些天发现了一个巨牛的人工智能学习网站&#xff0c;通俗易懂&#xff0c;风趣幽默&#xff0c;忍不住分享一下…

c++的学习之路:7、类和对象(3)

一、初始化列表 初始化列表&#xff1a;以一个冒号开始&#xff0c;接着是一个以逗号分隔的数据成员列表&#xff0c;每个"成员变量"后面跟一个放在括号中的初始值或表达式&#xff0c;如下方代码就是初始化列表的方式。从图片可以看出这种方式也可以利用缺省初始化…

rs485自动收发电路

R/RO&#xff1a;receive/receive out&#xff0c;接收&#xff0c;连接单片机的 rx D/DI&#xff1a;drive/drive in&#xff0c;驱动&#xff0c;连接单片机的 tx 自动控制电路的目的就是在 tx 空闲&#xff08;空闲为高并&#xff09;时拉低 RE 和 DE&#xff0c;工作&…

紫光展锐P7885核心板详细参数介绍_5G安卓智能模块开发方案

紫光展锐P7885核心板采用了先进的6nm EUV制程工艺&#xff0c;集成了高性能的应用处理器和金融级安全解决方案&#xff0c;为用户带来了全新的性能体验。 P7885核心板搭载了先进的6nm制程工艺SoC P7885&#xff0c;其中包含四核A76和四核A55&#xff0c;主频可达2.7Ghz&#xf…

每天五分钟计算机视觉:使用神经网络完成人脸的特征点检测

本文重点 我们上一节课程中学习了如何利用神经网络对图片中的对象进行定位,也就是通过输出四个参数值bx、by、bℎ和bw给出图片中对象的边界框。 本节课程我们学习特征点的检测,神经网络可以通过输出图片中对象的特征点的(x,y)坐标来实现对目标特征的识别,我们看几个例子。…

Laya1.8.4 UI长按选择对应位置释放技能

需求&#xff1a; 需要实现拖拽摇杆选择技能释放位置&#xff0c;释放技能。 原理&#xff1a;首先拆分需求&#xff0c;分为两部分&#xff0c;UI部分和场景部分&#xff0c;UI部分需要实现长按效果&#xff0c;长按后又要有拖动效果&#xff0c;将官方文档的示例代码改了改…

k8s笔记28--快速在ubuntu上基于二进制和源码安装containerd

k8s笔记28--快速在ubuntu上基于二进制和源码安装containerd 介绍containerd 安装方法二进制文件安装源码构建安装 注意事项说明 介绍 Containerd是一个工业标准的容器运行时&#xff0c;它强调简单、健壮和可移植性。它可作为Linux和Windows的守护进程&#xff0c;能管理主机系…

[人工智能] AI为农业赋能:智能灌溉系统

前言 人工智能&#xff08;AI&#xff09;在农业方面具有广泛的应用前景&#xff0c;这主要得益于其在数据处理、预测分析和决策优化等方面的优势。 农业生产涉及到大量的数据&#xff0c;包括土壤湿度、气温、降雨量、植物生长情况等。人工智能可以利用先进的数据处理技术&…

设计模式之工厂方法模式精讲

工厂方法模式又叫虚拟构造函数&#xff08;Virtual Constructor&#xff09;模式或者多态性工厂&#xff08;Polymorphic Factory&#xff09;模式。工厂方法模式的用意是定义一个创建产品对象的工厂接口&#xff0c;将实际创建性工作推迟到子类中。 工厂模式可以分为简单工厂…