Node.js中将回调代码转换为Async代码示例求助

嘿，作为JS/Node.js新手，能意识到用async/await让代码更易读真的很棒！我来帮你把这段回调嵌套的代码改成更清爽的async/await版本，顺便解释每一步的逻辑。

第一步：贴合现有实现的修改方案 #

首先，我们需要把回调式的方法转换成Promise形式，这样就能用await来等待异步操作完成。Node.js内置的util模块里的promisify工具可以帮我们快速做到这一点：

const { promisify } = require('util');

exports.list = async function(req, res) {
  try {
    // 把req.getConnection转换成返回Promise的方法，注意绑定上下文避免this指向错误
    const getConnection = promisify(req.getConnection.bind(req));
    const connection = await getConnection();

    // 同样把connection.query转换成Promise形式
    const query = promisify(connection.query.bind(connection));
    const rows = await query('SELECT * FROM customer');

    // 返回查询结果给客户端
    res.send(rows);
  } catch (err) {
    // 统一捕获所有异步操作的错误
    console.log("Error Selecting : %s ", err);
    // 别忘了给客户端返回错误响应，避免请求一直挂起
    res.status(500).send({ error: '数据库查询失败，请稍后重试' });
  }
};

关键改动说明 #

• 把exports.list声明为async function：这是使用await的前提，async函数会自动返回一个Promise，适配Express的路由处理逻辑。
• promisify工具：把原来的“回调优先”方法（比如req.getConnection、connection.query）转换成返回Promise的方法，这样就能用await线性等待结果，告别嵌套回调。
• try/catch块：代替原来嵌套回调里的if(err)判断，统一捕获所有异步操作的错误，代码结构更清晰，还能给客户端返回合适的错误状态码（比如500表示服务器内部错误）。

进阶优化：使用原生支持Promise的数据库库 #

如果你的项目还没固定数据库依赖，推荐使用mysql2（它是经典mysql库的升级版，原生支持Promise），这样就不用手动promisify了，代码更简洁：

const mysql = require('mysql2/promise');

// 数据库配置可以放到单独的配置文件里，方便维护
const dbConfig = {
  host: '你的数据库地址',
  user: '数据库用户名',
  password: '数据库密码',
  database: '目标数据库名'
};

exports.list = async function(req, res) {
  let connection;
  try {
    // 建立数据库连接
    connection = await mysql.createConnection(dbConfig);
    // 执行查询，mysql2的execute会返回[结果集, 字段信息]，我们只需要结果集部分
    const [rows] = await connection.execute('SELECT * FROM customer');
    
    res.send(rows);
  } catch (err) {
    console.log("Error Selecting : %s ", err);
    res.status(500).send({ error: '数据库查询失败，请稍后重试' });
  } finally {
    // 不管成功还是失败，都要关闭连接避免资源泄漏
    if (connection) await connection.end();
  }
};

这种方式更现代，也避免了手动处理回调转Promise的麻烦，适合新手快速上手。

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