webrtc 合流-程序员宅基地

技术标签: css  webrtc  前端  html  javascript  

<template>
  <!-- 大窗口 -->
  <div class="liveVideos">
    <video
      id="camaraVideo"
      width="100%"
      height="100%"
      ref="videoing"
      class="video"
      autoplay="autoplay"
      muted
    ></video>
    <div
      v-if="isShowLoading"
      style="width: 10px; height: 10px; position: absolute; top: 50%; left: 50%"
    >
      <div class="load-container load4">
        <div class="loader"></div>
      </div>
    </div>
  </div>
</template>

<script>
const config = {
  iceServers: [
    {
      urls: "turn:118.186.244.77:3478?transport=udp",
      credential: "hmcs123456",
      username: "admin",
    },
    { urls: "stun:global.stun.twilio.com:3478?transport=udp" },
  ],
};

import Janus from "../../../components/webrtcJS/janus.js";

import { streamSourec } from "../../../components/webrtcJS/ipAnalysis.js";

export default {
  name: "caramerSourcres",
  components: {},

  watch: {
    "settings.computer"(val) {
      // 摄像头画面
      console.log("settings.computer", val);
      this.changeDeskVideoEnable(val);
    },
    "settings.Microphoneing"(val) {
      // 麦克风
      console.log("settings.Microphoneing", val);
      this.changeAudioMicEnable(val);
    },
    "settings.Micrcomputer"(val) {
      // 桌面声音
      console.log("settings.Micrcomputer", val);
      this.changeAudioDeskEnable(val);
    },
    "settings.Microphone"(val) {
      // 改变麦克风
      console.log("settings.Microphone", val);
      this.changeMicroPhoneDevice(val);
    },
    "settings.viderCameraId"(val) {
      // 改变摄像机设备
      console.log("settings.viderCameraId", val);
      this.changeCamaraDevice(val);
    },
  },
  props: {
    videoSrc: {
      type: Object,
    },
    audioFlage: {
      type: Boolean,
      default: true,
    },
    styeing: {
      type: Boolean,
      default: false,
    },
    settings: {
      type: Object,
      /**
       * videoCamera 摄像头   boolean
       * viderCameraId 摄像机设备 选择的decerid 默认是''
       * computer 共享电脑画面 boolean
       *
       * Microphoneing 麦克风 true
       * Microphone  麦克风选择 选择的decerid 默认是''
       * MicrophoneValue 麦克风音量 50 number boolean
       * Micrcomputer  共享电脑声音 boolean
       *
       *
       * speaker  扬声器 电脑声音  选择的decerid 默认是''
       * speakerValue  扬声器声音大小 number
       *
       * isState 屏幕还是摄像头 默认摄像头 0     1 桌面
       * */
    }
  },
  data() {
    return {
      SSOID: window.localStorage.getItem("SSOID") || "",
      musicing: require("@/assets/room/music.png"),
      audiolocalMicStream: null,
      deskLocalStream: null,
      videolocalMicStream: null,
      isAlreadyPushStream: false,
      userName: window.localStorage.getItem("username") || "",
      isShowLoading : true,
    };
  },

  created() {
    console.log("deskLocalSource");
  },
  beforeDestroy() {
    this.hangupHandle();
  },
  mounted() {
    let that = this;
    this.getLocalStreamBySetting().then((stream) => {
      var camaraVideo = document.getElementById("camaraVideo");
      var tempStream = new MediaStream();
      tempStream.addTrack(...stream.getVideoTracks());
      Janus.attachMediaStream(camaraVideo, tempStream);
      if (stream) {
        streamSourec(stream, (value) => {
          that.$emit("changeAudioVal", { fromUserName: that.userName, value });
        });
      }
      that.$parent.preparedPublishOwnFeed(stream);
    });
  },

  methods: {
    mergeAudioStreams(desktopStream, voiceStream) {
      const context = new AudioContext();
      const destination = context.createMediaStreamDestination();
      if (desktopStream && desktopStream.getAudioTracks().length > 0) {
        const source1 = context.createMediaStreamSource(desktopStream);
        const desktopGain = context.createGain();
        desktopGain.gain.value = 0.7;
        source1.connect(desktopGain).connect(destination);
      }
      if (voiceStream && voiceStream.getAudioTracks().length > 0) {
        const source2 = context.createMediaStreamSource(voiceStream);
        const voiceGain = context.createGain();
        voiceGain.gain.value = 0.7;
        source2.connect(voiceGain).connect(destination);
      }
      return destination.stream.getAudioTracks();
    },

    async getLocalStreamBySetting() {
      let stream_media = new MediaStream();
      let that = this;

      //判定是否静音

      //麦克风声音
      try {
        let audioConstraints;
        if (this.settings.Microphone) {
          audioConstraints = {
            video: false,
            audio: {
              deviceId: this.settings.Microphone,
              noiseSuppression: true,
              echoCancellation: true,
            },
            logicalSurface: false,
          };
        } else {
          audioConstraints = {
            video: false,
            audio: {
              noiseSuppression: true,
              echoCancellation: true,
            },
            logicalSurface: false,
          };
        }
        this.audiolocalMicStream = await navigator.mediaDevices.getUserMedia(
          audioConstraints
        );
      } catch (err) {
        that.$message.error("获取麦克风失败");
        console.error("获取麦克风失败", err);
      }

      //获取桌面流
      const deskonstraints = {
        audio: {
          mandatory: {
            chromeMediaSource: "desktop",
          },
        },
        video: {
          mandatory: {
            chromeMediaSource: "desktop",
          },
        },
      };

      this.deskLocalStream = await navigator.mediaDevices.getUserMedia(
        deskonstraints
      );
      let mergeAudioTracks = this.mergeAudioStreams(
        this.deskLocalStream,
        this.audiolocalMicStream
      );

      this.changeAudioMicEnable(this.settings.Microphoneing);
      this.changeAudioDeskEnable(this.settings.Micrcomputer);

      if (mergeAudioTracks) {
        stream_media.addTrack(...mergeAudioTracks);
      }

      //电脑桌面声音

      if (this.deskLocalStream) {
        stream_media.addTrack(...this.deskLocalStream.getVideoTracks());
      }

      return stream_media;
    },

    // 控制麦克风静音
    changeAudioMicEnable(enable) {
      if (this.audiolocalMicStream) {
        for (
          var i = 0;
          i < this.audiolocalMicStream.getAudioTracks().length;
          i++
        ) {
          var track = this.audiolocalMicStream.getAudioTracks()[i];
          if (track) track.enabled = enable;
        }
      }
    },
    // 控制屏幕
    changeDeskVideoEnable(enable) {
      console.log(enable);
      if (this.deskLocalStream) {
        for (var i = 0; i < this.deskLocalStream.getVideoTracks().length; i++) {
          var track = this.deskLocalStream.getVideoTracks()[0];
          if (track) track.enabled = enable;
        }
      }
    },
    // 主播听不到自己的电脑声音
    changeAudioDeskEnable(enable) {
      if (this.deskLocalStream) {
        for (var i = 0; i < this.deskLocalStream.getAudioTracks().length; i++) {
          var track = this.deskLocalStream.getAudioTracks()[0];
          if (track) track.enabled = enable;
        }
      }
    },

    changeMicroPhoneDevice(deviceId) {
      this.hangupHandle();
    },
    changeCamaraDevice(deviceId) {
      this.hangupHandle();
    },
    hangupHandle() {
      if (this.deskLocalStream) {
        let tracks = this.deskLocalStream.getTracks();
        tracks.forEach(function (track) {
          track.stop();
        });
        this.deskLocalStream = null;
      }

      if (this.audiolocalMicStream) {
        let tracks = this.audiolocalMicStream.getTracks();
        tracks.forEach(function (track) {
          track.stop();
        });
        this.audiolocalMicStream = null;
      }

      if (this.videolocalMicStream) {
        let tracks = this.videolocalMicStream.getTracks();
        tracks.forEach(function (track) {
          track.stop();
        });
        this.videolocalMicStream = null;
      }
    },
    userHandle() {
      // 关闭连接并设置为空
      this.hangupHandle();
    },
     cancelLoading(){
      this.isShowLoading=false
    },
  },
};
</script>

