node.js - FTP 服务器上的 Fs.readFile

Question

我在 Node.js 中有一些脚本，当我在计算机上运行它时，它可以工作，但当我在服务器上运行时，它就不起作用。我有 2 个服务器:我在第一个服务器(服务器 1)上运行 web 应用程序，第二个服务器(服务器 2)包含文件。

var fs = require('fs');
var FTPClient = require('ftp');
var c = new FTPClient();

c.connect({
  host: "192.168.200.2",
  user: "*****",
  password: "******"
});

c.on('ready', function() {

  console.log("Connected to datastore !");

  var dateFile = './Dictionnary/lastUpdate.json';
  var csvFile = '//192.168.200.2/Alfa/file4457.csv'
  var lastUpdate;

  fs.stat(csvFile, (err, stat) => {
    if (err) {
      console.error(err);
    };

    var date = { mtime: stat.mtime }

    var lastDate = new Date(jsonfile.readFileSync(dateFile).mtime);

    var newDate = new Date(stat.mtime);

    if (newDate <= lastDate) {
      console.log('Dictionnary up-to-date');
    } else {
      console.log('Update Needed');
      var DeleteQuery = mySqlClient.query('DELETE FROM dictionnary');
      csv = fs.readFile(csvFile, 'utf-8', (err, data) => {
        if (err) {
          throw err
        };
        dictionnary = parseCSV(data);
        for (i = 0; i < dictionnary.length - 1; i++) {
          var insertQuery = ("INSERT INTO Dictionnary VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)");
          var query = mySqlClient.query(insertQuery, [dictionnary[i][0], dictionnary[i][1], dictionnary[i][2], dictionnary[i][3], dictionnary[i][4], dictionnary[i][5], dictionnary[i][6], dictionnary[i][7], dictionnary[i][8], dictionnary[i][9], dictionnary[i][10], , dictionnary[i][11], , dictionnary[i][12]]);
         };
      }
   }
}

当我在计算机上运行脚本时，我可以在(服务器 2)上找到该文件，但是当我在(服务器 1)上运行它时，它不再工作，并且出现此错误:

 Error: ENOENT: no such file or directory, open '//192.168.200.2/Alfa/file4457.csv'

我认为这是通行证的问题，所以我尝试使用//192.168.200.2/Alfa/file4457.csv，./Alfa/file4457.csv， 阿尔法/file4457.csv

但这不起作用。

我检查了路径，他很好。

对于 fs.stat() 这不是问题，我仍然可以用 c.lastMod() 替换它，但我找不到可以用来做什么替换fs.readFile()

感谢您的阅读。

Answer 1

fs 将查找您为其提供的路径 //192.168.200.2/Alfa/file4457.csv。

从您执行脚本的服务器上找不到此路径。我不了解您的网络和服务器体系结构，因此我无法真正解释为什么它在您的计算机上运行而不是在服务器上运行。但我猜你的计算机和 FTP 服务器位于同一个本地网络上(如果我错了，请纠正我)。

阅读代码后，您将在远程 FTP 服务器上打开 FTP 连接:

c.connect({
  host: "192.168.200.2",
  user: "*****",
  password: "******"
});

c.on('ready', function() {
    ...
});

但是在 .on('ready', function() { ... }) 回调中，您不会对这个新打开的连接执行任何操作(看看您的代码，您从未使用过再次c)。

通过读取ftp Node 模块documentation ，您可以发现有 get 函数，能够从您的 FTP 连接检索文件。

get(< string >path, [< boolean >useCompression, ]< function >callback) - (void) - Retrieves a file at path from the server. useCompression defaults to false. callback has 2 parameters: < Error >err, < ReadableStream >fileStream.

因此，您必须使用 FTP 连接:

c.connect({
   host: "192.168.200.2",
   user: "*****",
   password: "******"
});

c.on('ready', function() {
    c.get('/Alfa/file4457.csv', function(err, stream) {
         var content = '';
         stream.on('data', function(chunk) {
             content += chunk.toString();
         });
         stream.on('end', function() {
             // content variable now contains all file content. 
         });
    })
});