经验总结

  1. 首页 > 生活 > >

有用的内置Node.js APIs( 四 )

生活百科

方法来引发新的事件，还有一个on()方法来附加处理器 。
事件示例项目提供了一个类，该类可以在预定的时间间隔内触发一个tick事件 。./lib/ticker.js模块导出一个default class，并extends EventEmitter：
// emits a 'tick' event every intervalimport EventEmitter from 'events';import { setInterval, clearInterval } from 'timers';export default class extends EventEmitter {其constructor必须调用父构造函数 。然后传递delay参数到start()方法：
constructor(delay) {super();this.start(delay);}start()方法检查delay是否有效，如有必要会重置当前的计时器，并设置新的delay属性：
start(delay) {if (!delay || delay == this.delay) return;if (this.interval) {clearInterval(this.interval);}this.delay = delay;然后它启动一个新的间隔计时器，运行事件名称为"tick"的emit()方法 。该事件的订阅者会收到一个包含延迟值和Node.js应用程序启动后秒数的对象：
// start timerthis.interval = setInterval(() => {// raise eventthis.emit('tick', {delay:this.delay,time:performance.now()});}, this.delay);}}主event.js入口脚本导入了该模块，并设置了一秒钟的delay时段（1000毫秒） 。
// create a tickerimport Ticker from './lib/ticker.js';// trigger a new event every secondconst ticker = new Ticker(1000);它附加了每次tick事件发生时触发的处理函数：
// add handlerticker.on('tick', e => {console.log('handler 1 tick!', e);});// add handlerticker.on('tick', e => {console.log('handler 2 tick!', e);});第三个处理器仅使用once()方法对第一个tick事件进行触发：
// add handlerticker.once('tick', e => {console.log('handler 3 tick!', e);});最后，输出当前监听器的数量：
// show number of listenersconsole.log(`listeners: ${ // show number of listenersconsole.log(`listeners: ${ ticker.listenerCount('tick') }`);使用node event.js运行代码 。
输出显示处理器3触发了一次，而处理器1和2在每个tick上运行，直到应用程序被终止 。
Streams上面的文件系统示例代码在输出最小化的结果之前将整个文件读入内存 。如果文件大于可用的RAM怎么办？Node.js应用程序将以"内存不足（out of memory）"错误失败 。
解决方案是流 。这将在更小、更容易管理的块中处理传入的数据 。流可以做到：

  • 可读：从文件、HTTP请求、TCP套接字、标准输入等读取 。
  • 可写：写入到文件、HTTP响应、TCP套接字、标准输出等 。
  • 双工：既可读又可写的流 。
  • 转换：转换数据的双工流 。
每块数据都以Buffer对象的形式返回，它代表一个固定长度的字节序列 。你可能需要将其转换为字符串或其他适当的类型进行处理 。
该示例代码有一个filestream项目，它使用一个转换流来解决filecompress项目中的文件大小问题 。和以前一样，它在声明一个继承Transform的Compress类之前，接受并验证了输入和输出的文件名：
import { createReadStream, createWriteStream } from 'fs';import { Transform } from 'stream';// compression Transformclass Compress extends Transform {constructor(opts) {super(opts);this.chunks = 0;this.lengthOrig = 0;this.lengthNew = 0;}_transform(chunk, encoding, callback) {constdata = https://www.huyubaike.com/biancheng/chunk.toString(),// buffer to stringcontent = data.replace(/n/s+/g,'\n')// trim leading spaces.replace(/\/\/.*?\n/g, '')// remove // comments.replace(/\s+/g, ' ')// remove whitespace.replace(/\/\*.*?\*\//g, '')// remove /* comments */.replace(/<!--.*?-->/g, '')// remove <!-- comments -->.replace(/\s*([<>(){}}[\]])\s*/g, '$1') // remove bracket spaces.trim();this.chunks++;this.lengthOrig += data.length;this.lengthNew += content.length;this.push( content );callback();}}

经验总结扩展阅读


上一篇：老鼠屎是硬的还是软的

下一篇：2023年9月20日适合招聘吗 2023年9月20日招聘行吗