<style lang="scss" scoped>
.liveVideos {
      
  // -webkit-app-region: drag;
  width: 100%;
  height: auto;
  position: relative !important;
  // video {
  //   // object-fit: fill;
  // }
}
.box_change {
      
  position: absolute;
  bottom: 0;
  left: 0;
  width: 100%;
  height: 30px;
  background: #000000;
  border-radius: 2px 2px 2px 2px;
  opacity: 0.5;
  display: flex;
  justify-content: center;
  align-items: center;
  z-index: 11;
  span {
    font-size: 12px;
    font-family: Source Han Sans SC-Regular, Source Han Sans SC;
    font-weight: 400;
    color: #e6e6e6;
    margin-left: 8px;
  }
}
</style>
版权声明:本文为博主原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。
本文链接:https://blog.csdn.net/weixin_54274691/article/details/129153881

智能推荐

while循环&CPU占用率高问题深入分析与解决方案_main函数使用while(1)循环cpu占用99-程序员宅基地

文章浏览阅读3.8k次,点赞9次,收藏28次。直接上一个工作中碰到的问题,另外一个系统开启多线程调用我这边的接口,然后我这边会开启多线程批量查询第三方接口并且返回给调用方。使用的是两三年前别人遗留下来的方法,放到线上后发现确实是可以正常取到结果,但是一旦调用,CPU占用就直接100%(部署环境是win server服务器)。因此查看了下相关的老代码并使用JProfiler查看发现是在某个while循环的时候有问题。具体项目代码就不贴了,类似于下面这段代码。​​​​​​while(flag) {//your code;}这里的flag._main函数使用while(1)循环cpu占用99

【无标题】jetbrains idea shift f6不生效_idea shift +f6快捷键不生效-程序员宅基地

文章浏览阅读347次。idea shift f6 快捷键无效_idea shift +f6快捷键不生效

node.js学习笔记之Node中的核心模块_node模块中有很多核心模块,以下不属于核心模块,使用时需下载的是-程序员宅基地

文章浏览阅读135次。Ecmacript 中没有DOM 和 BOM核心模块Node为JavaScript提供了很多服务器级别,这些API绝大多数都被包装到了一个具名和核心模块中了,例如文件操作的 fs 核心模块 ,http服务构建的http 模块 path 路径操作模块 os 操作系统信息模块// 用来获取机器信息的var os = require('os')// 用来操作路径的var path = require('path')// 获取当前机器的 CPU 信息console.log(os.cpus._node模块中有很多核心模块,以下不属于核心模块,使用时需下载的是

数学建模【SPSS 下载-安装、方差分析与回归分析的SPSS实现(软件概述、方差分析、回归分析)】_化工数学模型数据回归软件-程序员宅基地

文章浏览阅读10w+次,点赞435次,收藏3.4k次。SPSS 22 下载安装过程7.6 方差分析与回归分析的SPSS实现7.6.1 SPSS软件概述1 SPSS版本与安装2 SPSS界面3 SPSS特点4 SPSS数据7.6.2 SPSS与方差分析1 单因素方差分析2 双因素方差分析7.6.3 SPSS与回归分析SPSS回归分析过程牙膏价格问题的回归分析_化工数学模型数据回归软件

利用hutool实现邮件发送功能_hutool发送邮件-程序员宅基地

文章浏览阅读7.5k次。如何利用hutool工具包实现邮件发送功能呢?1、首先引入hutool依赖<dependency> <groupId>cn.hutool</groupId> <artifactId>hutool-all</artifactId> <version>5.7.19</version></dependency>2、编写邮件发送工具类package com.pc.c..._hutool发送邮件

docker安装elasticsearch,elasticsearch-head,kibana,ik分词器_docker安装kibana连接elasticsearch并且elasticsearch有密码-程序员宅基地

文章浏览阅读867次,点赞2次,收藏2次。docker安装elasticsearch,elasticsearch-head,kibana,ik分词器安装方式基本有两种,一种是pull的方式,一种是Dockerfile的方式,由于pull的方式pull下来后还需配置许多东西且不便于复用,个人比较喜欢使用Dockerfile的方式所有docker支持的镜像基本都在https://hub.docker.com/docker的官网上能找到合..._docker安装kibana连接elasticsearch并且elasticsearch有密码

随便推点

Python 攻克移动开发失败!_beeware-程序员宅基地

文章浏览阅读1.3w次,点赞57次,收藏92次。整理 | 郑丽媛出品 | CSDN(ID:CSDNnews)近年来,随着机器学习的兴起,有一门编程语言逐渐变得火热——Python。得益于其针对机器学习提供了大量开源框架和第三方模块,内置..._beeware

Swift4.0_Timer 的基本使用_swift timer 暂停-程序员宅基地

文章浏览阅读7.9k次。//// ViewController.swift// Day_10_Timer//// Created by dongqiangfei on 2018/10/15.// Copyright 2018年 飞飞. All rights reserved.//import UIKitclass ViewController: UIViewController { ..._swift timer 暂停

元素三大等待-程序员宅基地

文章浏览阅读986次,点赞2次,收藏2次。1.硬性等待让当前线程暂停执行,应用场景:代码执行速度太快了,但是UI元素没有立马加载出来,造成两者不同步,这时候就可以让代码等待一下,再去执行找元素的动作线程休眠,强制等待 Thread.sleep(long mills)package com.example.demo;import org.junit.jupiter.api.Test;import org.openqa.selenium.By;import org.openqa.selenium.firefox.Firefox.._元素三大等待

Java软件工程师职位分析_java岗位分析-程序员宅基地

文章浏览阅读3k次,点赞4次,收藏14次。Java软件工程师职位分析_java岗位分析

Java:Unreachable code的解决方法_java unreachable code-程序员宅基地

文章浏览阅读2k次。Java:Unreachable code的解决方法_java unreachable code

标签data-*自定义属性值和根据data属性值查找对应标签_如何根据data-*属性获取对应的标签对象-程序员宅基地

文章浏览阅读1w次。1、html中设置标签data-*的值 标题 11111 222222、点击获取当前标签的data-url的值$('dd').on('click', function() { var urlVal = $(this).data('ur_如何根据data-*属性获取对应的标签对象

推荐文章

热门文章

相关标签