Node js - send and receive a video



I want to send a YouTube video which is converted in my API node js with ytdl-core to my client for downloading it.It works if I use a navigator for ask to my API but I can't download when I use my client.

The two way I tried:

video.pipe(reponse);

I receive something like that:
§W��JXIn�!�↓#�▲If�Z2��Y�F∟��6�♠♂4�o�C4�-KeoX�@↔;#%◄Z↔¶������cl�N♦�5Z8��Ζ��↓��fƦ�P¤�{P�◄�ټ�֩��S��ŗ�Z�↑����.�☻j��G�▬�L�2�ލ▬�|�T�w<�¶☺�☼!zTMʌ��� L#n=♠V♣nMT�֑zr☺��o�l���↕�iʮ��♫�3���W�lK���x}��7↨4q�zV��5kB��a�m��∟y◄��Xx5�l�OYkFX?�9s��g�♫���0St��#$4#4�+�J���♂U◄Ĺ;Á�♀Qž?R߈/��˽}KeoX�@↔�!b�k�u�RhĀR▼$��b�0�ɉIi %�Es�&�u���dvK♥g→E☻ .��ݒ����}�[∟��♣;☼=f� ....or

reponse.status(200).send(video);

I receive that:

{
_readableState: {
objectMode: false,
highWaterMark: 524288,
buffer: { head: null, tail: null, length: 0 },
length: 0,
pipes: [],
flowing: null,
ended: false,
endEmitted: false,
reading: false,
constructed: true,
sync: false,
needReadable: false,
emittedReadable: false,
readableListening: false,
resumeScheduled: false,
errorEmitted: false,
emitClose: true,
autoDestroy: true,
destroyed: false,
errored: null,
closed: false,
closeEmitted: false,
defaultEncoding: 'utf8',
awaitDrainWriters: null,
multiAwaitDrain: false,
readingMore: false,
dataEmitted: false,
decoder: null,
encoding: null
},
_events: {},
_eventsCount: 1,
_writableState: {
objectMode: false,
highWaterMark: 524288,
finalCalled: false,
needDrain: false,
ending: false,
ended: false,
finished: false,
destroyed: false,
decodeStrings: true,
defaultEncoding: 'utf8',
length: 0,
writing: false,
corked: 0,
sync: true,
bufferProcessing: false,
writecb: null,
writelen: 0,
afterWriteTickInfo: null,
buffered: [],
bufferedIndex: 0,
allBuffers: true,
allNoop: true,
pendingcb: 0,
constructed: true,
prefinished: false,
errorEmitted: false,
emitClose: true,
autoDestroy: true,
errored: null,
closed: false,
closeEmitted: false
},
allowHalfOpen: true
}
[nodemon] restarting due to changes...
[nodemon] starting `node index.js`
server started ! : port 5000
{
_readableState: {
objectMode: false,
highWaterMark: 524288,
buffer: { head: null, tail: null, length: 0 },
length: 0,
pipes: [],
flowing: null,
ended: false,
endEmitted: false,
reading: false,
constructed: true,
sync: false,
needReadable: false,
emittedReadable: false,
readableListening: false,
resumeScheduled: false,
errorEmitted: false,
emitClose: true,
autoDestroy: true,
destroyed: false,
errored: null,
closed: false,
closeEmitted: false,
defaultEncoding: 'utf8',
awaitDrainWriters: null,
multiAwaitDrain: false,
readingMore: false,
dataEmitted: false,
decoder: null,
encoding: null
},
_events: {},
_eventsCount: 1,
_writableState: {
objectMode: false,
highWaterMark: 524288,
finalCalled: false,
needDrain: false,
ending: false,
ended: false,
finished: false,
destroyed: false,
decodeStrings: true,
defaultEncoding: 'utf8',
length: 0,
writing: false,
corked: 0,
sync: true,
bufferProcessing: false,
writecb: null,
writelen: 0,
afterWriteTickInfo: null,
buffered: [],
bufferedIndex: 0,
allBuffers: true,
allNoop: true,
pendingcb: 0,
constructed: true,
prefinished: false,
errorEmitted: false,
emitClose: true,
autoDestroy: true,
errored: null,
closed: false,
closeEmitted: false
},
allowHalfOpen: true
}

I don't know how to down load it because pipe don't work when I receive the 2 answers.

then, try the following:

$ npm init
$ sudo apt install youtube-dl
$ sudo apt install ffmpeg
$ npm install shelljs;
$ npm install -g shelljs;
&lt;!DOCTYPE html>
<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 {
margin: 5% auto;
max-width: 100%;
background-color: rgb(14, 14, 14);
padding-top: 10%;
padding-left: 35%;
}
</style>
</head>
<body>
<video id="videoPlayer" width="50%" controls muted="muted" autoplay>
<source src="/video" type="video/mp4" />
</video>
</body>
</html>
const shx = require('shelljs');
shx.exec("youtube-dl rtsp://wowzaec2demo.streamlock.net/vod/mp4:BigBuckBunny_115k.mov?random=" + Math.random());
// *********************************************** //
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 express = require("express");
const app = express();
const fs = require("fs");
app.get("/", function (req, res) {
res.sendFile(__dirname + "/index.html");
});
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;
});
app.listen(8000, function () {
console.log("Listening on port 8000!");
});
// *********************************************** //
const CHUNK_SIZE = 10 ** 6; // 1MB
const start = Number(range.replace(/D/g, ""));
// *********************************************** //
const start = Number(range.replace(/D/g, ""));
// *********************************************** //
const end = Math.min(start + CHUNK_SIZE, videoSize - 1);
// *********************************************** //
const headers = {
"Content-Range": `bytes ${start}-${end}/${videoSize}`,
... // this ... just indicates that there is more code here. 
// it is not part of code.
}
// *********************************************** //
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);
// *********************************************** //
const videoStream = fs.createReadStream(videoPath, { start, end });
// *********************************************** //
videoStream.pipe(res);
// *********************************************** //
const end = Math.min(start + CHUNK_SIZE, videoSize - 1);
const contentLength = end - start + 1;
const headers = {
"Content-Range": `bytes ${start}-${end}/${videoSize}`,
"Accept-Ranges": "bytes",
"Content-Length": contentLength,
"Content-Type": "video/mp4",
};
res.writeHead(206, headers);
const videoStream = fs.createReadStream(videoPath, { start, end });
videoStream.pipe(res);
});
app.listen(8000, function () {
console.log("Listening on port 8000!");
});
const end = Math.min(start + CHUNK_SIZE, videoSize - 1);
const contentLength = end - start + 1;
const headers = {
"Content-Range": `bytes ${start}-${end}/${videoSize}`,
"Accept-Ranges": "bytes",
"Content-Length": contentLength,
"Content-Type": "video/mp4",
};
res.writeHead(206, headers);
const videoStream = fs.createReadStream(videoPath, { start, end });
videoStream.pipe(res);
});
app.listen(8000, function () {
console.log("Listening on port 8000!");
});
// *********************************************** //
"scripts": {
"start": "nodemon index.js" //this is the main line you need to add
},
//note that the index.js is just the name of my file. yours might be named differently

if you want the full reply, here you have it:

  • https://blog.logrocket.com/build-video-streaming-server-node/

You can usegstreamnodejs/npm integration.

Installation:

sudo apt-get install gstreamer-tools
npm install gstreamer

Example:

var gstreamer = require("../");

gstreamer.start({
url: "rtsp://wowzaec2demo.streamlock.net/vod/mp4:BigBuckBunny_115k.mov?random=" + Math.random(),
//url: "rtsp://192.168.1.92:554//1",
port: 80,
quiet: false
});

最新更新