在Node.js中如何使用async.eachSeries实现步骤间结果传递？

你当前用的async.eachSeries本身不支持跨迭代步骤传递执行结果，要实现需求优先推荐换用async.reduce方法，这是async库专门为「顺序迭代+传递累积结果」场景设计的API。

推荐实现代码 #

const async = require('async')

async.reduce(
  [1, 2, 3, 4, 5],
  // 第一次迭代的初始累积值，可根据业务需求调整
  null,
  function downloadChunk (previousResult, chunkID, asyncCallback) {
    console.log('当前处理的 chunkID：', chunkID)
    // 此处可直接使用上一步传递过来的 previousResult 做业务处理
    if (previousResult) {
      console.log('接收到上一步的结果：', previousResult)
    }
    const currentResult = `This is a result from ${chunkID} call and should be used somewhere in ${chunkID + 1}`
    // 将当前步骤结果通过回调传递给下一步
    asyncCallback(null, currentResult)
  },
  function complete (err, finalResult) {
    if (err) {
      console.log('Error: ' + err)
      return
    }
    console.log('全部步骤执行完成，最终结果：', finalResult)
    console.log('this is the end. All the variables have been used')
  }
)

其他可选方案 #

如果不想修改API，也可以在外部作用域定义变量存储上一步结果，不过这种方案会污染外部作用域，多并行流程下容易出现变量冲突，仅适合简单单流程场景使用：

const async = require('async')
// 存储上一步执行结果的外部变量
let prevResult = null

async.eachSeries([1, 2, 3, 4, 5],
  function downloadChunk (chunkID, asyncCallback) {
    console.log(chunkID)
    if (prevResult) {
      console.log('上一步结果：', prevResult)
    }
    const result = `This is a result from ${chunkID} call and should be used somewhere in ${chunkID + 1}`
    prevResult = result
    asyncCallback()
  },
  function complete (err) {
    if (err) console.log('Error: ' + err)
    console.log('this is the end. All the variables have been used')
  }
)

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