使用asyncawait模块跨Express多端点调用函数的正确方式

我来帮你搞定这个问题！因为Node版本低不得不依赖asyncawait模块确实有点麻烦，但复用方法的思路其实和原生async/await很像，只是要贴合这个模块的语法规则来。

第一步：把可复用方法用asyncawait正确包装 #

首先，你需要把带await逻辑的方法用asyncawait.async()包裹起来，这样方法内部才能合法使用asyncawait.await()。举个实际例子：

const asyncawait = require('asyncawait');
// 先解构出核心函数，方便后续调用
const async = asyncawait.async;
const await = asyncawait.await;

// 定义你要复用的异步方法
const fetchUserData = async(function(userId) {
  // 这里放你的异步逻辑，比如数据库查询、第三方API请求
  const rawData = await(someDatabaseQuery(userId));
  // 可选：对返回数据做处理
  const processedData = formatUserInfo(rawData);
  return processedData;
});

第二步：在Express路由中调用复用方法 #

用async()包装后的方法本质上会返回一个Promise，所以有两种靠谱的调用方式：

方式一：用async()包装路由处理函数，内部用await调用

这种方式和你之前单个路由的写法逻辑一致，只是把复用方法抽离了，重点要做好错误捕获：

// 路由1：根据ID获取用户信息
app.get('/user/:id', async(function(req, res, next) {
  try {
    const userId = req.params.id;
    const userData = await(fetchUserData(userId));
    res.status(200).json(userData);
  } catch (err) {
    // 把错误传给Express全局错误处理中间件
    next(err);
  }
}));

// 路由2：批量获取用户信息（复用同一个方法）
app.post('/users/batch', async(function(req, res, next) {
  try {
    const userIds = req.body.userIds;
    // 批量调用复用方法，用Promise.all处理并行请求
    const userList = await(Promise.all(userIds.map(id => fetchUserData(id))));
    res.status(200).json(userList);
  } catch (err) {
    next(err);
  }
}));

方式二：用Promise链式调用（不用包装路由函数）

如果不想用async()包裹路由处理函数，也可以直接用.then()/.catch()的方式调用：

app.get('/user/profile/:id', function(req, res, next) {
  const userId = req.params.id;
  fetchUserData(userId)
    .then(userData => res.status(200).json(userData))
    .catch(err => next(err));
});

关键注意事项 #

• 所有使用await的代码，必须放在async()包装的函数内部，这是asyncawait模块的硬性规则，和原生async/await的“await只能在async函数里用”逻辑一致。
• 必须处理错误！不管是用try/catch还是.catch()，如果异步操作出错却没捕获，会导致Express服务崩溃或者请求挂起无响应。
• 确保已安装asyncawait模块：如果还没装，先执行npm install asyncawait --save。

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