嵌套异步调用中无法访问父作用域变量问题求助

你遇到的这个问题，本质是闭包作用域在异步回调中的变量绑定意外——虽然你用console.log确认了auth_session已定义，但访问session属性时报错，大概率是var的函数级作用域特性导致的隐式问题，或者异步回调执行时变量的绑定出现了偏差。

下面给你几个直接可行的解决方案，按推荐程度排序：

1. 用let替代var声明auth_session #

var的作用域是函数级，会被提升到函数顶部；而let是块级作用域，能精准把变量绑定在当前的if(results.length == 1)代码块内，彻底避免闭包中变量被意外覆盖或混淆：

修改后的关键代码片段：

if (results.length == 1) {
  // 用let锁定块级作用域，避免变量提升带来的意外
  let auth_session = results[0];
  if (md5(request.httpRequest.headers['user-agent'] + (request.httpRequest.headers['accept-encoding'] + request.httpRequest.headers['accept-language'])) == auth_session.fingerprint) {
    mysqlconn.query('SELECT * FROM users WHERE id = ? LIMIT 1', [auth_session.uid], function(err, results, fields) {
      if (err) { throw err; }
      if (results.length === 1) {
        var userinfo = results[0];
        // 现在可以正常访问auth_session.session了
        if (auth_session.session === 1) {
          mysqlconn.query('UPDATE auth_sessions SET expires = ? WHERE id = ? LIMIT 1', [time() + SESSION_TIMEOUT, auth_session.id]);
        }
        // 处理userinfo的业务逻辑
      } else {
        reject_request();
      }
    });
  } else {
    reject_request();
  }
}

2. 使用箭头函数作为查询回调 #

箭头函数不会创建自己的独立作用域，它会直接继承外层作用域的变量绑定，这样能确保回调里的auth_session就是你最初定义的那个变量：

if (results.length == 1) {
  var auth_session = results[0];
  if (md5(request.httpRequest.headers['user-agent'] + (request.httpRequest.headers['accept-encoding'] + request.httpRequest.headers['accept-language'])) == auth_session.fingerprint) {
    // 把第二个查询的回调换成箭头函数
    mysqlconn.query('SELECT * FROM users WHERE id = ? LIMIT 1', [auth_session.uid], (err, results, fields) => {
      if (err) { throw err; }
      if (results.length === 1) {
        var userinfo = results[0];
        if (auth_session.session === 1) {
          mysqlconn.query('UPDATE auth_sessions SET expires = ? WHERE id = ? LIMIT 1', [time() + SESSION_TIMEOUT, auth_session.id]);
        }
        // 处理userinfo的业务逻辑
      } else {
        reject_request();
      }
    });
  } else {
    reject_request();
  }
}

3. 将子查询逻辑封装为独立函数（更易维护） #

把需要使用auth_session的子查询逻辑抽成单独的函数，直接把auth_session作为参数传递进去，彻底绕闭包作用域的问题，同时代码结构更清晰：

// 定义独立的子查询处理函数
function fetchUserAndUpdateSession(auth_session) {
  mysqlconn.query('SELECT * FROM users WHERE id = ? LIMIT 1', [auth_session.uid], function(err, results, fields) {
    if (err) { throw err; }
    if (results.length === 1) {
      var userinfo = results[0];
      if (auth_session.session === 1) {
        mysqlconn.query('UPDATE auth_sessions SET expires = ? WHERE id = ? LIMIT 1', [time() + SESSION_TIMEOUT, auth_session.id]);
      }
      // 处理userinfo的业务逻辑
    } else {
      reject_request();
    }
  });
}

// 主查询回调中调用该函数
mysqlconn.query('SELECT * FROM auth_sessions WHERE session_id = ? AND session_name = ? AND (expires > ? OR expires = 0) LIMIT 1', [cookies.SESSION_ID, cookies.SESSION_NAME, time()], function(err, results, fields) {
  if (err) { throw err; }
  if (results.length == 1) {
    var auth_session = results[0];
    const fingerprint = md5(request.httpRequest.headers['user-agent'] + (request.httpRequest.headers['accept-encoding'] + request.httpRequest.headers['accept-language']));
    if (fingerprint === auth_session.fingerprint) {
      // 直接传递auth_session到子函数
      fetchUserAndUpdateSession(auth_session);
    } else {
      reject_request();
    }
  } else {
    reject_request();
  }
});

额外长期建议 #

嵌套回调会逐渐形成"回调地狱"，后期维护成本很高。建议你用Promise封装MySQL查询，再结合async/await语法编写逻辑，代码可读性和可维护性会大幅提升：

// 先把mysqlconn.query封装成Promise
function query(sql, params) {
  return new Promise((resolve, reject) => {
    mysqlconn.query(sql, params, (err, results) => {
      if (err) reject(err);
      else resolve(results);
    });
  });
}

// 用async/await编写逻辑
async function handleAuthRequest() {
  try {
    const authResults = await query('SELECT * FROM auth_sessions WHERE session_id = ? AND session_name = ? AND (expires > ? OR expires = 0) LIMIT 1', [cookies.SESSION_ID, cookies.SESSION_NAME, time()]);
    if (authResults.length !== 1) {
      reject_request();
      return;
    }
    const auth_session = authResults[0];
    const fingerprint = md5(request.httpRequest.headers['user-agent'] + (request.httpRequest.headers['accept-encoding'] + request.httpRequest.headers['accept-language']));
    if (fingerprint !== auth_session.fingerprint) {
      reject_request();
      return;
    }
    const userResults = await query('SELECT * FROM users WHERE id = ? LIMIT 1', [auth_session.uid]);
    if (userResults.length !== 1) {
      reject_request();
      return;
    }
    const userinfo = userResults[0];
    if (auth_session.session === 1) {
      await query('UPDATE auth_sessions SET expires = ? WHERE id = ? LIMIT 1', [time() + SESSION_TIMEOUT, auth_session.id]);
    }
    // 处理userinfo的业务逻辑
  } catch (err) {
    throw err;
  }
}

内容的提问来源于stack exchange，提问作者Goulash