mysql - NodeJS 和 MySQL : getting array data inside query callback

Question

我正在尝试运行这段代码:

setInterval(function () {

    var params = {
        QueueUrl: 'https://sqs.us-east-1.amazonaws.com/821808622769/Teste', // required
        MaxNumberOfMessages: 10
    };
    sqs.receiveMessage(params, function (err, data) {
        if (err)
            console.log('Erro de SQS:' + err);
        else {
            var retorno = data.Messages;
            for (var i in data.Messages) {

                var queryString = 'SELECT now()'; //dummy query, just for tests
                db_connection.query(queryString, null, function (err, rows, fields) {
                    if (err) {
                        console.log('Erro no BD:' + err);
                        return;
                    }

                    var date = new Date();
                    console.log(retorno[i].Body + ' ' + date.getTime().toString());
                });

            }
            console.log();
        }
    });
}, 30000);

我在 AWS SQS 中有 5 条消息，例如:

但是当我运行我的代码时，有时我会收到一条重复的消息，而不是每条消息的 retorno[i].Body，如图所示

我的 for 循环运行了 1 到 5 个查询，但我如何将回调中的 retorno[i] 携带到数据库查询？我的意思是，我如何确定我正在处理的是哪条消息？

Answer 1

使用 .bind() 可以将 i 的内部版本设置为与循环中 i 的版本相同。

.bind({i:i}) 在回调结束时更改内部代码以引用 this.i

for (var i in data.Messages) {

  var queryString = 'SELECT now()'; //dummy query, just for tests
  db_connection.query(queryString, null, function(err, rows, fields) {
      if (err) {
        console.log('Erro no BD:' + err);
        return;
      }

      var date = new Date();
      console.log(retorno[this.i].Body + ' ' + date.getTime().toString());
    }.bind({
      i: i
    });
  }
}