nodejs fs.readStram.on 的用法
时间: 2023-12-19 16:06:38 浏览: 31
`fs.createReadStream()` 方法返回一个可读流,可以使用 `.on()` 方法来监听流事件,例如:
```javascript
const fs = require('fs');
const rs = fs.createReadStream('/path/to/file');
rs.on('open', () => {
console.log('文件已打开');
});
rs.on('data', (chunk) => {
console.log(`接收到 ${chunk.length} 个字节的数据`);
});
rs.on('end', () => {
console.log('数据已全部接收完毕');
});
rs.on('close', () => {
console.log('文件已关闭');
});
rs.on('error', (err) => {
console.error(err);
});
```
在上述代码中,我们使用 `fs.createReadStream()` 方法创建了一个可读流,并使用 `.on()` 方法监听了 `open`、`data`、`end`、`close` 和 `error` 事件。当这些事件触发时,对应的回调函数将会执行。注意,在监听 `data` 事件时,回调函数的参数是一个数据块(Buffer 类型),而不是完整的数据流。
相关问题
nodejs fs.createReadStream
`fs.createReadStream()` 是 Node.js 中的一个内置模块,用于创建可读流以从文件中读取数据。它接受一个文件路径作为参数,返回一个可读流对象。
下面是一个使用 `fs.createReadStream()` 读取文件并输出文件内容的例子:
```
const fs = require('fs');
// 创建可读流
const readStream = fs.createReadStream('/path/to/file');
// 读取文件内容并输出
readStream.on('data', (chunk) => {
console.log(chunk.toString());
});
// 处理读取完成事件
readStream.on('end', () => {
console.log('文件读取完成');
});
// 处理错误事件
readStream.on('error', (err) => {
console.error('文件读取错误:', err);
});
```
在上面的例子中,我们创建了一个可读流对象 `readStream`,并通过监听其 `data` 事件来读取文件内容。当文件读取完成时,我们监听 `end` 事件进行处理。如果在读取过程中出现错误,我们监听 `error` 事件进行处理。
nodejs fs.watch
`fs.watch`是Node.js中的一个API,用于监视文件或目录的更改。它可以用于实时检测文件或目录的变化,例如新增、删除、修改等操作。当文件或目录发生变化时,`fs.watch`会触发一个change事件,可以在事件回调函数中处理相应的逻辑。需要注意的是,`fs.watch`不一定适用于所有操作系统,有些操作系统可能会有限制或不支持此功能。在使用时需要注意操作系统的兼容性。