一、回调函数（callback）

1、概念

A callback is a function that is passed as an argument to another function and is executed after its parent function has completed.
翻译：回调函数是作为参数传递给另一个函数的函数，在父函数实现后执行。

2、例子阐明

var fs = require("fs");
var a
 
function f(x) {console.log(x)
}
 
function writeFile() {fs.writeFile('input01.txt', 'www.baidu.com', function (err) {if (!err) {console.log("文件写入结束!")
            a = 1
        }
    });
}
 
a = 0
writeFile()
f(a)

输入后果：0
文件写入结束!

代码阐明 ：设置一个全局变量 a = 0，后执行 writeFile 函数（也就是写入一个文件 input01.txt），这个函数外面有一行 c = 1，函数执行结束之后再跳进去调用 f() 函数，f()函数, 就是把打印一个变量。

依照“失常”逻辑，首先 a=0，而后调用 writeFile 函数，该函数外面有一句 a = 1，最初再调用 f(a)，又因为调用 writeFile()是在 f(a)之前，所以 a=1 这条语句必定是会被执行到，那么后果应该是打印 1，后果居然是 0，明明咱们在 writeFile 函数里咱们从新对 a 进行了赋值，为什么后果还是 0 呢？

因为程序运行到 writeFile()这一行的时候，是一个比拟耗时的 IO 操作，JS 碰到这种操作并不会停在原地始终期待直到函数执行结束，而是间接运行下一条代码（即 f(a)），而此时 a = 1 这一行代码其实并没有被执行到，所以打印进去的后果还是 0 !

如果要打印出 a= 1, 只须要将 f(a)也放进 writeFile()函数外面，就能保障 a = 1 之后再调用 f(a):

var fs = require("fs");
var a
 
function f(x) {console.log(x)
}
 
function writeFile() {fs.writeFile('input01.txt', 'www.baidu.com', function (err) {if (!err) {console.log("文件写入结束!")
            a = 1
            f(a)
        }
    });
}
 
a = 0;
writeFile();

输入后果：文件写入结束!
1

代码阐明： 先执行 writeFile()函数，再执行 writeFile 中的 f(a)，a = 1 肯定会被执行到。

然而改成这样并不完满，因为这么做就相当于将 f()” 焊死 ” 在 writeFile()里了，如果此处我最终想调用的函数不是 f()而是别的其余函数 f1(),f2(),f3()… 应该怎么写？难不成要写几个不同的 writeFile()，而他们之间的区别仅仅是最初调用的那个函数不同？显然是不可获得，而应用回调函数就可解决：“关键字”callback。（精确地说 callback 并不真的是 Javascript 里的关键字，然而鉴于大家都约定成俗把 callback 这个单词作为回调函数的默认抉择了，这里权且就不谨严地称它为 ” 关键字 ” 吧)

var fs = require("fs");
 
function f(x) {console.log(x)
}
 
function writeFile(callback) { //callback，示意这个参数不是一个一般变量，而是一个函数
    fs.writeFile('input01.txt', 'www.baidu.com', function (err) {if (!err) {console.log("文件写入结束!")
            a = 1
            callback(a) // 因为咱们传进来的函数名是 f()，所以此行相当于调用一次 f(c)
        }
    });
}
var a = 0
writeFile(f) // 函数 f 作为一个参数传进 writeFile 函数

输入后果：文件写入结束!
1

代码阐明 ：呈现了两次 callback， 第一个 callback呈现在 writeFile 的形参里，起定义的作用，示意这个参数并不是一个一般变量，而是一个函数，也就是后面所说的重点，即所谓的“以函数为参数”。第二个 callback呈现在 a = 1 上面，示意此处“执行”从形参传递进来的那个函数。

这样一来，writeFile()函数在执行结束之后到底调用哪个函数就变“活”了，如果咱们想 writeFile()函数执行完之后并不是像第二个例子那样只能调用 f()，而是还有别的函数比如说 x() y() z()，那么只须要写成 writeFile(x),writeFile(y)… 就行了。

