Node.js实战对于Buffer和Stream模块系统的深入剖析

简介: Node.js实战对于Buffer和Stream模块系统的深入剖析

Buffer 缓冲区

在这里插入图片描述

JavaScript语言本身只有字符串数据类型,没有二进制数据类型。
但是,在处理TCP流或文件流时必须使用二进制数据。
因此,在node JS中,定义了一个缓冲区类来创建用于存储二进制数据的缓冲区。

const buf = Buffer.from('runoob', 'ascii');

在node JS中,缓冲区类是与node内核一起发布的核心库。
缓冲库是node JS带来的一种存储原始数据的方法,它允许节点JS。

console.log(buf.toString('hex'));
console.log(buf.toString('base64'));

原始数据存储在buffer类的实例中。缓冲区类似于整数数组,但它对应于V8堆内存之外的一段原始内存。

写入缓冲区

写入 Node 缓冲区的语法如下所示:

buf.write(string[, offset[, length]][, encoding])
  • string - 写入缓冲区的字符串。
  • offset - 缓冲区开始写入的索引值,默认为 0 。
  • length - 写入的字节数,默认为 buffer.length
  • encoding - 使用的编码。默认为 'utf8' 。
buf = Buffer.alloc(256);
len = buf.write("www.runoob.com");

console.log("写入字节数 : "+  len);

输出为:

$node main.js
写入字节数 : 14

buf.write(string[, offset[, length]][, encoding])
根据参数偏移量和指定的编码方法将参数字符串数据写入缓冲区。偏移量的默认值为0,默认编码方法为utf8。
长度是要写入的字符串的字节大小。返回数字类型,指示写入了多少8位字节流。
如果缓冲区没有足够的空间容纳整个字符串,它将只写入部分字符串。默认情况下,长度是缓冲区长度-偏移量此方法似乎无法写入某些字符。

buf.writeDoubleBE(value, offset[, noAssert])
根据传递的偏移量和指定的endian格式将值写入缓冲区。
注意:值必须是有效的64位双精度值。如果参数noassert为真,则不会验证值和偏移参数。
这意味着该值可能太大,或者偏移量可能超过缓冲区的末尾,从而导致丢弃该值。
默认值为false。

从流中读取数据

var fs = require("fs");
var data = '';

创建可读流

var readerStream = fs.createReadStream('input.txt');

设置编码为 utf8。

readerStream.setEncoding('UTF8');

处理流事件 --> data, end, and error

readerStream.on('data', function(chunk) {
   data += chunk;
});
readerStream.on('end',function(){
   console.log(data);
});

readerStream.on('error', function(err){
   console.log(err.stack);
});

console.log("程序执行完毕");

管道流

管道为输出流到输入流提供了一种机制。通常我们使用它从一个流中获取数据并将其传递给另一个流。
创建一个可读流

var readerStream = fs.createReadStream('input.txt');

创建一个可写流

var writerStream = fs.createWriteStream('output.txt');

管道读写操作,读取 input.txt 文件内容,并将内容写入到 output.txt 文件中。

readerStream.pipe(writerStream);

链式流

链接是一种将输出流连接到另一个流并创建多个流操作链的机制。链流通常用于管道操作。
接下来,我们使用管道和链来压缩和解压缩文件。

var fs = require("fs");
var zlib = require('zlib');

压缩 input.txt 文件为 input.txt.gz

fs.createReadStream('input.txt')
  .pipe(zlib.createGzip())
  .pipe(fs.createWriteStream('input.txt.gz'));

执行上述操作后,我们可以看到输入Txt压缩文件input.Txt.gz。
接下来,让我们解压文件并创建解压JS文件,代码如下:

var fs = require("fs");
var zlib = require('zlib');

解压 input.txt.gz 文件为 input.txt

fs.createReadStream('input.txt.gz')
  .pipe(zlib.createGunzip())
  .pipe(fs.createWriteStream('input.txt'));

模块系统

以便启用节点的文件。js相互调用,节点。js提供了一个简单的模块系统。
模块是JS应用程序的基本组件,文件和模块是一一对应的。
换句话说,node JS文件是一个模块。该文件可以是JavaScript代码、JSON或编译的C/C++扩展。
hello.js

function Hello() { 
    var name; 
    this.setName = function(thyName) { 
        name = thyName; 
    }; 
    this.sayHello = function() { 
        console.log('Hello ' + name); 
    }; 
}; 

模块接口中唯一的变化是使用模块Exports=Hello,而不是Exports world=function(){}
当模块被外部引用时,其接口对象是要输出的Hello对象本身,而不是原始导出。

var Hello = require('./hello'); 
hello = new Hello(); 
hello.setName('BYVoid'); 
hello.sayHello(); 

在这里插入图片描述

