脚本之家 服务器常用软件
快捷导航
您的位置：首页 → 网络编程 → JavaScript → javascript技巧 → Egg.js构建stream流式接口服务

Egg.js构建一个stream流式接口服务实现详解

 更新时间：2023年09月20日 14:15:34   作者：天問  
这篇文章主要为大家介绍了Egg.js构建一个stream流式接口服务实现详解，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪

引言

经常需要用到 stream 流式接口服务,比如：大文件下载、日志实时输出等等。本文将介绍如何使用Egg.js构建一个 stream 流式接口服务。

Egg.js Stream API

一、准备工作

目录结构：

app/
    /controller
        index.js
        test.txt
        test.sh
  • index.js 控制器
  • test.txt 测试文件，最好是20M以上的文件，这样才能看出流式返回的效果
  • test.sh 测试脚本，用于实时输出日志的测试脚本

二、流式文件处理

  • controller/index.js 文件内容如下：
'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 文件内容如下：
'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 文件内容如下：
#!/usr/bin/env sh
set -e
int=1
while(( $int<=10 ))
do
    echo $int
    sleep 2
    let "int++"
done

四、测试

前端使用 fetch 方法进行测试，为什么不用 axios ?因为 axios 是基于 XMLHttpRequest 的，不支持流式接口。 具体实现请参考：前端实现 stream 流式请求

以上就是Egg.js构建一个stream流式接口服务实现详解的详细内容，更多关于Egg.js构建stream流式接口服务的资料请关注脚本之家其它相关文章！

您可能感兴趣的文章:

相关文章

最新评论