总结： 在大多数编程语言中，函数的形参总是从外向内传递参数，但在 JS 中，如果形参碰到“关键字”callback 则齐全相同，它示意从外向外反向调用某个内部函数。

此处并不一定非要写为“callback”，你能够任意写成 abc, foo... 等等。callback 只是一种约定俗成的写法，它明确地通知代码阅读者：此处是一个回调函数。

有时候，咱们会看到一些函数的形参列表里间接嵌套一个函数的状况，其本质上依然是回调函数，因为没有了函数名，所以也称 匿名函数。

var fs = require("fs");
 
function writeFile(callback) {fs.writeFile('input01.txt', 'www.baidu.com', function (err) {if (!err) {console.log("文件写入结束!")
            a = 1
            callback(a) 
        }
    });
    
}
var a = 0
writeFile(function (x) {console.log(x)
});
输入后果：文件写入结束!
1

writeFile()函数不变，只是在调用它的时候，间接将函数体嵌在参数列表里了，其作用跟上一个例子齐全一样。其实在本例中，fs.writeFile 函数前面也有一个匿名回调函数 function (err) {}，这个函数示意当文件写入结束后，就回调它，如果在写入过程中呈现了谬误，则通过变量 err 携带进去。

阐明： 在 JS 里，并非所有操作都是异步的，比方 for 循环，无论这个 for 循环须要耗时多长，零碎也肯定会等它转完之后才会执行上面的语句。

二、Promise 介绍

1、回调天堂

首先咱们来看什么是回调天堂

在应用 JavaScript 时，为了实现某些逻辑常常会写出层层嵌套的回调函数，如果嵌套过多，会极大影响代码可读性和逻辑，这种状况也被成为回调天堂。

function pick(next){setTimeout(()=>{console.log('收到信息',new Date());
        next();},500);
}
function groundMouth(next){setTimeout(()=>{console.log('货物装载',new Date());
        next();},400);
}
function blow(next){setTimeout(()=>{console.log('打包出仓',new Date());
        next();},300);
}
function PEbag(next){setTimeout(()=>{console.log('集成装车',new Date());
        next();},200);
}
function pack(){setTimeout(()=>{console.log('发送运输',new Date());
    },100);
}

pick(()=>{groundMouth(()=>{blow(()=>{PEbag(()=>{pack();
            });
        });
    });
});

输入后果：收到信息 2022-03-20T14:24:15.363Z
货物装载 2022-03-20T14:24:15.771Z
打包出仓 2022-03-20T14:24:16.072Z
集成装车 2022-03-20T14:24:16.273Z
发送运输 2022-03-20T14:24:16.375Z

如果还有后续步骤，须要始终嵌套上来，这样代码的可读性就变差了。

如果应用 Promise 该怎么解决呢？

2、Promise 介绍

2.1 Promise 的状态

用 new Promise 实例化的 promise 对象有以下三个状态。

• “has-resolution” 即 Fulfilled resolve(胜利) 时。此时会调用 onFulfilled
• “has-rejection” 即 Rejected reject(失败) 时。此时会调用 onRejected
• “unresolved” 即Pending 既不是 resolve 也不是 reject 的状态。也就是 promise 对象刚被创立后的初始化状态等

promise 对象的状态，从 Pending 转换为 Fulfilled 或 Rejected 之后，这个 promise 对象的状态就不会再产生任何变动。也就是说，只有异步操作的后果能够决定以后是哪一种状态，其余任何操作都无奈扭转这种状态；一旦状态扭转，就不会再扭转。

Promise 与 Event 等不同，在 .then 后执行的函数能够必定地说只会被调用一次。

Promise 中的函数是同步的，只有.then 后的函数才是异步的

2.2 结构器

创立一个 Promise 对象，能够应用 new 调用 Promise 的结构器来进行实例化。

var promise = new Promise(function(resolve, reject) { // 异步解决
// 解决完结后、调用 resolve 或 reject
});

