|
|
@@ -1,903 +0,0 @@
|
|
|
-<template>
|
|
|
- <div class="push-wrap">
|
|
|
- <div
|
|
|
- ref="topRef"
|
|
|
- class="left"
|
|
|
- >
|
|
|
- <div class="video-wrap">
|
|
|
- <video
|
|
|
- id="localVideo"
|
|
|
- ref="localVideoRef"
|
|
|
- autoplay
|
|
|
- webkit-playsinline="true"
|
|
|
- playsinline
|
|
|
- x-webkit-airplay="allow"
|
|
|
- x5-video-player-type="h5"
|
|
|
- x5-video-player-fullscreen="true"
|
|
|
- x5-video-orientation="portraint"
|
|
|
- muted
|
|
|
- controls
|
|
|
- ></video>
|
|
|
- <div
|
|
|
- v-if="currMediaTypeList.length <= 0"
|
|
|
- class="add-wrap"
|
|
|
- >
|
|
|
- <div
|
|
|
- class="item"
|
|
|
- @click="startMediaDevices"
|
|
|
- >
|
|
|
- 摄像头
|
|
|
- </div>
|
|
|
- <div
|
|
|
- class="item"
|
|
|
- @click="startGetDisplayMedia"
|
|
|
- >
|
|
|
- 窗口
|
|
|
- </div>
|
|
|
- </div>
|
|
|
- </div>
|
|
|
- <div
|
|
|
- ref="bottomRef"
|
|
|
- class="control"
|
|
|
- >
|
|
|
- <div class="info">
|
|
|
- <div class="avatar"></div>
|
|
|
- <div class="detail">
|
|
|
- <div class="top">
|
|
|
- <input
|
|
|
- ref="roomNameRef"
|
|
|
- v-model="roomName"
|
|
|
- type="text"
|
|
|
- placeholder="输入房间名"
|
|
|
- />
|
|
|
- <button
|
|
|
- class="btn"
|
|
|
- @click="confirmRoomName"
|
|
|
- >
|
|
|
- 确定
|
|
|
- </button>
|
|
|
- <!-- 房东的猫livehouse/音乐节 -->
|
|
|
- </div>
|
|
|
- <div class="bottom">
|
|
|
- <span>socketId:{{ getSocketId() }}</span>
|
|
|
- </div>
|
|
|
- </div>
|
|
|
- </div>
|
|
|
- <div class="other">
|
|
|
- <div class="top">
|
|
|
- <span class="item">
|
|
|
- <i class="ico"></i>
|
|
|
- <span>正在观看人数:{{ liveUserList.length }}</span>
|
|
|
- </span>
|
|
|
- </div>
|
|
|
- <div class="bottom">
|
|
|
- <button @click="startLive">开始直播</button>
|
|
|
- <button @click="endLive">结束直播</button>
|
|
|
- </div>
|
|
|
- </div>
|
|
|
- </div>
|
|
|
- </div>
|
|
|
- <div class="right">
|
|
|
- <div class="resource-card">
|
|
|
- <div class="title">素材列表</div>
|
|
|
- <div class="list">
|
|
|
- <div
|
|
|
- v-for="(item, index) in currMediaTypeList"
|
|
|
- :key="index"
|
|
|
- class="item"
|
|
|
- >
|
|
|
- <span class="name">{{ item }}</span>
|
|
|
- </div>
|
|
|
- </div>
|
|
|
- </div>
|
|
|
- <div class="danmu-card">
|
|
|
- <div class="title">弹幕互动</div>
|
|
|
- <div class="list">
|
|
|
- <div
|
|
|
- v-for="(item, index) in damuList"
|
|
|
- :key="index"
|
|
|
- class="item"
|
|
|
- >
|
|
|
- <span class="name">{{ item.socketId }}:</span>
|
|
|
- <span class="msg">{{ item.msg }}</span>
|
|
|
- </div>
|
|
|
- </div>
|
|
|
-
|
|
|
- <div class="send-msg">
|
|
|
- <input
|
|
|
- v-model="danmuStr"
|
|
|
- class="ipt"
|
|
|
- />
|
|
|
- <div
|
|
|
- class="btn"
|
|
|
- @click="sendDanmu"
|
|
|
- >
|
|
|
- 发送
|
|
|
- </div>
|
|
|
- </div>
|
|
|
- </div>
|
|
|
- </div>
|
|
|
- </div>
|
|
|
-</template>
|
|
|
-
|
|
|
-<script lang="ts" setup>
|
|
|
-import { getRandomString } from 'billd-utils';
|
|
|
-import MediaStreamRecorder from 'msr';
|
|
|
-import { onMounted, onUnmounted, ref } from 'vue';
|
|
|
-
|
|
|
-import { IAdminIn, ICandidate, IOffer, LiveTypeEnum } from '@/interface';
|
|
|
-import { WebRTCClass } from '@/network/webRtc';
|
|
|
-import {
|
|
|
- WebSocketClass,
|
|
|
- WsConnectStatusEnum,
|
|
|
- WsMsgTypeEnum,
|
|
|
-} from '@/network/webSocket';
|
|
|
-import { useNetworkStore } from '@/store/network';
|
|
|
-
|
|
|
-const networkStore = useNetworkStore();
|
|
|
-
|
|
|
-const topRef = ref<HTMLDivElement>();
|
|
|
-const bottomRef = ref<HTMLDivElement>();
|
|
|
-const roomIdRef = ref<HTMLInputElement>();
|
|
|
-const joinRef = ref<HTMLButtonElement>();
|
|
|
-const leaveRef = ref<HTMLButtonElement>();
|
|
|
-const defaultRoomId = getRandomString(15);
|
|
|
-const roomId = ref<string>(defaultRoomId);
|
|
|
-const danmuStr = ref('');
|
|
|
-const roomName = ref('');
|
|
|
-const roomNameRef = ref<HTMLInputElement>();
|
|
|
-const websocketInstant = ref<WebSocketClass>();
|
|
|
-const isDone = ref(false);
|
|
|
-const localVideoRef = ref<HTMLVideoElement>();
|
|
|
-const localStream = ref();
|
|
|
-const currMediaTypeList = ref<LiveTypeEnum[]>([]);
|
|
|
-const currMediaType = ref<LiveTypeEnum>();
|
|
|
-const joined = ref(false);
|
|
|
-const isAdmin = ref(true);
|
|
|
-const offerSended = ref(new Set());
|
|
|
-const damuList = ref<
|
|
|
- {
|
|
|
- socketId: string;
|
|
|
- msgType: number;
|
|
|
- msg: string;
|
|
|
- }[]
|
|
|
->([]);
|
|
|
-
|
|
|
-const liveUserList = ref<
|
|
|
- {
|
|
|
- socketId: string;
|
|
|
- avatar: string;
|
|
|
- expr: number;
|
|
|
- }[]
|
|
|
->([]);
|
|
|
-
|
|
|
-function closeWs() {
|
|
|
- const instance = networkStore.wsMap.get(roomId.value);
|
|
|
- if (!instance) return;
|
|
|
- instance.close();
|
|
|
-}
|
|
|
-
|
|
|
-function closeRtc() {
|
|
|
- networkStore.rtcMap.forEach((rtc) => {
|
|
|
- rtc.close();
|
|
|
- });
|
|
|
-}
|
|
|
-
|
|
|
-function sendDanmu() {
|
|
|
- if (!danmuStr.value.length) {
|
|
|
- alert('请输入弹幕内容!');
|
|
|
- }
|
|
|
- if (!websocketInstant.value) return;
|
|
|
- websocketInstant.value.send({
|
|
|
- msgType: WsMsgTypeEnum.message,
|
|
|
- data: { msg: danmuStr.value },
|
|
|
- });
|
|
|
- damuList.value.push({
|
|
|
- socketId: getSocketId(),
|
|
|
- msgType: 1,
|
|
|
- msg: danmuStr.value,
|
|
|
- });
|
|
|
- danmuStr.value = '';
|
|
|
-}
|
|
|
-
|
|
|
-onUnmounted(() => {
|
|
|
- closeWs();
|
|
|
- closeRtc();
|
|
|
-});
|
|
|
-let flvPlayer;
|
|
|
-
|
|
|
-function startRtmp() {
|
|
|
- try {
|
|
|
- flvPlayer.play();
|
|
|
- } catch (error) {
|
|
|
- console.log(error);
|
|
|
- }
|
|
|
-}
|
|
|
-
|
|
|
-onMounted(() => {
|
|
|
- // if (flvJs.isSupported()) {
|
|
|
- // flvPlayer = flvJs.createPlayer({
|
|
|
- // type: 'flv',
|
|
|
- // url: 'http://localhost:8080/live/show.flv',
|
|
|
- // // url: 'http://42.193.157.44:9000/live/fddm_2.flv',
|
|
|
- // // url: 'https://www.hsslive.cn/stream/live/fddm_2.flv',
|
|
|
- // // url: 'https://www.hsslive.cn/bilibilistream/live-bvc/173676/live_381307133_59434826.flv?expires=1680798150&len=0&oi=1900220676&pt=web&qn=0&trid=10002eb4d1a458684cc9a93d888d7b580cac&sigparams=cdn,expires,len,oi,pt,qn,trid&cdn=cn-gotcha15&sign=1724a76684e5e1f8d68346613a32f8c0&sk=3e2a893893799632504afbdef4a9e3d7&p2p_type=1&sl=1&free_type=0&mid=381307133&sche=ban&score=1&pp=rtmp&freeze=1&source=onetier&trace=10&site=12e2a543d23e1c612a7145eb5a5cfac4&order=1',
|
|
|
- // // url: 'https://xy117x149x235x203xy.mcdn.bilivideo.cn/live-bvc/173676/live_381307133_59434826.flv?expires=1680798150&len=0&oi=1900220676&pt=web&qn=0&trid=10002eb4d1a458684cc9a93d888d7b580cac&sigparams=cdn,expires,len,oi,pt,qn,trid&cdn=cn-gotcha15&sign=1724a76684e5e1f8d68346613a32f8c0&sk=3e2a893893799632504afbdef4a9e3d7&p2p_type=1&sl=1&free_type=0&mid=381307133&sche=ban&score=1&pp=rtmp&freeze=1&source=onetier&trace=10&site=12e2a543d23e1c612a7145eb5a5cfac4&order=1',
|
|
|
- // });
|
|
|
- // // @ts-ignore
|
|
|
- // flvPlayer.attachMediaElement(
|
|
|
- // document.querySelector<HTMLVideoElement>('#blobVideo')
|
|
|
- // );
|
|
|
- // flvPlayer.load();
|
|
|
- // }
|
|
|
- if (topRef.value && bottomRef.value && localVideoRef.value) {
|
|
|
- const res =
|
|
|
- bottomRef.value.getBoundingClientRect().top -
|
|
|
- topRef.value.getBoundingClientRect().top;
|
|
|
- localVideoRef.value.style.height = `100px`;
|
|
|
- // localVideoRef.value.style.height = `${res}px`;
|
|
|
- }
|
|
|
- localVideoRef.value?.addEventListener('loadstart', () => {
|
|
|
- console.warn('视频流-loadstart');
|
|
|
- const rtc = networkStore.getRtcMap(roomId.value);
|
|
|
- if (!rtc) return;
|
|
|
- rtc.rtcStatus.loadstart = true;
|
|
|
- rtc.update();
|
|
|
- });
|
|
|
-
|
|
|
- localVideoRef.value?.addEventListener('loadedmetadata', () => {
|
|
|
- console.warn('视频流-loadedmetadata');
|
|
|
- const rtc = networkStore.getRtcMap(roomId.value);
|
|
|
- if (!rtc) return;
|
|
|
- rtc.rtcStatus.loadedmetadata = true;
|
|
|
- rtc.update();
|
|
|
- if (isAdmin.value) {
|
|
|
- batchSendOffer();
|
|
|
- }
|
|
|
- });
|
|
|
-});
|
|
|
-
|
|
|
-function getSocketId() {
|
|
|
- return networkStore.wsMap.get(roomId.value!)?.socketIo?.id || '-1';
|
|
|
-}
|
|
|
-
|
|
|
-function sendJoin() {
|
|
|
- const instance = networkStore.wsMap.get(roomId.value);
|
|
|
- if (!instance) return;
|
|
|
- instance.send({
|
|
|
- msgType: WsMsgTypeEnum.join,
|
|
|
- data: {
|
|
|
- roomName: roomName.value,
|
|
|
- },
|
|
|
- });
|
|
|
-}
|
|
|
-
|
|
|
-function batchSendOffer() {
|
|
|
- liveUserList.value.forEach(async (item) => {
|
|
|
- if (
|
|
|
- !offerSended.value.has(item.socketId) &&
|
|
|
- item.socketId !== getSocketId()
|
|
|
- ) {
|
|
|
- await startNewWebRtc(item.socketId);
|
|
|
- await addTrack();
|
|
|
- console.warn('new WebRTCClass完成');
|
|
|
- console.log('执行sendOffer', {
|
|
|
- sender: getSocketId(),
|
|
|
- receiver: item.socketId,
|
|
|
- });
|
|
|
- sendOffer({ sender: getSocketId(), receiver: item.socketId });
|
|
|
- offerSended.value.add(item.socketId);
|
|
|
- }
|
|
|
- });
|
|
|
-}
|
|
|
-
|
|
|
-function initReceive() {
|
|
|
- const instance = websocketInstant.value;
|
|
|
- if (!instance?.socketIo) return;
|
|
|
- // websocket连接成功
|
|
|
- instance.socketIo.on(WsConnectStatusEnum.connect, () => {
|
|
|
- console.log('【websocket】websocket连接成功', instance.socketIo?.id);
|
|
|
- if (!instance) return;
|
|
|
- instance.status = WsConnectStatusEnum.connect;
|
|
|
- instance.update();
|
|
|
- });
|
|
|
-
|
|
|
- // websocket连接断开
|
|
|
- instance.socketIo.on(WsConnectStatusEnum.disconnect, () => {
|
|
|
- console.log('【websocket】websocket连接断开', instance);
|
|
|
- if (!instance) return;
|
|
|
- instance.status = WsConnectStatusEnum.disconnect;
|
|
|
- instance.update();
|
|
|
- });
|
|
|
-
|
|
|
- // 当前所有在线用户
|
|
|
- instance.socketIo.on(WsMsgTypeEnum.roomLiveing, (data: IAdminIn) => {
|
|
|
- console.log('【websocket】收到管理员正在直播', data);
|
|
|
- });
|
|
|
-
|
|
|
- // 当前所有在线用户
|
|
|
- instance.socketIo.on(WsMsgTypeEnum.liveUser, () => {
|
|
|
- console.log('【websocket】当前所有在线用户');
|
|
|
- if (!instance) return;
|
|
|
- });
|
|
|
-
|
|
|
- // 收到offer
|
|
|
- instance.socketIo.on(WsMsgTypeEnum.offer, async (data: IOffer) => {
|
|
|
- console.warn('【websocket】收到offer', data);
|
|
|
- if (!instance) return;
|
|
|
- if (data.data.receiver === getSocketId()) {
|
|
|
- console.log('收到offer,这个offer是发给我的');
|
|
|
- const rtc = startNewWebRtc(data.data.sender);
|
|
|
- await rtc.setRemoteDescription(data.data.sdp);
|
|
|
- const sdp = await rtc.createAnswer();
|
|
|
- await rtc.setLocalDescription(sdp);
|
|
|
- websocketInstant.value?.send({
|
|
|
- msgType: WsMsgTypeEnum.answer,
|
|
|
- data: { sdp, sender: getSocketId(), receiver: data.data.sender },
|
|
|
- });
|
|
|
- } else {
|
|
|
- console.log('收到offer,但是这个offer不是发给我的');
|
|
|
- }
|
|
|
- });
|
|
|
-
|
|
|
- // 收到answer
|
|
|
- instance.socketIo.on(WsMsgTypeEnum.answer, async (data: IOffer) => {
|
|
|
- console.warn('【websocket】收到answer', data);
|
|
|
- if (isDone.value) return;
|
|
|
- if (!instance) return;
|
|
|
- const rtc = networkStore.getRtcMap(`${roomId.value}___${data.socketId}`);
|
|
|
- console.log(rtc, '收到answer收到answer');
|
|
|
- if (!rtc) return;
|
|
|
- rtc.rtcStatus.answer = true;
|
|
|
- rtc.update();
|
|
|
- if (data.data.receiver === getSocketId()) {
|
|
|
- console.log('收到answer,这个answer是发给我的');
|
|
|
- await rtc.setRemoteDescription(data.data.sdp);
|
|
|
- } else {
|
|
|
- console.log('收到answer,但这个answer不是发给我的');
|
|
|
- }
|
|
|
- });
|
|
|
-
|
|
|
- // 收到candidate
|
|
|
- instance.socketIo.on(WsMsgTypeEnum.candidate, (data: ICandidate) => {
|
|
|
- console.warn('【websocket】收到candidate', data);
|
|
|
- if (isDone.value) return;
|
|
|
- if (!instance) return;
|
|
|
- const rtc =
|
|
|
- networkStore.getRtcMap(`${roomId.value}___${data.socketId}`) ||
|
|
|
- networkStore.getRtcMap(roomId.value);
|
|
|
- if (!rtc) return;
|
|
|
- if (data.socketId !== getSocketId()) {
|
|
|
- console.log('不是我发的candidate');
|
|
|
- const candidate = new RTCIceCandidate({
|
|
|
- sdpMid: data.data.sdpMid,
|
|
|
- sdpMLineIndex: data.data.sdpMLineIndex,
|
|
|
- candidate: data.data.candidate,
|
|
|
- });
|
|
|
- rtc.peerConnection
|
|
|
- ?.addIceCandidate(candidate)
|
|
|
- .then(() => {
|
|
|
- console.log('candidate成功');
|
|
|
- // rtc.handleStream();
|
|
|
- })
|
|
|
- .catch((err) => {
|
|
|
- console.error('candidate失败', err);
|
|
|
- });
|
|
|
- } else {
|
|
|
- console.log('是我发的candidate');
|
|
|
- }
|
|
|
- });
|
|
|
-
|
|
|
- // 收到用户发送消息
|
|
|
- instance.socketIo.on(WsMsgTypeEnum.message, (data) => {
|
|
|
- console.log('【websocket】收到用户发送消息', data);
|
|
|
- if (!instance) return;
|
|
|
- damuList.value.push({
|
|
|
- socketId: data.socketId,
|
|
|
- msgType: 1,
|
|
|
- msg: data.data.msg,
|
|
|
- });
|
|
|
- });
|
|
|
-
|
|
|
- // 用户加入房间
|
|
|
- instance.socketIo.on(WsMsgTypeEnum.join, (data) => {
|
|
|
- console.log('【websocket】用户加入房间', data);
|
|
|
- if (!instance) return;
|
|
|
- });
|
|
|
-
|
|
|
- // 用户加入房间
|
|
|
- instance.socketIo.on(WsMsgTypeEnum.joined, (data) => {
|
|
|
- console.log('【websocket】用户加入房间完成', data);
|
|
|
- joined.value = true;
|
|
|
- liveUserList.value.push({
|
|
|
- avatar: 'red',
|
|
|
- socketId: `${getSocketId()}`,
|
|
|
- expr: 1,
|
|
|
- });
|
|
|
- batchSendOffer();
|
|
|
- });
|
|
|
-
|
|
|
- // 其他用户加入房间
|
|
|
- instance.socketIo.on(WsMsgTypeEnum.otherJoin, (data) => {
|
|
|
- console.log('【websocket】其他用户加入房间', data);
|
|
|
- liveUserList.value.push({
|
|
|
- avatar: 'red',
|
|
|
- socketId: data.socketId,
|
|
|
- expr: 1,
|
|
|
- });
|
|
|
- console.log('当前所有在线用户', JSON.stringify(liveUserList.value));
|
|
|
- console.log(isAdmin.value, joined.value);
|
|
|
- if (isAdmin.value && joined.value) {
|
|
|
- batchSendOffer();
|
|
|
- }
|
|
|
- });
|
|
|
-
|
|
|
- // 用户离开房间
|
|
|
- instance.socketIo.on(WsMsgTypeEnum.leave, (data) => {
|
|
|
- console.log('【websocket】用户离开房间', data);
|
|
|
- if (!instance) return;
|
|
|
- instance.socketIo?.emit(WsMsgTypeEnum.leave, {
|
|
|
- roomId: instance.roomId,
|
|
|
- });
|
|
|
- });
|
|
|
-
|
|
|
- // 用户离开房间完成
|
|
|
- instance.socketIo.on(WsMsgTypeEnum.leaved, (data) => {
|
|
|
- console.log('【websocket】用户离开房间完成', data);
|
|
|
- if (!instance) return;
|
|
|
- const res = liveUserList.value.filter(
|
|
|
- (item) => item.socketId !== data.socketId
|
|
|
- );
|
|
|
- console.log('当前所有在线用户', JSON.stringify(res));
|
|
|
- liveUserList.value = res;
|
|
|
- });
|
|
|
-}
|
|
|
-
|
|
|
-function roomNameIsOk() {
|
|
|
- if (!roomName.value.length) {
|
|
|
- alert('请输入房间名!');
|
|
|
- return false;
|
|
|
- }
|
|
|
- if (roomName.value.length < 3 || roomName.value.length > 10) {
|
|
|
- alert('房间名要求3-10个字符!');
|
|
|
- return false;
|
|
|
- }
|
|
|
- return true;
|
|
|
-}
|
|
|
-
|
|
|
-function confirmRoomName() {
|
|
|
- if (!roomNameIsOk()) return;
|
|
|
- if (!roomNameRef.value) return;
|
|
|
- roomNameRef.value.disabled = true;
|
|
|
-}
|
|
|
-
|
|
|
-function endLive() {
|
|
|
- console.log('endLive');
|
|
|
- closeRtc();
|
|
|
- currMediaTypeList.value = [];
|
|
|
- localStream.value = null;
|
|
|
- if (localVideoRef.value) {
|
|
|
- localVideoRef.value.srcObject = null;
|
|
|
- }
|
|
|
- if (!websocketInstant.value) return;
|
|
|
- websocketInstant.value.close();
|
|
|
- // websocketInstant.value.send({
|
|
|
- // msgType: WsMsgTypeEnum.roomNoLive,
|
|
|
- // });
|
|
|
-}
|
|
|
-
|
|
|
-function startLive() {
|
|
|
- websocketInstant.value = new WebSocketClass({
|
|
|
- roomId: roomId.value,
|
|
|
- url:
|
|
|
- process.env.NODE_ENV === 'development'
|
|
|
- ? 'ws://localhost:4300'
|
|
|
- : 'wss://live.hsslive.cn',
|
|
|
- isAdmin: isAdmin.value,
|
|
|
- });
|
|
|
- websocketInstant.value.update();
|
|
|
- setTimeout(() => {
|
|
|
- websocketInstant.value!.socketIo?.emit(WsMsgTypeEnum.message, {
|
|
|
- data: { debug: 1 },
|
|
|
- });
|
|
|
- }, 1000);
|
|
|
-
|
|
|
- // initReceive();
|
|
|
- // sendJoin();
|
|
|
-}
|
|
|
-
|
|
|
-const blobArr = ref<Blob[]>([]);
|
|
|
-/** 摄像头 */
|
|
|
-async function startMediaDevices() {
|
|
|
- if (!localStream.value) {
|
|
|
- // WARN navigator.mediaDevices在localhost和https才能用,http://192.168.1.103:8000局域网用不了
|
|
|
- const event = await navigator.mediaDevices.getUserMedia({
|
|
|
- video: true,
|
|
|
- audio: false,
|
|
|
- });
|
|
|
- console.log('getUserMedia成功', event);
|
|
|
- currMediaType.value = LiveTypeEnum.camera;
|
|
|
- currMediaTypeList.value.push(LiveTypeEnum.camera);
|
|
|
- if (!localVideoRef.value) return;
|
|
|
- localVideoRef.value.srcObject = event;
|
|
|
- // const rec = new MediaRecorder(event, { mimeType: 'image/png' });
|
|
|
- // const rec = new MediaRecorder(event);
|
|
|
- const rec = new MediaRecorder(event, {
|
|
|
- // mimeType: 'video/webm;codecs=avc1.64001f,opus',
|
|
|
- mimeType: 'video/webm',
|
|
|
- });
|
|
|
- rec.addEventListener('dataavailable', (e) => {
|
|
|
- console.log(new Date().toLocaleString(), 'dataavailable');
|
|
|
- if (e.data.size > 0) {
|
|
|
- blobArr.value.push(e.data);
|
|
|
- }
|
|
|
- console.log(e.data.stream());
|
|
|
- // document.querySelector<HTMLVideoElement>('#blobVideo')!.srcObject =
|
|
|
- // e.data.stream();
|
|
|
- // const recordedBlob = new Blob([e.data], { type: 'video/webm' });
|
|
|
- const recordedBlob = new Blob([e.data]);
|
|
|
- console.log(recordedBlob);
|
|
|
- // const url = window.URL.createObjectURL(recordedBlob);
|
|
|
- // const a = document.createElement('a');
|
|
|
- // a.style.display = 'none';
|
|
|
- // a.href = url;
|
|
|
- // a.download = 'test.webm';
|
|
|
- // document.body.appendChild(a);
|
|
|
- // a.click();
|
|
|
- // setTimeout(() => {
|
|
|
- // document.body.removeChild(a);
|
|
|
- // window.URL.revokeObjectURL(url);
|
|
|
- // }, 100);
|
|
|
- if (!websocketInstant.value) return;
|
|
|
- // websocketInstant.value.socketIo?.emit(WsMsgTypeEnum.sendBlob, e.data);
|
|
|
- // websocketInstant.value.socketIo?.emit('aaa', { aa: recordedBlob });
|
|
|
- websocketInstant.value.send({
|
|
|
- msgType: WsMsgTypeEnum.sendBlob,
|
|
|
- data: { blob: recordedBlob, timestamp: new Date().getTime() },
|
|
|
- });
|
|
|
- });
|
|
|
- rec.start(500);
|
|
|
-
|
|
|
- localStream.value = event;
|
|
|
- }
|
|
|
-}
|
|
|
-/** 窗口 */
|
|
|
-async function startGetDisplayMedia() {
|
|
|
- if (!localStream.value) {
|
|
|
- // WARN navigator.mediaDevices.getDisplayMedia在localhost和https才能用,http://192.168.1.103:8000局域网用不了
|
|
|
- const event = await navigator.mediaDevices.getDisplayMedia({
|
|
|
- video: true,
|
|
|
- audio: true,
|
|
|
- });
|
|
|
- console.log('getDisplayMedia成功', event);
|
|
|
- currMediaType.value = LiveTypeEnum.screen;
|
|
|
- currMediaTypeList.value.push(LiveTypeEnum.screen);
|
|
|
- if (!localVideoRef.value) return;
|
|
|
- localVideoRef.value.srcObject = event;
|
|
|
- localStream.value = event;
|
|
|
- const rec = new MediaStreamRecorder(event);
|
|
|
- // const rec = new MediaRecorder(event, {
|
|
|
- // mimeType: 'video/webm',
|
|
|
- // });
|
|
|
- rec.ondataavailable = (blob) => {
|
|
|
- if (!websocketInstant.value) return;
|
|
|
- // websocketInstant.value.socketIo?.emit(WsMsgTypeEnum.sendBlob, e.data);
|
|
|
- // websocketInstant.value.socketIo?.emit('aaa', { aa: recordedBlob });
|
|
|
- websocketInstant.value.send({
|
|
|
- msgType: WsMsgTypeEnum.sendBlob,
|
|
|
- data: { blob, timestamp: new Date().getTime() },
|
|
|
- });
|
|
|
- };
|
|
|
- rec.start(500);
|
|
|
-
|
|
|
- // rec.addEventListener('dataavailable', (e) => {
|
|
|
- // console.log(new Date().toLocaleString(), 'dataavailable');
|
|
|
- // if (e.data.size <= 0) {
|
|
|
- // return;
|
|
|
- // }
|
|
|
- // blobArr.value.push(e.data);
|
|
|
-
|
|
|
- // console.log(e.data.stream());
|
|
|
- // // document.querySelector<HTMLVideoElement>('#blobVideo')!.srcObject =
|
|
|
- // // e.data.stream();
|
|
|
- // // const recordedBlob = new Blob([e.data], { type: 'video/webm' });
|
|
|
- // // const res1 = blobArr.value.pop();
|
|
|
- // // const res2 = res1 ? [res1] : [];
|
|
|
- // // const recordedBlob = new Blob(res2, { type: 'video/webm' });
|
|
|
- // const recordedBlob = new Blob(blobArr.value, { type: 'video/webm' });
|
|
|
- // // const recordedBlob = new Blob([e.data]);
|
|
|
- // console.log(recordedBlob, blobArr.value.length, 222);
|
|
|
- // // const url = window.URL.createObjectURL(recordedBlob);
|
|
|
- // // const a = document.createElement('a');
|
|
|
- // // a.style.display = 'none';
|
|
|
- // // a.href = url;
|
|
|
- // // a.download = 'test.webm';
|
|
|
- // // document.body.appendChild(a);
|
|
|
- // // a.click();
|
|
|
- // // setTimeout(() => {
|
|
|
- // // document.body.removeChild(a);
|
|
|
- // // window.URL.revokeObjectURL(url);
|
|
|
- // // }, 100);
|
|
|
- // if (!websocketInstant.value) return;
|
|
|
- // // websocketInstant.value.socketIo?.emit(WsMsgTypeEnum.sendBlob, e.data);
|
|
|
- // // websocketInstant.value.socketIo?.emit('aaa', { aa: recordedBlob });
|
|
|
- // websocketInstant.value.send({
|
|
|
- // msgType: WsMsgTypeEnum.sendBlob,
|
|
|
- // data: { blob: recordedBlob, timestamp: new Date().getTime() },
|
|
|
- // });
|
|
|
- // // blobArr.value = [];
|
|
|
- // });
|
|
|
- // rec.start(500);
|
|
|
- }
|
|
|
-}
|
|
|
-function addTrack() {
|
|
|
- if (!localStream.value) return;
|
|
|
- liveUserList.value.forEach((item) => {
|
|
|
- if (item.socketId !== getSocketId()) {
|
|
|
- localStream.value.getTracks().forEach((track) => {
|
|
|
- const rtc = networkStore.getRtcMap(
|
|
|
- `${roomId.value}___${item.socketId}`
|
|
|
- );
|
|
|
- rtc?.addTrack(track, localStream.value);
|
|
|
- });
|
|
|
- }
|
|
|
- });
|
|
|
-}
|
|
|
-
|
|
|
-async function sendOffer({
|
|
|
- sender,
|
|
|
- receiver,
|
|
|
-}: {
|
|
|
- sender: string;
|
|
|
- receiver: string;
|
|
|
-}) {
|
|
|
- if (isDone.value) return;
|
|
|
- if (!websocketInstant.value) return;
|
|
|
- const rtc = networkStore.getRtcMap(`${roomId.value}___${receiver}`);
|
|
|
- if (!rtc) return;
|
|
|
- const sdp = await rtc.createOffer();
|
|
|
- await rtc.setLocalDescription(sdp);
|
|
|
- websocketInstant.value.send({
|
|
|
- msgType: WsMsgTypeEnum.offer,
|
|
|
- data: { sdp, sender, receiver },
|
|
|
- });
|
|
|
-}
|
|
|
-
|
|
|
-function startNewWebRtc(receiver: string) {
|
|
|
- console.warn('开始new WebRTCClass', receiver);
|
|
|
- const rtc = new WebRTCClass({ roomId: `${roomId.value}___${receiver}` });
|
|
|
- rtc.rtcStatus.joined = true;
|
|
|
- rtc.update();
|
|
|
- return rtc;
|
|
|
-}
|
|
|
-
|
|
|
-function leave() {
|
|
|
- if (joinRef.value && leaveRef.value && roomIdRef.value) {
|
|
|
- roomIdRef.value.disabled = false;
|
|
|
- joinRef.value.disabled = false;
|
|
|
- leaveRef.value.disabled = true;
|
|
|
- }
|
|
|
- if (!websocketInstant.value) return;
|
|
|
- websocketInstant.value.socketIo?.emit(WsMsgTypeEnum.leave, {
|
|
|
- roomId: websocketInstant.value.roomId,
|
|
|
- });
|
|
|
-}
|
|
|
-</script>
|
|
|
-
|
|
|
-<style lang="scss" scoped>
|
|
|
-.push-wrap {
|
|
|
- margin: 20px auto 0;
|
|
|
- min-width: $large-width;
|
|
|
- height: 700px;
|
|
|
- text-align: center;
|
|
|
- .left {
|
|
|
- position: relative;
|
|
|
- display: inline-block;
|
|
|
- box-sizing: border-box;
|
|
|
- width: $large-left-width;
|
|
|
- height: 100%;
|
|
|
- border-radius: 10px;
|
|
|
- background-color: white;
|
|
|
- color: #9499a0;
|
|
|
- vertical-align: top;
|
|
|
-
|
|
|
- .video-wrap {
|
|
|
- position: relative;
|
|
|
- background-color: #18191c;
|
|
|
- #localVideo {
|
|
|
- max-width: 100%;
|
|
|
- max-height: 100%;
|
|
|
- }
|
|
|
- .add-wrap {
|
|
|
- position: absolute;
|
|
|
- top: 50%;
|
|
|
- left: 50%;
|
|
|
- display: flex;
|
|
|
- align-items: center;
|
|
|
- justify-content: space-around;
|
|
|
- width: 200px;
|
|
|
- height: 50px;
|
|
|
- background-color: #fff;
|
|
|
- transform: translate(-50%, -50%);
|
|
|
- .item {
|
|
|
- width: 60px;
|
|
|
- height: 30px;
|
|
|
- border-radius: 4px;
|
|
|
- background-color: rebeccapurple;
|
|
|
- color: white;
|
|
|
- font-size: 14px;
|
|
|
- line-height: 30px;
|
|
|
- cursor: pointer;
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
- .control {
|
|
|
- position: absolute;
|
|
|
- right: 0;
|
|
|
- bottom: 0;
|
|
|
- left: 0;
|
|
|
- display: flex;
|
|
|
- justify-content: space-between;
|
|
|
- padding: 20px;
|
|
|
- background-color: papayawhip;
|
|
|
-
|
|
|
- .info {
|
|
|
- display: flex;
|
|
|
- align-items: center;
|
|
|
-
|
|
|
- .avatar {
|
|
|
- margin-right: 20px;
|
|
|
- width: 64px;
|
|
|
- height: 64px;
|
|
|
- border-radius: 50%;
|
|
|
- background-color: yellow;
|
|
|
- }
|
|
|
- .detail {
|
|
|
- display: flex;
|
|
|
- flex-direction: column;
|
|
|
- text-align: initial;
|
|
|
- .top {
|
|
|
- margin-bottom: 10px;
|
|
|
- color: #18191c;
|
|
|
- .btn {
|
|
|
- margin-left: 10px;
|
|
|
- }
|
|
|
- }
|
|
|
- .bottom {
|
|
|
- font-size: 14px;
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
- .other {
|
|
|
- display: flex;
|
|
|
- flex-direction: column;
|
|
|
- justify-content: center;
|
|
|
- font-size: 12px;
|
|
|
- .top {
|
|
|
- display: flex;
|
|
|
- align-items: center;
|
|
|
- .item {
|
|
|
- display: flex;
|
|
|
- align-items: center;
|
|
|
- margin-right: 20px;
|
|
|
- .ico {
|
|
|
- display: inline-block;
|
|
|
- margin-right: 4px;
|
|
|
- width: 10px;
|
|
|
- height: 10px;
|
|
|
- border-radius: 50%;
|
|
|
- background-color: skyblue;
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
- .bottom {
|
|
|
- margin-top: 10px;
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
- .right {
|
|
|
- position: relative;
|
|
|
- display: inline-block;
|
|
|
- box-sizing: border-box;
|
|
|
- margin-left: 10px;
|
|
|
- width: 240px;
|
|
|
- height: 100%;
|
|
|
- border-radius: 10px;
|
|
|
- background-color: white;
|
|
|
- color: #9499a0;
|
|
|
-
|
|
|
- .resource-card {
|
|
|
- margin-bottom: 5%;
|
|
|
- margin-bottom: 10px;
|
|
|
- width: 100%;
|
|
|
- height: 290px;
|
|
|
- border-radius: 4px;
|
|
|
- background-color: papayawhip;
|
|
|
- .title {
|
|
|
- padding: 10px;
|
|
|
- text-align: initial;
|
|
|
- }
|
|
|
- .item {
|
|
|
- display: flex;
|
|
|
- align-items: center;
|
|
|
- justify-content: space-between;
|
|
|
- margin-bottom: 10px;
|
|
|
- font-size: 12px;
|
|
|
- }
|
|
|
- }
|
|
|
- .danmu-card {
|
|
|
- box-sizing: border-box;
|
|
|
- padding: 10px;
|
|
|
- width: 100%;
|
|
|
- height: 400px;
|
|
|
- border-radius: 4px;
|
|
|
- background-color: papayawhip;
|
|
|
- text-align: initial;
|
|
|
- .title {
|
|
|
- margin-bottom: 10px;
|
|
|
- }
|
|
|
- .list {
|
|
|
- margin-bottom: 10px;
|
|
|
- height: 300px;
|
|
|
- .item {
|
|
|
- margin-bottom: 10px;
|
|
|
- font-size: 12px;
|
|
|
- .name {
|
|
|
- color: #9499a0;
|
|
|
- }
|
|
|
- .msg {
|
|
|
- color: #61666d;
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- .send-msg {
|
|
|
- display: flex;
|
|
|
- align-items: center;
|
|
|
- box-sizing: border-box;
|
|
|
- .ipt {
|
|
|
- display: block;
|
|
|
- box-sizing: border-box;
|
|
|
- margin: 0 auto;
|
|
|
- margin-right: 10px;
|
|
|
- padding: 10px;
|
|
|
- width: 80%;
|
|
|
- height: 30px;
|
|
|
- outline: none;
|
|
|
- border: 1px solid hsla(0, 0%, 60%, 0.2);
|
|
|
- border-radius: 4px;
|
|
|
- background-color: #f1f2f3;
|
|
|
- font-size: 14px;
|
|
|
- }
|
|
|
- .btn {
|
|
|
- box-sizing: border-box;
|
|
|
- width: 80px;
|
|
|
- height: 30px;
|
|
|
- border-radius: 4px;
|
|
|
- background-color: #23ade5;
|
|
|
- color: white;
|
|
|
- text-align: center;
|
|
|
- font-size: 12px;
|
|
|
- line-height: 30px;
|
|
|
- cursor: pointer;
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
-}
|
|
|
-// 屏幕宽度小于$large-width的时候
|
|
|
-@media screen and (max-width: $large-width) {
|
|
|
- .push-wrap {
|
|
|
- .left {
|
|
|
- width: $medium-left-width;
|
|
|
- }
|
|
|
- .right {
|
|
|
- .list {
|
|
|
- .item {
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
-}
|
|
|
-</style>
|