如何用async/await替代setTimeout处理Twit请求返回自定义对象数组

原来依赖1秒固定延时返回响应的实现，核心缺陷是没有和Twit接口的真实异步完成状态做绑定：网络情况好的时候，1秒固定延时会拉长前端等待时间；网络波动的时候，1秒到了请求还没完成，就会返回空数据或者不完整的结果，可靠性完全没有保障。

改造核心原则 #

• 把Twit库原生的回调式接口请求，封装为标准Promise对象，适配async/await的语法规则
• 两个无依赖关系的Twitter用户时间线请求并行发起，不串行等待，压缩整体接口耗时
• 等所有请求完成、自定义字段提取加工完成后，再调用res.json返回结果，全程移除setTimeout逻辑

完整实现代码 #

首先是Twit请求的Promise封装，解决回调风格无法被await识别的问题：

// Twit客户端初始化逻辑保留原有项目配置，此处仅展示请求封装
const fetchUserTimeline = (twitInstance, requestParams) => {
  return new Promise((resolve, reject) => {
    twitInstance.get(
      'statuses/user_timeline',
      requestParams,
      (error, responseData) => {
        if (error) return reject(error)
        resolve(responseData)
      }
    )
  })
}

然后是Express GET路由的改造，注意路由处理函数需要声明为async才能使用await语法：

app.get('/twitter/timelines', async (req, res) => {
  try {
    // 用Promise.all并行等待两个独立请求全部完成
    const [timelineAccount1, timelineAccount2] = await Promise.all([
      fetchUserTimeline(TwitClient, { screen_name: '第一个目标账号', count: 15 }),
      fetchUserTimeline(TwitClient, { screen_name: '第二个目标账号', count: 15 })
    ])

    // 通用字段提取方法：从原始tweet结构中提取需要的自定义字段
    const mapTweetToCustomStructure = (rawTweetList) => {
      return rawTweetList.map(tweet => ({
        userName: tweet.user.name,
        postContent: tweet.text,
        avatarLink: tweet.user.profile_image_url_https,
        postTime: tweet.created_at
      }))
    }

    // 合并两个账号的时间线数据，组成最终返回的对象数组
    const processedResult = [
      ...mapTweetToCustomStructure(timelineAccount1),
      ...mapTweetToCustomStructure(timelineAccount2)
    ]

    // 所有加工完成后再返回响应，Insomnia中可直接查看标准JSON结构
    res.json({
      status: 'success',
      payload: processedResult
    })
  } catch (error) {
    // 统一捕获全流程的错误，避免接口无响应
    res.status(502).json({
      status: 'failed',
      message: 'Twitter接口请求异常',
      detail: error.message
    })
  }
})

调试注意事项 #

• 不要把Promise.all的并行等待改成两个串行的await请求，不然总响应耗时会变成两个请求的耗时总和，平白增加接口等待时间
• 字段提取时注意Twitter原始响应的结构层级：用户名称、头像这类用户信息是嵌套在每条tweet的user属性下的，不要错读成顶层字段
• 移除原有的setTimeout逻辑后，要检查是否存在重复调用res.json的代码，避免Express抛出“响应头已发送”的运行时错误
• 如果在Insomnia中看到返回空数组，优先排查Twit配置的OAuth权限是否包含读取用户时间线的范围，其次检查传入的账号screen_name参数是否正确

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