Потоковое видео с HTML 5 через node.js - PullRequest
Новая
       62

Потоковое видео с HTML 5 через node.js

43 голосов
/ 05 декабря 2010

Я пытаюсь настроить веб-сервер, который будет поддерживать потоковое видео для тега HTML5 video с использованием node.js. Вот мой код: 

var range = request.headers.range;
var total = file.length;

var parts = range.replace(/bytes=/, "").split("-");
var partialstart = parts[0];
var partialend = parts[1];

var start = parseInt(partialstart, 10);
var end = partialend ? parseInt(partialend, 10) : total-1;

var chunksize = (end-start)+1;

response.writeHead(206, { "Content-Range": "bytes " + start + "-" + end + "/" + total, "Accept-Ranges": "bytes", "Content-Length": chunksize, "Content-Type": type });
response.end(file);

Где «запрос» представляет запрос http, типом является «application / ogg» или «video / ogg» (я пробовал оба), а «file» - это файл .ogv, который был прочитан из файловой системы. Вот заголовки ответа: 

Content-Range   bytes 0-14270463/14270464
Accept-Ranges   bytes
Content-Length   14270464
Connection     keep-alive
Content-Type     video/ogg

Я изучил заголовки ответа, и этот код работает нормально, но есть пара проблем:

  1. Видео загружается очень медленно из-за нахождения в локальной сети. Из того, что я могу сказать, изучая ответ с помощью firebug, файл, кажется, передается со скоростью около 150 кбит / с.
  2. Видео не воспроизводится вообще. Даже если я подожду, пока все это загрузится, видео-тег HTML 5 просто показывает большой крестик вместо фильма в Firefox.

Есть ли у кого-нибудь идеи относительно того, что я могу сделать, чтобы потоковое видео работало через node.js?

Спасибо!
Chris

Ответы [ 7 ]

23 голосов
/ 18 мая 2012

Я знаю, что это действительно старый вопрос, но, как кажется, Google нравится, я подумал, что стоит отметить, что я написал Node.js модуль потокового видео (Github или через NPM).Надеюсь, это тоже стоит посмотреть.

18 голосов
/ 14 декабря 2010

Мне удалось заставить это работать с некоторой помощью на форумах nodejs:

http://groups.google.com/group/nodejs/browse_thread/thread/8339e0dc825c057f/822b2dd48f36e890

Основные моменты из цепочки групп Google:

Известно, что Google Chrome первым делает запрос в диапазоне 0-1024. и затем запросите диапазон "1024-".

response.end (file.slice (start, chunksize), «binary»);

Тогда:

Мне удалось заставить видео воспроизводиться без проблем в Firefox, установив заголовок «connection» для «close»

Тогда:

Похоже, вы неправильно вычислили длину содержимого:

var chunksize = (конец-начало) +1;

Если start равен 0, а end равен 1, в вашем случае chunksize равен 2, и он должен быть 1.

11 голосов
/ 10 марта 2015

Это решение выполняет асинхронное чтение видео- или аудиофайлов на стороне сервера ... оно раскручивает сервер nodejs по URL, видимому в

http://localhost:8888/

также правильно обрабатывает движения ползунка виджета пользовательского интерфейса HTML5 (браузер / приложение) на стороне клиента

сохранить приведенный ниже фрагмент кода как файл на стороне сервера: 

media_server.js

... выполнить его на стороне сервера, используя 

node media_server.js

наслаждаться 

var http = require('http'),
    fs = require('fs'),
    util = require('util');

var path = "/path/to/local/video/or/audio/file/on/server.mp4";

var port = 8888;
var host = "localhost";

http.createServer(function (req, res) {

  var stat = fs.statSync(path);
  var total = stat.size;

  if (req.headers.range) {   // meaning client (browser) has moved the forward/back slider
                                         // which has sent this request back to this server logic ... cool
    var range = req.headers.range;
    var parts = range.replace(/bytes=/, "").split("-");
    var partialstart = parts[0];
    var partialend = parts[1];

    var start = parseInt(partialstart, 10);
    var end = partialend ? parseInt(partialend, 10) : total-1;
    var chunksize = (end-start)+1;
    console.log('RANGE: ' + start + ' - ' + end + ' = ' + chunksize);

    var file = fs.createReadStream(path, {start: start, end: end});
    res.writeHead(206, { 'Content-Range': 'bytes ' + start + '-' + end + '/' + total, 'Accept-Ranges': 'bytes', 'Content-Length': chunksize, 'Content-Type': 'video/mp4' });
    file.pipe(res);

  } else {

    console.log('ALL: ' + total);
    res.writeHead(200, { 'Content-Length': total, 'Content-Type': 'video/mp4' });
    fs.createReadStream(path).pipe(res);
  }
}).listen(port, host);

console.log("Server running at http://" + host + ":" + port + "/");
5 голосов
/ 18 марта 2015

Основываясь на ответе Sam9291, я переписал функцию, используя createReadStream() и исправив некоторые проблемы: 

/**
 * Sends a static file to the HTTP client, supporting partial transfers.
 * 
 * @req HTTP request object
 * @res HTTP response object
 * @fn Path to file that should be sent
 * @contentType MIME type for the response (defaults to HTML)
 */      
