express readline 返回逐行文件数据，fetch如何接收，求助大佬们

问答

Aassmdx发布于 6 年前最后回复 6 年前

454840

	//服务端处理请求的代码: 
	 const fs = require('fs');
	 const readline = require('readline');
	 async getLog(req, res) {
	  const _this = this;
	  try {
		const { createReadStream } = fs;
		const log = '/opt/example.log'; // log 大小：40MB
		const readStream = createReadStream(log);
		const rl = readline.createInterface(readStream, res);
		rl.on("close", () => {
		  console.log("end");
		  readStream.close();
		  res.end();
		});
	  } catch (e) {
		logger.error("获取log失败", e);
		res.json(_this.fail(ERROR_PARAMETER, "获取日志失败，请稍后重试"));
	  }
	}

//浏览器fetch代码：
fetch(getLog)
    .then(async response => {
      const reader = response.body.getReader();
      do {
        let { done, value } = await reader.read();
        console.log(value);  //这里获取的只有一个undefined
        if (done) {
          break;
        }
      } while (true);
    })
    .catch(e => {
      console.error(e);
    });

查看回复

assmdx#16 年前

倒腾了半天终于解决了

	const fs = require('fs');
	 const readline = require('readline');
	 async getLog(req, res) {
	  const _this = this;
	  try {
		const { createReadStream } = fs;
		const log = '/opt/example.log'; // log 大小：40MB
		const readStream = createReadStream(log);
		readStream.pipe(res);
        readStream.on("end", () => {
           console.log("finished");
           res.end();
        });
	  } catch (e) {
		logger.error("获取log失败", e);
		res.json(_this.fail(ERROR_PARAMETER, "获取日志失败，请稍后重试"));
	  }
	}

   async queryLog() {
      let logs = "";
      fetch(getLog)
        .then(async response => {
          const reader = response.body.getReader();
          const decoder = new TextDecoder();
          do {
            let { done, value } = await reader.read();
            if (value) {
              let str = decoder.decode(value, { stream: true });
              logs = logs + str;
            }
            if (done) {
              break;
            }
          } while (true);
        })
        .catch(e => {
          console.error(e);
        });
    }

i5ting#26 年前

去理解一下异步流程控制

assmdx#36 年前

引用 i5ting去理解一下异步流程控制

@i5ting 感谢狼叔指点. 还有更高效优雅的写法吗 0.0？把浏览器端代码优化了一下：

	async queryLog() {
      let index = 0;
	  let logs = "";
      let response = await fetch(getLog);
      const reader = response.body.getReader();
      const decoder = new TextDecoder();
      do {
        let { done, value } = await reader.read();
        if (value) {
          let str = decoder.decode(value, { stream: true });
          logs = logs + str;
        }
        if (done) {
          break;
        }
      } while (true);
    }

cctv1005s#46 年前

引用 assmdx@i5ting 感谢狼叔指点. 还有更高效优雅的写法吗 0.0？把浏览器端代码优化了一下：

@assmdx 有，用 eventemitter 来搞

参与回复

登录后即可参与回复。登录

express readline 返回逐行文件数据，fetch如何接收，求助大佬们

回复 (4)

参与回复