相关文章
|
JavaScript 前端开发
在Node.js中,如何合理使用模块来避免全局变量的问题?
在Node.js中,如何合理使用模块来避免全局变量的问题?
654 167
|
人工智能 自然语言处理 JavaScript
通义灵码2.5实战评测:Vue.js贪吃蛇游戏一键生成
通义灵码基于自然语言需求,快速生成完整Vue组件。例如,用Vue 2和JavaScript实现贪吃蛇游戏:包含键盘控制、得分系统、游戏结束判定与Canvas动态渲染。AI生成的代码符合规范,支持响应式数据与事件监听,还能进阶优化(如增加启停按钮、速度随分数提升)。传统需1小时的工作量,使用通义灵码仅10分钟完成,大幅提升开发效率。操作简单:安装插件、输入需求、运行项目即可实现功能。
688 4
 通义灵码2.5实战评测:Vue.js贪吃蛇游戏一键生成
|
JavaScript Linux 内存技术
Debian 11系统下Node.js版本更新方法详解
本指南详细介绍在Linux系统中安装和管理Node.js的步骤。首先检查现有环境,包括查看当前版本和清除旧版本;接着通过NodeSource仓库安装最新版Node.js并验证安装结果。推荐使用nvm(Node Version Manager)进行多版本管理,便于切换和设置默认版本。同时,提供常见问题解决方法,如权限错误处理和全局模块迁移方案,以及版本回滚操作,确保用户能够灵活应对不同需求。
1653 0
|
JavaScript Linux 内存技术
Debian 11系统下Node.js版本更新方法
Debian 11更新Node.js主要就是这三种方式,无论你是初涉其中的新手还是找寻挑战的专家,总有一种方式能满足你的需求。现在,你已经是这个
1667 80
|
11月前
|
JavaScript 前端开发 安全
【逆向】Python 调用 JS 代码实战:使用 pyexecjs 与 Node.js 无缝衔接
本文介绍了如何使用 Python 的轻量级库 `pyexecjs` 调用 JavaScript 代码,并结合 Node.js 实现完整的执行流程。内容涵盖环境搭建、基本使用、常见问题解决方案及爬虫逆向分析中的实战技巧,帮助开发者在 Python 中高效处理 JS 逻辑。
|
JavaScript 前端开发 算法
流量分发代码实战|学会用JS控制用户访问路径
流量分发工具(Traffic Distributor),又称跳转器或负载均衡器,可通过JavaScript按预设规则将用户随机引导至不同网站,适用于SEO优化、广告投放、A/B测试等场景。本文分享一段不到百行的JS代码,实现智能、隐蔽的流量控制,并附完整示例与算法解析。
434 1
|
JavaScript 前端开发 开发者
Node学习笔记:HTTP模块
总的来说,Node.js的HTTP模块是一个强大的工具,可以帮助你处理HTTP协议的各种需求。无论你是想开设自己的餐厅(创建服务器),还是想去别的餐厅点菜(发出请求),HTTP模块都能满足你的需求。
417 18
|
SQL JavaScript 安全
【04】Java+若依+vue.js技术栈实现钱包积分管理系统项目-若依框架二次开发准备工作-以及建立初步后端目录菜单列-优雅草卓伊凡商业项目实战
【04】Java+若依+vue.js技术栈实现钱包积分管理系统项目-若依框架二次开发准备工作-以及建立初步后端目录菜单列-优雅草卓伊凡商业项目实战
709 11
【04】Java+若依+vue.js技术栈实现钱包积分管理系统项目-若依框架二次开发准备工作-以及建立初步后端目录菜单列-优雅草卓伊凡商业项目实战
|
JavaScript 前端开发 数据可视化
【01】Cocos游戏开发引擎从0开发一款游戏-cocos环境搭建以及配置-Cocos Creator软件系统下载安装-node环境-优雅草卓伊凡
【01】Cocos游戏开发引擎从0开发一款游戏-cocos环境搭建以及配置-Cocos Creator软件系统下载安装-node环境-优雅草卓伊凡
1122 2
【01】Cocos游戏开发引擎从0开发一款游戏-cocos环境搭建以及配置-Cocos Creator软件系统下载安装-node环境-优雅草卓伊凡
|
监控 JavaScript 前端开发
MutationObserver详解+案例——深入理解 JavaScript 中的 MutationObserver:原理与实战案例
MutationObserver 是一个非常强大的 API,提供了一种高效、灵活的方式来监听和响应 DOM 变化。它解决了传统 DOM 事件监听器的诸多局限性,通过异步、批量的方式处理 DOM 变化,大大提高了性能和效率。在实际开发中,合理使用 MutationObserver 可以帮助我们更好地控制 DOM 操作,提高代码的健壮性和可维护性。 只有锻炼思维才能可持续地解决问题,只有思维才是真正值得学习和分享的核心要素。如果这篇博客能给您带来一点帮助,麻烦您点个赞支持一下,还可以收藏起来以备不时之需,有疑问和错误欢迎在评论区指出~
MutationObserver详解+案例——深入理解 JavaScript 中的 MutationObserver:原理与实战案例

热门文章

最新文章