用node.js搭建一个视频推流服务

本文介绍: 在响应头里面我们需要返回Con t e n t的大小，Con ten t–range，Acce p t–range s，Con tent-type。还需要资源的路径和资源的大小，资源的大小会用来计算那一部分 content要被send。这里的播放的视频是一个多个Par ti al Content组合起来的，每个Par ti al Content大小是1M。最终实现的效果如刚开始的实例，在浏览器中打开视频，会请求/video，该接口返回 media 类型的数据流片段。计算结束位置，这里取开始位置加上1M数据和结束位置两者之间的最小值。

由于业务中有不少视频使用的场景，今天来说说如何使用 node 完成一个视频推流服务。

先看看效果：

这里的播放的视频是一个多个Par ti al Content组合起来的，每个Par ti al Content大小是1M。

一，项目搭建

npm init

npm install --save express nodemon

<!DOCTYPE html&gt;
<html lang="en">
  <head>
    <meta charset="UTF-8" />
    <meta http-equiv="X-UA-Compatible" content="IE=edge" />
    <meta name="viewport" content="width=device-width, initial-scale=1.0" />
    <title>Video Streaming With Node</title>
    <style>
      body {
        max-width: 100%;
        height: 100vh;
        background-color: rgb(14, 14, 14);
        display: flex;
        margin: auto;
        align-items: center;
        justify-content: center;
      }
    </style>
  </head>
  <body>
    <video id="videoPlayer" width="70%" controls autoplay >
      <source src="/video" type="video/mp4" />
    </video>
  </body>
</html>

const express = require("express"); const app = express(); const fs = require("fs");


 app.get("/", function (req, res) {
 res.sendFile(__dirname + "/index.html");
 });
 // more code will go in here just befor the listening function

app.listen(8000, function () { console.log("Listening on port 8000!"); });

app.get("/video", function (req, res) {
    const range = req.headers.range;
    if (!range) {
        res.status(400).send("Requires Range header");
    }
});

const videoPath = "Chris-Do.mp4";
const videoSize = fs.statSync("Chris-Do.mp4").size;

const CHUNK_SIZE = 10 ** 6; // 1MB
const start = Number(range.replace(/D/g, ""));

const end = Math.min(start + CHUNK_SIZE, videoSize - 1);

const headers = {
    "Content-Range": `bytes ${start}-${end}/${videoSize}`,
    "Accept-Ranges": "bytes",
    "Content-Length": contentLength,
    "Content-Type": "video/mp4",
};

// HTTP Status 206 for Partial Content
res.writeHead(206, headers);

// create video read stream for this particular chunk
  const videoStream = fs.createReadStream(videoPath, { start, end });

  // Stream the video chunk to the client
  videoStream.pipe(res);