javascript - 如何在node js服务器的for循环中管理近5000条记录？

Question

我使用 NodeJS 创建了一个服务器。 MySQL中有一个数据库，里面有近5000个用户。我必须读取 mysql 数据库并更新并在 MongoDB 数据库中创建日志。我为此实现了一个代码。 https://gist.github.com/chanakaDe/aa9d6a511070c3c78ba3ebc018306ad8

问题就在这里。在此代码的第 50 行中，我添加了该值。

userArray[i].ID]

这是来自 for 循环的用户 ID，我需要使用该 ID 更新 mysql 表。 for 循环 block 中的所有这些代码。但我收到此错误。

TypeError: Cannot read property 'ID' of undefined

因此我将这些值分配给顶部的变量。请参阅第 38 行和第 39 行。

var selectedUserID = userArray[i].ID;
                var selectedUserTelephone = userArray[i].telephone;

当我这样使用时，没有错误。但用户 ID 没有更新。最近 2 个值具有相同的用户 ID。

这个问题的解决方案是什么？

Answer 1

这是一个常见的 JavaScript 问题，与异步操作期间变量的范围和提升的概念相关。

var a = 0;

function doThingWithA () {
  console.log(a)
}

for (var i=0; i<1000; i++) {
  a++;
  setTimeout(function () {
    doThingWithA();
  }, 10);
}

在此示例中，“a”将始终以 1000 的值进行记录。其原因是 setTimeout(模仿慢速数据库操作)需要时间，并且在此期间(在日志发生之前)“a”增加为 1000，因为 for 循环不等待 setTimeout 完成。

最好的解决方案是使用“异步”模块。

pool.getConnection(function (err, connection) {
  connection.query(query, function (err, users) {
    async.eachSeries(users, function (user, next) {
      async.parallel([
        function updateUserStatus (cb) { /* your current code */ },
        function updateUserAccount (cb) { /* current code for this */ }
      ], next);
    }, function (err) { console.log('finished for all users!') })
  });
});

您还可以使用 promise 。这是 Node.js 中典型的异步问题。通过阅读您的代码，您似乎认为每个操作都是串行运行的，而在 Node 中，每个输入/输出(例如数据库调用)都会被触发，但您的代码继续运行，如上面的 for 循环示例所示。