function sendFile(req, res, fn, contentType) {

  contentType = contentType || "text/html";

  fs.stat(fn, function(err, stats) {
    var headers;

    if (err) {
      res.writeHead(404, {"Content-Type":"text/plain"});
      res.end("Could not read file");
      return;
    }

    var range = req.headers.range || "";    
    var total = stats.size;

    if (range) {

      var parts = range.replace(/bytes=/, "").split("-");
      var partialstart = parts[0];
      var partialend = parts[1];

      var start = parseInt(partialstart, 10);
      var end = partialend ? parseInt(partialend, 10) : total-1;

      var chunksize = (end-start)+1;

      headers = { 
        "Content-Range": "bytes " + start + "-" + end + "/" + total, 
        "Accept-Ranges": "bytes", 
        "Content-Length": chunksize, 
        "Content-Type": contentType 
      };
      res.writeHead(206, headers);

    } else {

      headers = { 
        "Accept-Ranges": "bytes", 
        "Content-Length": stats.size, 
        "Content-Type": contentType 
      };
      res.writeHead(200, headers);

    }

    var readStream = fs.createReadStream(fn, {start:start, end:end});
    readStream.pipe(res);    

  });

}
4 голосов
/ 15 августа 2013

Я использую инфраструктуру MVC sails.js поверх Node.js , и мне удалось заставить его работать нормально с помощью следующего кода: 

/**
 * VideoController
 *
 * @module      :: Controller
 * @description :: Contains logic for handling requests.
 */

 var fs = require('fs');

module.exports = {

  /* e.g.
  sayHello: function (req, res) {
    res.send('hello world!');
  }
  */

  /**
   * /video/stream
   */ 
  stream: function (req,res) {

    // This will render the view: 
    // C:\Users\sam\Documents\Dev\Fun\mymoviebank/views/video/stream.ejs
    res.view();

  },

  play: function (req,res) {

    fs.readFile('/Users/sam/Videos/big_buck_bunny.mp4', function (err, data) {
      if (err) throw err;

      var range = req.headers.range;
        var total = data.length;

        var parts = range.replace(/bytes=/, "").split("-");
        var partialstart = parts[0];
        var partialend = parts[1];

        var start = parseInt(partialstart, 10);
        var end = partialend ? parseInt(partialend, 10) : total-1;

        var chunksize = (end-start)+1;

        res.writeHead(206, { "Content-Range": "bytes " + start + "-" + end + "/" + total, "Accept-Ranges": "bytes", "Content-Length": chunksize, "Content-Type": 'video/mp4' });
        res.end(data);

    });

  }

};

Надеюсь, это поможет

3 голосов
/ 08 октября 2013

Я нашел это решение, которое кажется более простым и (в отличие от проверенного ответа) работает для меня.(Я попытался адаптировать решение coffeescript в конце этого потока, и оно как-то сработало, когда я рассмотрел тот факт, что первоначальный запрос (для "bytes = 0-") его взорвал.http://elegantcode.com/2011/04/06/taking-baby-steps-with-node-js-pumping-data-between-streams/

Моя фактическая реализация: 

function stream_response( res, file_path, content_type ){
    var readStream = fs.createReadStream(file_path);

    readStream.on('data', function(data) {
        var flushed = res.write(data);
        // Pause the read stream when the write stream gets saturated
        console.log( 'streaming data', file_path );
        if(!flushed){
            readStream.pause();
        }
    });

    res.on('drain', function() {
        // Resume the read stream when the write stream gets hungry 
        readStream.resume();
    });

    readStream.on('end', function() {
        res.end();
    });

    readStream.on('error', function(err) {
        console.error('Exception', err, 'while streaming', file_path);
        res.end();
    });

    res.writeHead(200, {'Content-Type': content_type});
}
0 голосов
/ 07 апреля 2019

при использовании Express укажите это в файле media_server.js или index.js, который будет обслуживать мультимедиа через порт 3000 

const express = require('express')
const fs = require('fs')
const path = require('path')
const app = express()

app.use(express.static(path.join(__dirname, 'public')))

app.get('/', function(req, res) {
  res.sendFile(path.join(__dirname + '/index.html'))
})

app.get('/video', function(req, res) {
  const path = 'assets/sample.mp4'// your video path
  const stat = fs.statSync(path)
  const fileSize = stat.size
  const range = req.headers.range

  if (range) {
    const parts = range.replace(/bytes=/, "").split("-")
    const start = parseInt(parts[0], 10)
    const end = parts[1]
      ? parseInt(parts[1], 10)
      : fileSize-1

    const chunksize = (end-start)+1
    const file = fs.createReadStream(path, {start, end})
    const head = {
      'Content-Range': `bytes ${start}-${end}/${fileSize}`,
      'Accept-Ranges': 'bytes',
      'Content-Length': chunksize,
      'Content-Type': 'video/mp4',
    }

    res.writeHead(206, head)
    file.pipe(res)
  } else {
    const head = {
      'Content-Length': fileSize,
      'Content-Type': 'video/mp4',
    }
    res.writeHead(200, head)
    fs.createReadStream(path).pipe(res)
  }
})

app.listen(3000, function () {
  console.log('Listening on port 3000!')
})

, а затем в ваш index.html 

<html>
  <head>
    <title>Video stream sample</title>
  </head>
  <body>
    <video id="videoPlayer" controls muted="muted" autoplay> 
      <source src="http://localhost:3000/video" type="video/mp4">
    </video>
  </body>
</html>
...