“Streams are Node’s best and most misunderstood idea.”
— Dominic Tarr
大家好,我是曲靈風(fēng)乒躺,這段時間看node stream的東西勺三,想通過stream做一玩意兒,最后搞了一個視頻站的東西(手機(jī)排版沒做好,電腦排版還可以)悲没。
先聲明一下,這里用到的技術(shù)有點多男图,因為本文是針對stream的示姿,其他的東西會一筆帶過,涉及到流的東西會詳細(xì)逊笆。
上正文栈戳,想必大家都知道,使用流的兩大優(yōu)勢是
- 處理大量數(shù)據(jù)难裆。
- 組合代碼子檀,例如使用pipe。
這里的具體解釋可以查看參考資料
的 Node.js Streams: Everything you need to know乃戈。
既然stream可以處理大量數(shù)據(jù)褂痰,那么處理視頻這樣的文件就可以使用stream。
先看app.js
var express = require('express');
var app = express();
var port = process.env.PORT || 3000;
app.set('views', __dirname + '/views');
app.set('view engine', 'ejs');
app.use(require('./controllers'));
app.listen(port, function () {
console.log('listen to port:' + port);
});
獲取了一個應(yīng)用程序?qū)嵗齛pp(相當(dāng)于new一個應(yīng)用程序?qū)嵗?症虑;
設(shè)置模板文件存放的目錄缩歪;
設(shè)置模板引擎為ejs
;
路由在app.use(require('./controllers'))
設(shè)置谍憔;
最后監(jiān)聽端口匪蝙。
具體程序應(yīng)用框架的架構(gòu)可以參考我的文章
通過express實現(xiàn)一個簡單的MVC
通過路由到達(dá)文件movie.js
var express = require('express');
var router = express.Router();
var fs = require('fs');
router.get('/', function(req, res){
var path = 'video/shanghaiTan.mp4';
var stat = fs.statSync(path);
var fileSize = stat.size;
var range = req.headers.range;
var parts = range.replace(/bytes=/, "").split("-")
var start = parseInt(parts[0], 10);
var end = parts[1] ? parseInt(parts[1], 10) : fileSize - 1;
var chunksize = (end-start) + 1;
var file = fs.createReadStream(path, {start, end})
var head = {
'Content-Range': `bytes ${start}-${end}/${fileSize}`,
'Accept-Ranges': 'bytes',
'Content-Length': chunksize,
'Content-Type': 'video/mp4',
}
res.writeHead(206, head);
file.pipe(res);
});
module.exports = router;
這里是stream主要應(yīng)用的地方主籍,通過使用stream,使得每次發(fā)送數(shù)據(jù)是一塊一塊的骗污,而并非一下子把所有的數(shù)據(jù)發(fā)送的前端崇猫。
bootstrap請求視頻默認(rèn)是Content-Range的方式,這是種部分請求的方式需忿,針對范圍請求诅炉,響應(yīng)會返回狀態(tài)碼為 206 Partial Content 的響應(yīng)報文,見下圖所示屋厘。
因為rander的格式是Range: bytes = 0 -
涕烧,因此通過字符串的處理可以獲取相應(yīng)信息,從而構(gòu)建響應(yīng)頭汗洒。
最后通過可讀流的pipe方法寫到可寫流(response對象中)议纯。
所有流都是事件(EventEmitter)的實例,因此可以監(jiān)聽事件溢谤。而pipe方法的實現(xiàn)原理是就是通過對data
和end
事件的監(jiān)聽獲取數(shù)據(jù)的瞻凤,其中pipe還利用了后壓機(jī)制,是流比較好的實現(xiàn)方式世杀。
其實為了做這個東西阀参,著實是踩了不少坑,例如:
- 訪問服務(wù)器端口不成功瞻坝,在知乎上問問題蛛壳。
-
'Content-Type': 'video/mp4'
,這里的設(shè)置只會播放mp4中編碼是H.264
所刀,其他編碼視頻可能不顯示衙荐。
詳細(xì)的問題,最后通過網(wǎng)上的一個Node依賴實現(xiàn)的浮创。 - bootstrap也是第一次使用忧吟,也踩了不少坑??。
希望各位看官不要再掉坑里了斩披,最后獎勵自己一朵小紅花??瀑罗。
參考資料
Node.js Streams: Everything you need to know
Video stream with Node.js and HTML5
Basic use of Node.js streams
Node.js Streams by Example