Skip to main content

回调函数

Node.js 异步编程的直接体现就是回调。

异步编程依托于回调来实现，但不能说使用了回调后程序就异步化了。

回调函数在完成任务后就会被调用，Node 使用了大量的回调函数，Node 所有 API 都支持回调函数。

例如，我们可以一边读取文件，一边执行其他命令，在文件读取完成后，我们将文件内容作为回调函数的参数返回。这样在执行代码时就没有阻塞或等待文件 I/O 操作。这就大大提高了 Node.js 的性能，可以处理大量的并发请求。

回调函数一般作为函数的最后一个参数出现：

function foo1(name, age, callback) { }
function foo2(value, callback1, callback2) { }

阻塞代码实例(readFileSync)​

创建一个文件 input.txt ，内容如下：

菜鸟教程官网地址：www.runoob.com

创建 main.js 文件, 代码如下：

var fs = require("fs");

var data = fs.readFileSync('input.txt');

console.log(data.toString());
console.log("程序执行结束!");

以上代码执行结果如下：

$ node main.js
菜鸟教程官网地址：www.runoob.com

程序执行结束!

非阻塞代码实例(readFile)​

创建一个文件 input.txt ，内容如下：

菜鸟教程官网地址：www.runoob.com

创建 main.js 文件, 代码如下：

var fs = require("fs");

fs.readFile('input.txt', function (err, data) {
    if (err) return console.error(err);
    console.log(data.toString());
});

console.log("程序执行结束!");

以上代码执行结果如下：

$ node main.js
程序执行结束!
菜鸟教程官网地址：www.runoob.com

以上两个实例我们了解了阻塞与非阻塞调用的不同。第一个实例在文件读取完后才执行程序。 第二个实例我们不需要等待文件读取完，这样就可以在读取文件时同时执行接下来的代码，大大提高了程序的性能。

因此，阻塞是按顺序执行的，而非阻塞是不需要按顺序的，所以如果需要处理回调函数的参数，我们就需要写在回调函数内。

笔记​

阻塞和非阻塞，同步和异步​

  • 一楼 阻塞和非阻塞，同步和异步是node.js里经常遇到的词汇，我举个简单的例子来说明：

我要看足球比赛，但是妈妈叫我烧水，电视机在客厅，烧水要在厨房。家里有2个水壶，一个是普通的水壶，另一个是水开了会叫的那种水壶。我可以：

用普通的水壶烧，人在边上看着，水开了再去看球。（同步，阻塞）这个是常规做法，但是我看球不爽了。 用普通水壶烧，人去看球，隔几分钟去厨房看看。（同步，非阻塞）这个又大问题，万一在我离开的几分钟水开了，我就麻烦了。 用会叫的水壶，人在边上看着。（异步，阻塞）这个没有问题，但是我太傻了。 用会叫的水壶，人去看球，听见水壶叫了再去看。（异步，非阻塞）这个应该是最好的。 等着看球的我：阻塞

看着电视的我：非阻塞

普通水壶：同步

会叫的水壶：异步

所以，异步往往配合非阻塞，才能发挥出威力。

  • 二楼

1.阻塞：就像单线程cpu一样，一个任务由多个小任务组成，但是只能一个任务接一个任务流程的往想下走，谁在任务排序的前面就谁先执行，执行完了进行下一个，如果遇到错误，下面的小任务就不要做了，一直卡住。

2.非阻塞：就像多线程cpu一样，一个任务由多个小任务组成，可以分开线程来做，哪个线程做分配到的任务，完成了对应的任务就行，某个线程的任务没做完那就做报对应的错，其他的不受影响。

  • 三楼 同步：同步就是你要做的事你列了一个清单，按照清单上的顺序 一个一个执行

异步：就是可以同时干好几件事

阻塞：就是按照清单上的顺序一件一件的往下走，当一件事没有做完，下面的事都干不了

非阻塞：就是这件事没有干完，后面的事不会等你这件事干完了再干，而是直接开始干下一件事，等你这件事干完了，后面的事也干完了，这样就大大提高了效率

基于新版本 ES 的语法糖，Node 的异步操作可以替换成以下两种写法。​

1、Promise

const _submit = (payload, formid, destination) => {
  return new Promise((resolve, reject) => { // 返回一个Promise对象，实现异步回调
    app.requestPost(destination, {
      payload,
      formid: formid
    }, true).then((res) => { // 调用一个异步函数，使用then方法对接成功回调
      if (res) {
        resolve(); // call成功回调
      } else {
        reject(); / call失败回调
      }
    }).catch(() => { // 调用一个异步函数，使用catch方法对接失败回调
      reject();
    })
  });
}

2、async/await

async function query(collection, querySelector, queryOptions) {
  let db, data;
  try {
    db = await MongoClient.connect(_dburl); // 使用await标记上游异步函数，此时event loop会将与该变量有关的操作阻塞
    data = await db.db(DBNAME).collection(collection).find(querySelector, queryOptions || {}).toArray();
  } catch (e) {
    log(e.message, 2);
  }
  return data;
}