Egg.js構(gòu)建一個stream流式接口服務(wù)實現(xiàn)詳解
引言
經(jīng)常需要用到 stream 流式接口服務(wù),比如:大文件下載、日志實時輸出等等。本文將介紹如何使用Egg.js構(gòu)建一個 stream 流式接口服務(wù)。
Egg.js Stream API
一、準備工作
目錄結(jié)構(gòu):
app/
/controller
index.js
test.txt
test.sh- index.js 控制器
- test.txt 測試文件,最好是20M以上的文件,這樣才能看出流式返回的效果
- test.sh 測試腳本,用于實時輸出日志的測試腳本
二、流式文件處理
controller/index.js文件內(nèi)容如下:
'use strict';
const Controller = require('egg').Controller;
const { createReadStream } = require('fs');
const { join } = require('path');
class HomeController extends Controller {
async testStream() {
const { ctx } = this;
ctx.set('Content-Type', 'text/plain; charset=utf-8');
const stream = createReadStream(join(__dirname, './test.txt'));
ctx.body = stream;
}
}
module.exports = HomeController;三、流式日志處理
controller/index.js文件內(nèi)容如下:
'use strict';
const Controller = require('egg').Controller;
const { createReadStream } = require('fs');
const { join } = require('path');
const { spawn } = require('child_process');
class HomeController extends Controller {
async testStream() {
ctx.set('Content-Type', 'text/plain; charset=utf-8');
const shPath = join(__dirname, './test.sh');
const stream = spawn('sh', [ shPath ]);
ctx.body = stream.stdout;
}
}
module.exports = HomeController;controller/test.sh文件內(nèi)容如下:
#!/usr/bin/env sh
set -e
int=1
while(( $int<=10 ))
do
echo $int
sleep 2
let "int++"
done四、測試
前端使用 fetch 方法進行測試,為什么不用 axios ?因為 axios 是基于 XMLHttpRequest 的,不支持流式接口。 具體實現(xiàn)請參考:前端實現(xiàn) stream 流式請求
以上就是Egg.js構(gòu)建一個stream流式接口服務(wù)實現(xiàn)詳解的詳細內(nèi)容,更多關(guān)于Egg.js構(gòu)建stream流式接口服務(wù)的資料請關(guān)注腳本之家其它相關(guān)文章!
相關(guān)文章
JavaScript 實現(xiàn)自己的安卓手機自動化工具腳本(推薦)
這篇文章主要介紹了 JavaScript 實現(xiàn)自己的安卓手機自動化工具腳本,本文給大家介紹的非常詳細,對大家的學(xué)習(xí)或工作具有一定的參考借鑒價值,需要的朋友可以參考下2020-05-05
javascript 用函數(shù)語句和表達式定義函數(shù)的區(qū)別詳解
本篇文章主要介紹了javascript 用函數(shù)語句和表達式定義函數(shù)的區(qū)別。需要的朋友可以過來參考下,希望對大家有所幫助2014-01-01
js循環(huán)中使用正則失效異常的踩坑實戰(zhàn)
這篇文章主要給大家介紹了關(guān)于js循環(huán)中使用正則失效異常的踩坑實戰(zhàn),文中通過實例代碼介紹的非常詳細,對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友可以參考下2023-05-05

