锦上添花的视频弹幕模块开发

add: async (req) => {
    let { content, episodeId, playTime, productId } = req.body
    if (!(content && episodeId && Number(playTime) >= 0 && productId)) {
        return BackCode.buildError({ msg: '缺少必要参数' })
    }
    let token = req.headers.authorization.split(' ').pop()
    let userInfo = SecretTool.jwtVerify(token)
    let barrageItem = {
        episode_id: episodeId,
        product_id: productId,
        play_time: playTime,
        content: content,
        account_id: userInfo.id,
        head_img: userInfo.head_img,
        username: userInfo.username,
        del: 0,
    }
    await DB.BulletScreen.create(barrageItem)
    return BackCode.buildSuccess()
},

list_by_episode: async (req) => {
  let { beginTime, endTime, episodeId, productId } = req.body
  if (!(productId && episodeId && Number(beginTime) >= 0 && endTime)) {
    return BackCode.buildError({ msg: '缺少必要参数' })
  }
  let barrageList = await DB.BulletScreen.findAll({
    where: { play_time: { [Op.between]: [beginTime, endTime] }, episode_id: episodeId, product_id: productId    }
  })
  return BackCode.buildSuccessAndData({ data: barrageList })
},

-   优点
    -   节省资源：对比客户端轮询请求后端接口，更加节省服务器资源和宽带
    -   更强实时性：由于协议是全双工的，所以服务器可以随时主动给客户端下发数据，延迟更小
    -   保持连接状态：HTTP请求建立一次链接就断开，而websocket是持久性链接
-   使用场景
    -   弹幕
    -   多玩家游戏
    -   视频会议
    -   股票基金报价实时更新
    -   体育实况更新
    -   音视频聊天
    -   在线教育
    -   社交订阅

/**
 * 弹幕逻辑配置
 */
import { useRef, useState } from "react";
import { io } from "socket.io-client";
const useSocket = () => {
  // 弹幕实例变量名
  const socket = useRef<any>(null);
  // 发送的弹幕
  const videoDanmuList = useRef<any[]>([]);
  const initialize = () => {
    // 建立传输链接 http://127.0.0.1:8081
    socket.current = io("ws://127.0.0.1:8081");
    socket.current.on("connect", () => {
      console.log("socketio已连接");
    });
    onBulletChat();
  };
  // 发送弹幕事件
  const handleAddDanmu = (data: any) => {
    socket.current.emit("bulletChat", data);
  };
  // 监听bulletChat事件
  const onBulletChat = () => {
    socket.current.on("message", (data: any) => {
      videoDanmuList.current.push(data);
    });
  };
  return {
    videoDanmuList,
    initialize,
    handleAddDanmu,
    onBulletChat,
  };
};
export default useSocket;

const express = require('express');
const app = express();
const { createServer } = require('http');
const server = createServer(app)
server.listen(8081, () => {
  console.log('服务启动在：http://127.0.0.1:8081')
})

const { Server } = require('socket.io')
const Redis = require("ioredis");
// redis发布的api
const clientPublish = new Redis({ port: 6379, host: '8.130.120.189', password: 'xdclass.net' });
// redis订阅api
const clientSubscribe = new Redis({ port: 6379, host: '8.130.120.189', password: 'xdclass.net' });
clientSubscribe.subscribe('chat');
const websocket = (server) => {
    // 实例化socket
    const io = new Server(server, { cors: { origin: '*' } })
    // websocket建立链接
    io.on('connection', (socket) => {
        console.log('有客户端链接进来了')
        // 监听bulletChat事件
        socket.on('bulletChat', (info) => {
            clientPublish.publish('chat', JSON.stringify(info))
        })
    })
    // 订阅redis收到消息后，执行websocket的消息推送客户端
    clientSubscribe.on('message', (channel, message) => {
        io.emit('message', JSON.parse(message))
    })
}
module.exports = websocket

-   单播：点对点 私信私聊
-   多播：也叫组播（特定人群） 多人聊天，发布订阅
-   广播：游戏公告

如果你使用Node.js做服务端，那么该选择Socket.IO