我在Node.js中使用读取流时遇到一个非常奇怪的问题。我正在使用SSH2在我和sftp服务器之间创建sftp连接。然后，我尝试从sftp流创建一个读取流。从读取流的发出的“数据”事件中，我将数据追加到数组中。当读取流的“关闭”事件发生时，我调用Buffer.concat来创建concat，我将检索到的所有数据块都放入一个缓冲区中。这是在堆栈溢出时在此处提出的其他问题中描述的相同技术。例如这里。但是，我无法使用检索到的数据。似乎缓冲区的大小比我要检索的文件小32个字节（通过计算检索到的数据的长度）。这与我的SFTP连接有关吗？还是我如何创建读取流？
如果重要的话，该文件的类型为zip。当我尝试读取文件以缓冲后解压缩文件（在node.js中并手动）时，它不起作用。
经过调查，我发现：
任何建议表示赞赏！
这是我的代码：
var Client = require('ssh2').Client;
var m_ssh2Credentials = {
host: config.ftpHostName,
port: config.ftpPort,
username: config.ftpUser,
password: config.ftpPassword,
readyTimeout: 20000,
algorithms: { cipher: ["3des-cbc", "aes256-cbc", "aes192-cbc","aes128-cbc"]}
};
...
var conn = new Client();
var dataLength = 0;
conn.on('ready', function() {
conn.sftp(function(err, sftp) {
if (err) {
writeToErrorLog("downloadFile(): Failed to open SFTP connection.");
} else {
writeToLog("downloadFile(): Opened SFTP connection.");
}
var streamErr = "";
var dataLength = 0;
var stream = sftp.createReadStream(config.ftpPath + "/" + m_fileName)
stream.on('data', function(d){
data.push(d);
dataLength += d.length;
});
.on('error', function(e){
streamErr = e;
})
.on('close', function(){
if(streamErr) {
writeToErrorLog("downloadFile(): Error retrieving the file: " + streamErr);
} else {
writeToLog("downloadFile(): No error using read stream.");
m_fileBuffer = Buffer.concat(data, dataLength);
writeToLog("Data length: " + dataLength);
writeToLog("downloadFile(): File saved to buffer.");
}
conn.end();
});
})
})
.on('error', function(err) {
writeToErrorLog("downloadFile(): Error connecting: " + err);
}).connect(m_ssh2Credentials);
因此，经过大量调查，我终于意识到在“数据”事件中传输的最后几位数据有问题。据我了解，这似乎是读取流实现中的一个错误。通过使用SSH2库中更简单的功能（open，fstat，read），我能够解决此问题。这个解决方案对我有用。希望在其他人遇到相同问题的情况下共享解决方案。
工作代码：
sftp.open(config.ftpPath + "/" + m_fileName, "r", function(err, fd) {
sftp.fstat(fd, function(err, stats) {
var bufferSize = stats.size,
chunkSize = 16384,
buffer = new Buffer(bufferSize),
bytesRead = 0,
errorOccured = false;
while (bytesRead < bufferSize && !errorOccured) {
if ((bytesRead + chunkSize) > bufferSize) {
chunkSize = (bufferSize - bytesRead);
}
sftp.read(fd, buffer, bytesRead, chunkSize, bytesRead, callbackFunc);
bytesRead += chunkSize;
}
var totalBytesRead = 0;
function callbackFunc(err, bytesRead, buf, pos) {
if(err) {
writeToErrorLog("downloadFile(): Error retrieving the file.");
errorOccured = true;
sftp.close(fd);
}
totalBytesRead += bytesRead;
data.push(buf);
if(totalBytesRead === bufferSize) {
m_fileBuffer = Buffer.concat(data);
writeToLog("downloadFile(): File saved to buffer.");
sftp.close(fd);
m_eventEmitter.emit(' downloadFile_Completed ');
}
}
})
});
本文收集自互联网，转载请注明来源。
如有侵权，请联系[email protected] 删除。
我来说两句