fs.createwritestream start不起作用
时间: 2024-06-03 16:08:14 浏览: 88
在使用`fs.createWriteStream`时,`start`参数用于指定写入文件的起始位置,但是它只在以下情况下起作用:
1. 如果文件已经存在,且`start`大于0,则从指定位置开始写入;
2. 如果文件不存在,则从头开始写入。
如果`start`不起作用,可能是以下原因:
1. `start`参数的值小于等于0,导致从文件头开始写入;
2. 文件已经存在,但是`start`参数的值大于等于文件大小,导致写入位置超出文件末尾;
3. 文件不存在,但是指定了`start`参数,导致无法从指定位置开始写入。
解决方法:
1. 确保`start`参数的值大于0;
2. 确保`start`参数的值小于文件大小,或者不指定`start`参数;
3. 确保文件存在,或者不指定`start`参数。
相关问题
fs.createwritestream并用到start
fs.createWriteStream()方法可以创建一个可写流,可以往其中写入数据并将其保存到指定的文件中。start参数是可选参数,用于指定从文件的哪个位置开始写入数据。
例如,以下代码创建了一个可写流,将数据写入example.txt文件中,并从文件的第10个字节开始写入数据:
```
const fs = require('fs');
const writeStream = fs.createWriteStream('example.txt', { start: 10 });
writeStream.write('Hello, world!');
writeStream.end();
```
注意,如果指定的start值大于文件的实际大小,则会创建一个空文件,并从指定位置开始写入数据。如果start值不是整数,则会被截断为整数。如果不指定start值,则默认从文件的开头开始写入数据。
for (var i=0;i<dataArray.length;i++) { var timenow=Date.now();//调用的时候,打个时间戳 const options = { directory: downloadPath, filename: dataArray[i].title + '.' + dataArray[i].fileType, saveAs: false, extension: dataArray[i].fileType, openFolderWhenDone: false, showProgressBar: true, showBadge: true, }; var downloader = new Downloader(dataArray[i], options); downloader.data.timeid=timenow;//存储唯一标识 downloader.start(); downloader.onStart = () => { // 下载开始 handleDownload.push(downloader); mainWindow.webContents.send('consolelog2', '检查代码在此执行次数'); }; downloader.onTotalProgress = (progress) => { // 更新下载进度 downloadArray.set(downloader.data.timeid, { title: downloader.data.title, sUrl: downloader.data.sUrl, progress: downloader.data.progress, size: downloader.data.size, status:downloader.data.status, timeid:downloader.data.timeid }); mainWindow.webContents.send('consolelog', downloadArray); mainWindow.webContents.send('donwloadStatus', true); }; downloader.onCompleted = () => { if(downloader.data.progress==100&&downloader.data.status=='process'){ mainWindow.webContents.send('endDownload', JSON.stringify(downloader)); mainWindow.webContents.send('donwloadStatus', false); downloader.data.status='complete' } if(downloader.data.progress<100){ mainWindow.webContents.send('donwloadStatus', true); } mainWindow.webContents.send('consolelog', downloadArray); }; } return JSON.stringify(dataArray); // 返回值将作为 Promise 的 resolved 值 }); 这段代码中,如果我是多个下载器,var downloader = new Downloader(dataArray[i], options); 这里就会导致重复创建一个名字的下载,导致我操作 downloader.start(); 的时候,会触发多个下载器的 start ,我要怎么优化。把下载器分离出独立
可以将 Downloader 类提取出来,单独作为一个模块,然后在循环中实例化多个 Downloader 对象,这样就可以避免重复创建相同名字的下载器。示例代码如下:
1. 创建 Downloader 类的模块 downloader.js:
```javascript
const request = require('request');
const fs = require('fs');
const path = require('path');
class Downloader {
constructor(data, options) {
this.data = data;
this.options = options;
this.req = null; // request 对象
this.writeStream = null; // 文件写入流
}
start() {
const { sUrl } = this.data;
const { directory, filename, saveAs, extension } = this.options;
const filePath = path.join(directory, saveAs ? filename : `${Date.now()}.${extension}`);
this.writeStream = fs.createWriteStream(filePath);
this.req = request
.get(sUrl)
.on('error', (err) => {
console.error(`请求 ${sUrl} 出错:${err.message}`);
this.data.status = 'failed';
})
.on('response', (response) => {
if (response.statusCode === 200) {
this.data.size = parseInt(response.headers['content-length'], 10);
} else {
this.data.status = 'failed';
}
})
.on('data', (chunk) => {
this.writeStream.write(chunk);
this.data.progress = (this.writeStream.bytesWritten / this.data.size) * 100;
})
.on('end', () => {
this.writeStream.end();
this.data.progress = 100;
this.data.status = 'complete';
});
}
pause() {
if (this.req) {
this.req.pause();
}
if (this.writeStream) {
this.writeStream.close();
}
}
resume() {
this.start();
}
cancel() {
this.pause();
const { directory, saveAs, extension } = this.options;
const filePath = path.join(directory, saveAs ? this.data.filename : `${Date.now()}.${extension}`);
fs.unlink(filePath, (err) => {
if (err) {
console.error(`删除文件 ${filePath} 出错:${err.message}`);
}
});
}
}
module.exports = Downloader;
```
2. 修改原来的代码,引入 downloader.js 模块,并实例化多个 Downloader 对象:
```javascript
const Downloader = require('./downloader');
...
for (let i = 0; i < dataArray.length; i++) {
const timenow = Date.now();
const options = {
directory: downloadPath,
filename: dataArray[i].title + '.' + dataArray[i].fileType,
saveAs: false,
extension: dataArray[i].fileType,
openFolderWhenDone: false,
showProgressBar: true,
showBadge: true,
};
const downloader = new Downloader(dataArray[i], options);
downloader.data.timeid = timenow;
downloader.start();
handleDownload.push(downloader);
downloader.onTotalProgress = (progress) => {
downloadArray.set(downloader.data.timeid, {
title: downloader.data.title,
sUrl: downloader.data.sUrl,
progress: downloader.data.progress,
size: downloader.data.size,
status: downloader.data.status,
timeid: downloader.data.timeid
});
mainWindow.webContents.send('consolelog', downloadArray);
mainWindow.webContents.send('donwloadStatus', true);
};
downloader.onCompleted = () => {
if (downloader.data.progress === 100 && downloader.data.status === 'process') {
mainWindow.webContents.send('endDownload', JSON.stringify(downloader));
mainWindow.webContents.send('donwloadStatus', false);
downloader.data.status = 'complete';
}
if (downloader.data.progress < 100) {
mainWindow.webContents.send('donwloadStatus', true);
}
mainWindow.webContents.send('consolelog', downloadArray);
};
}
```
阅读全文