2.3 实例办法

• Promise.prototype.then

对通过 new 生成的 promise 对象为了设置其值在 resolve (胜利)/ reject（失败）时调用的回调函数 能够应用 promise.then()实例办法(也就是说作用是为 Promise 实例增加状态扭转时的回调函数。)。

promise.then(onFulfilled, onRejected)

then办法的第一个参数是 Resolved 状态的回调函数，第二个参数（可选）是 Rejected 状态的回调函数。

• resolve(胜利)时 onFulfilled 会被调用
• reject(失败)时 onRejected 会被调用

onFulfilled、onRejected 两个都为可选参数。

then办法返回的是一个新的 Promise 实例（留神，不是原来那个 Promise 实例）。因而能够采纳链式写法，即 then 办法前面再调用另一个 `then 办法。

getJSON("/post/1.json") // 返回一个 Promise 对象
.then(function(post) {return getJSON(post.commentURL);  // 返回一个 Promise 对象
})
.then(function funcA(comments) {console.log("Resolved:", comments);  
}, function funcB(err) {console.log("Rejected:", err);  
});

下面的代码应用 then 办法，顺次指定了两个回调函数。第一个回调函数实现当前，会将返回后果作为参数，传入第二个回调函数。采纳链式的 then，能够指定一组依照秩序调用的回调函数。

• Promise.prototype.catch()

promise.then胜利和失败时都能够应用。另外在只想对异样进行解决时能够采纳 Promise.then(undefined, onRejected) 这种形式，只指定 reject 时的回调函数即可。

Promise.prototype.catch办法是 .then(null, rejection) 的别名，用于指定产生谬误时的回调函数, 等同于抛出谬误。
上文的代码能够革新成如下：

getJSON("/post/1.json") // 返回一个 Promise 对象
.then(function(post) {return getJSON(post.commentURL);  // 返回一个 Promise 对象
})
.then(function (comments) {console.log("Resolved:", comments);  
})
.catch(err) {console.log("Rejected:", err);  
});  

须要留神的是，如果 Promise 状态曾经变成 Resolved，再抛出谬误是有效的。

var promise = new Promise(function(resolve, reject) {resolve('success');  
  throw new Error('error');  
});  
promise  
  .then(function(value) {console.log(value)  
  })  
  .catch(function(error) {console.log(error)  
  });

输入后果：success

下面代码中，Promise 在 resolve 语句前面，再抛出谬误，不会被捕捉，等于没有抛出。

Promise 对象的谬误具备“冒泡”性质，会始终向后传递，直到被捕捉为止。也就是说，谬误总是会被下一个 catch 语句捕捉。

var catchError = new Promise(function(resolve, reject) {setTimeout(function(){resolve('success')
  }, 1000)  
}) 

catchError
.then(function(value){console.log('a')
})
.then(function(value){throw new Error('test');  
  console.log('b')
})
.then(function(value){console.log('c')
})
.catch(function(error){console.log(error)
})
输入后果：a
Error: test
    at D:\upyun\test\promise\promise12.js:26:9

下面代码中，一共有四个 Promise 对象：一个由 ’catchError’ 产生，三个由 then 产生。它们之中的第二个 then 办法出了谬误，中断了上面的 then 办法，间接被最初一个 catch 捕捉。

倡议总是应用 catch 办法，而不应用 then 办法的第二个处理错误的参数。

跟传统的 try / catch 代码块不同的是，如果没有应用 catch 办法指定错误处理的回调函数，Promise 对象抛出的谬误不会传递到外层代码，即不会有任何反馈。

var foo = function() {return new Promise(function(resolve, reject) {  
      //  上面一行会报错，因为 a 没有申明  
      resolve(a + 2);  
  });  
};  
foo().then(function() {console.log('everything is great');  
});
输入后果：ReferenceError: a is not defined

下面代码中，foo函数产生的 Promise 对象会报错，然而因为没有指定 catch 办法，这个谬误不会被捕捉，也不会传递到外层代码，导致运行后没有任何输入。

留神，Chrome 浏览器不恪守这条规定，它会抛出谬误“ReferenceError: x is not defined”。

var promise = new Promise(function(resolve, reject) {resolve("success");  
  setTimeout(function() {throw new Error('error')  
  }, 0)  
});  
promise.then(function(value) {console.log(value)  
}); 
输入后果：success
D:\upyun\test\promise\promise12.js:49
      throw new Error('error')
      ^

Error: error

下面代码中，Promise 指定在下一轮“事件循环”再抛出谬误，后果因为没有指定应用try...catch 语句，就冒泡到最外层，成了未捕捉的谬误。因为此时，Promise 的函数体曾经运行完结了，所以这个谬误是在 Promise 函数体外抛出的。

Node.js 有一个 unhandledRejection 事件，专门监听未捕捉的 reject 谬误。unhandledRejection事件的监听函数有两个参数，第一个是谬误对象，第二个是报错的 Promise 实例，它能够用来理解产生谬误的环境信息。

process.on('unhandledRejection', function(err, p) {console.error(err.stack)  
}); 

须要留神的是，catch 办法返回的还是一个 Promise 对象，因而前面还能够接着调用 then 办法。

var foo = function() {return new Promise(function(resolve, reject) {  
      //  上面一行会报错，因为 a 没有申明  
      resolve(a + 2);  
  });  
};  
foo()  
  .catch(function(error) {console.log('Error', error);  
  })  
  .then(function() {console.log('success');  
  });
输入后果：Error ReferenceError: a is not defined
success

下面代码运行完 catch 办法指定的回调函数，会接着运行前面那个 then 办法指定的回调函数。如果没有报错，则会跳过 catch 办法。

2.4 静态方法

Promise 这样的全局对象还领有一些静态方法。

包含 Promise.all() 还有 Promise.resolve() 等在内，次要都是一些对 Promise 进行操作的 辅助办法。

• Promise.all

Promise.all() 办法接管一个 promise 的 iterable 类型（注：Array，Map，Set 都属于 ES6 的 iterable 类型）的输出，并且只返回一个 Promise 实例，那个输出的所有 promise 的 resolve 回调的后果是一个数组。这个 Promise 的 resolve 回调执行是在所有输出的 promise 的 resolve 回调都完结，或者输出的 iterable 里没有 promise 了的时候。它的 reject 回调执行是，只有任何一个输出的 promise 的 reject 回调执行或者输出不非法的 promise 就会立刻抛出谬误，并且 reject 的是第一个抛出的错误信息。

const promise1 = Promise.resolve(3);
const promise2 = 42;
const promise3 = new Promise((resolve, reject) => {setTimeout(resolve, 100, 'foo');
});

Promise.all([promise1, promise2, promise3]).then((values) => {console.log(values);
});
输入后果：[3, 42, 'foo']

语法

Promise.all(iterable);

参数

• iterable
• 一个可迭代对象，如 Array 或 String。

返回值

• 如果传入的参数是一个空的可迭代对象，则返回一个 已实现（already resolved） 状态的 Promise。
• 如果传入的参数不蕴含任何 promise，则返回一个 异步实现（asynchronously resolved）  Promise。留神：Google Chrome 58 在这种状况下返回一个 已实现（already resolved） 状态的 Promise。
• 其它状况下返回一个 解决中（pending） 的 Promise。这个返回的 promise 之后会在所有的 promise 都实现或有一个 promise 失败时 异步 地变为实现或失败。返回值将会依照参数内的 promise 顺序排列，而不是由调用 promise 的实现程序决定。

阐明

此办法在汇合多个 promise 的返回后果时很有用。

实现（Fulfillment）： 如果传入的可迭代对象为空，Promise.all 会同步地返回一个已实现（resolved）状态的 promise。
如果所有传入的 promise 都变为实现状态，或者传入的可迭代对象内没有 promise，Promise.all 返回的 promise 异步地变为实现。

在任何状况下，Promise.all 返回的 promise 的实现状态的后果都是一个数组，它蕴含所有的传入迭代参数对象的值（也包含非 promise 值）。

失败 / 回绝（Rejection）： 如果传入的 promise 中有一个失败（rejected），Promise.all 异步地将失败的那个后果给失败状态的回调函数，而不论其它 promise 是否实现。

-Promise.resolve()

Promise.resolve(value) 办法返回一个以给定值解析后的 Promise 对象。如果这个值是一个 promise，那么将返回这个 promise；如果这个值是 thenable（即带有"then"  办法），返回的 promise 会“追随”这个 thenable 的对象，采纳它的最终状态；否则返回的 promise 将以此值实现。此函数将类 promise 对象的多层嵌套展平。

语法

Promise.resolve(value);

参数

value

将被 Promise 对象解析的参数，也能够是一个 Promise 对象，或者是一个 thenable。

返回值

返回一个带着给定值解析过的 Promise 对象，如果参数自身就是一个 Promise 对象，则间接返回这个 Promise 对象。

形容

静态方法 Promise.resolve返回一个解析过的 Promise 对象。

1. 应用动态 `Promise.resolve` 办法
Promise.resolve("Success").then(function(value) {console.log(value); 
}, function(value) {// 不会被调用});
输入后果：Success

2.resolve 一个数组
var p = Promise.resolve([1,2,3]);
p.then(function(v) {console.log(v[0]); // 1
});

2.5 还有须要留神，Promise 创立后回立即执行

var promise = new Promise(function(resolve, reject) {console.log('Promise');  
  resolve();});  
promise.then(function() {console.log('Resolved.');  
});  
console.log('hello world'); 
输入后果：Promise
hello world
Resolved.

下面代码中，Promise 新建后立刻执行，所以首先输入的是“Promise”。而后，then 办法指定的回调函数，将在以后脚本所有同步工作执行完才会执行，所以“Resolved”最初输入。

2.6 Promise 也是有毛病的

• 无奈勾销 Promise，一旦新建它就会立刻执行，无奈中途勾销。
• 如果不设置回调函数，Promise 外部抛出的谬误，不会反馈到内部。
• 当处于 Pending 状态时，无奈得悉目前停顿到哪一个阶段（刚刚开始还是行将实现）。

2.7 创立 Promise 对象流程

• new Promise(fn)返回一个 Promise 对象

• 在 fn 中指定异步等解决逻辑

  • 处理结果失常的话，调用 resolve(处理结果值)
  • 处理结果谬误的话，调用 reject(Error 对象)

2.8 创立 XHR 的 promise 对象

首先，创立一个用 Promise 把 XHR 解决包装起来的名为 getURL 的函数。

function getURL(URL) {return new Promise(function (resolve, reject) {var req = new XMLHttpRequest(); 

      req.open('GET', URL, true); 

      req.onload = function () {if (req.status === 200) {resolve(req.responseText);
          } else {reject(new Error(req.statusText));
          } 
      };
      
      req.onerror = function () {reject(new Error(req.statusText));
      };
      req.send();});
}
// 运行示例
var URL = "http://httpbin.org/get"; 
getURL(URL).then(function onFulfilled(value){console.log(value); 
}).catch(function onRejected(error){console.error(error); 
});

getURL 只有在通过 XHR 获得后果状态为 200 时才会调用 resolve, 而其余状况 (获得失败) 时则会调用 reject 办法。

resolve(req.responseText)

resolve函数的作用是，将 Promise对象的状态从“未实现”变为“胜利”（即从 Pending变为Resolved），在异步操作胜利时调用，并将异步操作后果，作为参数传递进来。

参数并没有特地的规定，基本上把要传给回调函数参数放进去就能够了。(then 办法能够接管到这个参数值)

reject(new Error(req.statusText))

reject函数的作用是，将 Promise 对象的状态从“未实现”变为“失败”（即从 Pending 变为Rejected），在异步操作失败时调用，并将异步操作报出的谬误，作为参数传递进来。

上文中，XHR 中 onerror事件被触发的时候就是产生谬误时，所以天经地义调用 reject。产生谬误时，创立一个 Error 对象后再将具体的值传进去。传给 的参数也没有什么非凡的限度，个别只有是 Error 对象 (或者 继承自Error 对象) 就能够。

2.9 解决下面的回调天堂

function pick(){return new Promise((resolve, reject) => {setTimeout(()=>{console.log('收到信息',new Date());
      resolve();},500);
  })

}
function groundMouth(){return new Promise((resolve, reject) => {setTimeout(()=>{console.log('货物装载',new Date());
      resolve();},400);
  })
}
function blow(){return new Promise((resolve, reject) => {setTimeout(()=>{console.log('打包出仓',new Date());
      resolve();},300);
  })

}
function PEbag(){return new Promise((resolve, reject) => {setTimeout(()=>{console.log('集成装车',new Date());
      resolve();},200);
  })
}
function pack(){return new Promise((resolve, reject) => {setTimeout(()=>{console.log('发送运输',new Date());
      resolve();},100);
  })
}
pick()
  .then(groundMouth)
  .then(blow)
  .then(PEbag)
  .then(pack)

// pick(()=>{//   groundMouth(()=>{//       blow(()=>{//           PEbag(()=>{//               pack();
//           });
//       });
//   });
// });
输入后果：收到信息 2022-03-21T03:24:56.520Z
货物装载 2022-03-21T03:24:56.925Z
打包出仓 2022-03-21T03:24:57.235Z
集成装车 2022-03-21T03:24:57.436Z
发送运输 2022-03-21T03:24:57.544Z

三、async await

首先阐明一下异步，以及常见的微工作和宏工作

1、异步，微工作，宏工作

异步

• 异步是用来解决 JS 单线程期待这种问题的
• 异步是基于回调函数的模式来实现的
• 常见的异步有：setTimeout、ajax、Promise……then、async/await、图片加载、网络申请资源
• 牢记 5 个版块 Call Stack、Web APIs、Browser console、Callback Queue、micro task queue 这五个版块走漏出异步的执行过程

• 宏工作是在 DOM 渲染后触发，微工作是在 DOM 渲染前触发

  常见微工作和宏工作

• 常见的微工作：Promise……then、async/await
• 常见的宏工作：setTimeout、setInterval

2、async await 介绍

async/await 是 ECMAScript 2017 提出的内容。但事实上它们只是 Promise 的语法糖。

因为 Promise 的呈现次要是为了解决异步的回调天堂问题。将噩梦般的嵌套回调变为了优雅的管道式回调。但这始终是逃不掉“回调”二字。而 async/await 虽说只是 Promise 的语法糖，但让你“脱离”了回调，拥抱了同步代码

1. 执行 async 函数，返回的是 Promise 对象

2.await 必须在 async 包裹之下执行

3.await 相当于 Promise 的 then 并且同一作用域下 await 上面的内容全副作为 then 中回调的内容

4.try……catch 可捕捉异样，代替了 Promise 的 catch

5. 异步中先执行微工作，再执行宏工作

async function fn() {return '我是 async 函数';}

console.log('async:', fn());
输入后果：async: Promise {'我是 async 函数'}

这里的 fn() 相当于 Promise.resolve(‘ 我是 async 函数 ’)

(async function() {const p = Promise.resolve('success');
  const data = await p; // await 就相当于 Promise.then, 故 data 就是 then 的参数
  console.log(data);    // 这里的代码为 then 中回调的内容
})();
输入后果：success

下面的这段代码，如果把 async 删掉，后果肯定会报错！

(async function() {const p = Promise.reject('err');
  // await + try...catch 相当于 Promise.catch
  try {
    const res = await p;
    console.log(res);
  } catch(ex) {// ex 来源于 reject()外面的数
    console.error(ex); 
  }
})();
输入后果：err

下面的代码中：await + try…catch 相当于 Promise.catch

3、同步，异步，微工作，宏工作的执行程序

先同后异，先微后宏

• 例子如下：

async function async1 () {console.log('async1 start');      // 2
  await async2();
  console.log('async1 end');        // 6
}
async function async2 () {console.log('async2');            // 3
}
console.log('script start');        // 1
setTimeout(function () {console.log('setTimeout');        // 8
}, 0)
async1()
new Promise (function (resolve) {console.log('promise1')           // 4
  resolve()}).then(function () {console.log('promise2')           // 7
})

console.log('script end')           // 5
输入后果：script start
async1 start
async2
promise1
script end
async1 end
promise2
setTimeout

• 代码剖析：

1. 先执行同步代码。2. 所以首先执行 console.log('script start');
3. setTimeout 为宏工作，先不执行 
4. 执行 async1 函数 console.log('async1 start'); 以及 async2(); await 因为是 Promise.then 的语法糖是异步代码，先不执行 
5. new Promise() 外部代码要执行，前面的 then 的内容为微工作先不执行
6. 执行 console.log('script end')
7. 同步代码执行完结 
8. 开始按代码程序执行微工作
9. 先执行 console.log('async1 end'); 后面说过，await 上面的代码相当于 then 里回调的内容
10.new Promise.then 外面的内容 console.log('promise2')
11. 最初执行 宏工作代码，即 setTimeout 里的内容。

四、promisify

1、Callback 与 Promise 间的桥梁 —— promisify

• Promisify

1.npm 装置
npm install bluebird

2. Node.js 后端引入（Common.js 标准）var Promise = require("bluebird");

3. 或者在 ES6 中
import * as Promise from "bluebird";

4. 如果那个 ES6 导入[不起作用](https://github.com/petkaantonov/bluebird/pull/1594)
import {Promise} from "bluebird";

Promise 很好地解决了异步办法的回调天堂、提供了咱们在异步办法中应用 return 的能力，并将 callback 的调用纳入了本人的治理，而不是交给异步函数后咱们就无能为力了（常常有 callback 被莫名调用两次而导致程序出错）。

2、promisify 介绍

就是“promise 化”，将一个不是 promise 的办法变成 promise。

• 作用

将本来须要通过传入回调参数来实现回调执行（或者叫同步执行）改为利用 promise 的.then的形式来调用, 从而实现 逻辑上的同步操作。

const fs = require('fs');
const Promise = require('bluebird');

// 原有的 callback 调用
fs.readFile('input02.txt', function(err, data) {if (!err) {console.log('===:' + data.toString());
  } else {console.log(err);
  }
});

// promisify 后
var readFileAsync = Promise.promisify(fs.readFile);
readFileAsync('input01.txt').then(data => {console.log('---:' + data.toString());
}, err => {console.log(err);
});

输入后果：===: www.baidu.com

---: 我是通过 fs.writeFile 写入文件的内容

这两个办法成果上是等价的。后者掌控性更好！

那么什么样的办法能够通过 promisify 变成 promise 呢？这里就须要介绍一个名词，nodeCallback。什么样的 callback 叫 nodeCallback？

• nodeCallback

  有两个条件：1. 回调函数在主函数中的参数地位必须是最初一个；2. 回调函数参数中的第一个参数必须是 error。

回调函数在主函数中的参数地位

// 正确
function main(a, b, c, callback) { }
 
// 谬误
function main(callback, a, b, c) {}

回调函数参数中的第一个参数必须是 error

// 正确
function callback(error, result1, result2) { }
 
// 谬误
function callback(result1, result2, error) {}

通过 nodeCallback，咱们定义了一个能被 promisify 的函数的格局，即，满足 nodeCallback 模式的办法，咱们能够通过 promisify 来让它变成一个返回 promise 的办法。

3、promisify 应用

const Promise = require('bluebird');
async function main(a, b, callback) {const array1 = a.concat(b);
  console.log('a=' + a);
  console.log('b=' + b);
  return callback(null, array1);
}
async function foo(c, d, callback) {const array2 = c.concat(d);
  console.log('c=' + c);
  console.log('d=' + d);
  callback(null, array2);
}

async function fu(a,b) {// Promise.promisify 将不是 promise 的办法转为 promise 办法(实现同步)，如果有 .then() 则为异步。const function1 = Promise.promisify(main);
  const function2 = Promise.promisify(foo);

  const data1 = await function1(a,b);   // await 就相当于 Promise.then, 故 data 就是 then 的参数
  console.log('data1:' + data1);        // 这里的代码为 then 中回调的内容
  for(let i = 0; i < data1.length; i++) {const data = data1[i];
    const data2 = await function2(data1, b);
    console.log('data2:' + data2);
  }
}

const arr1 = [2,3,4,5];
const arr2 = [45,6,7,8];
fu(arr1,arr2);
输入：a=2,3,4,5
b=45,6,7,8
data1:2,3,4,5,45,6,7,8
c=2,3,4,5,45,6,7,8
d=45,6,7,8
data2:2,3,4,5,45,6,7,8,45,6,7,8
c=2,3,4,5,45,6,7,8
d=45,6,7,8
data2:2,3,4,5,45,6,7,8,45,6,7,8
c=2,3,4,5,45,6,7,8
d=45,6,7,8
data2:2,3,4,5,45,6,7,8,45,6,7,8
c=2,3,4,5,45,6,7,8
d=45,6,7,8
data2:2,3,4,5,45,6,7,8,45,6,7,8
c=2,3,4,5,45,6,7,8
d=45,6,7,8
data2:2,3,4,5,45,6,7,8,45,6,7,8
c=2,3,4,5,45,6,7,8
d=45,6,7,8
data2:2,3,4,5,45,6,7,8,45,6,7,8
c=2,3,4,5,45,6,7,8
d=45,6,7,8
data2:2,3,4,5,45,6,7,8,45,6,7,8
c=2,3,4,5,45,6,7,8
d=45,6,7,8
data2:2,3,4,5,45,6,7,8,45,6,7,8

代码阐明：fu()函数中，将 main()函数和 foo()函数进行了 promisify 化。将 asycn await 函数转换为 promise 函数。其中 callback 中，须要给第一个参数给为：null。如果不为 null 会有如下谬误：

const Promise = require('bluebird');
async function main(a, b, callback) {const array1 = a.concat(b);
  console.log('a=' + a);
  console.log('b=' + b);
  return callback(array1); 
}
async function foo(c, d, callback) {const array2 = c.concat(d);
  console.log('c=' + c);
  console.log('d=' + d);
  callback(null, array2);
}

async function fu(a,b) {// Promise.promisify 将不是 promise 的办法转为 promise 办法(实现同步)，如果有 .then() 则为异步。const function1 = Promise.promisify(main);
  const function2 = Promise.promisify(foo);

  const data1 = await function1(a,b);   // await 就相当于 Promise.then, 故 data 就是 then 的参数
  console.log('data1:' + data1);        // 这里的代码为 then 中回调的内容
  for(let i = 0; i < data1.length; i++) {const data = data1[i];
    const data2 = await function2(data1, b);
    console.log('data2:' + data2);
  }
}

const arr1 = [2,3,4,5];
const arr2 = [45,6,7,8];
fu(arr1,arr2);

错误信息：

a=2,3,4,5
b=45,6,7,8
node:internal/process/promises:265
            triggerUncaughtException(err, true /* fromPromise */);
            ^

[UnhandledPromiseRejection: This error originated either by throwing inside of an async function without a catch block, or by rejecting a promise which was not handled 
with .catch(). The promise rejected with the reason "[object Array]".] {code: 'ERR_UNHANDLED_REJECTION'}