文档章节

nodejs 万恶的回调地狱解决方案

yjnic
 yjnic
发布于 2016/05/16 18:12
字数 613
阅读 42
收藏 0
Nodejs最大的亮点就在于事件驱动, 非阻塞I/O 模型,这使得Nodejs具有很强的并发处理能力,非常适合编写网络应用。在Nodejs中大部分的I/O操作几乎都是异步的,也就是我们处理I/O的操作结果基本上都需要在回调函数中处理,比如下面的这个读取文件内容的函数:

var fs = require('fs');// 要处理的文件列表
fs.readFile('./test1.txt', function (err, data) {
    if (err) throw err;
    fs.readFile('./test2.txt', function (err, data2) {
        if (err) throw err;
        // 在这里处理data和data2的数据
    });
});

这是最原始的方式,当文件一多就很难处理,而且不好维护,想一下,如果突然来个需求说不需要读第二个了,那么改动量将会很大。

本文主要是介绍如何优雅的处理以上异步回调问题。
初级方案:通过递归处理异步回调

var fs = require('fs');// 要处理的文件列表
var files = ['./test1.txt', './test2.txt'];

var result = [];
function myReadFile(files, callback){
    if(files.length === 0){
        callback(result);
    }else{
        var fileName = files.shift(); 
        fs.readFile(fileName, function(err, data) {
            if (err) throw err;
            else{
                result.push(data);
                myReadFile(files, callback);              
            }        
        });
    }
}
myReadFile(files, function(data){
    for(var i in data){
        console.log(data[i].toString());
    }
});

下面是比较高级,科学的方案
方案一,使用Async:
var fs = require('fs');// 要处理的文件列表
var async = require('async');
var tasks = [
  function(callback){
    fs.readFile('./test1.txt', function (err, data) {
      if (err) callback(err);
      callback(null, data);
    });
  },
  function(callback){
    fs.readFile('./test2.txt', function (err, data2) {
      if (err) callback(err);
      callback(null, data2);
    });
  }
];
async.parallel(tasks,function(err, results){
  if(err){
      console.error(err);
  }else{
      for(var i in results){
        console.log(results.toString());    
      }
  }
});
原理和上面的递归方案差不多

方案二:使用promise
var Promise = require('bluebird');
var fs = Promise.promisifyAll(require('fs'));//promise fs模块

var results = [];
fs.readFileAsync('./test1.txt').then(function(fileData){
    results.push(fileData);
}).then(function(){
    return fs.readFileAsync('./test2.txt');
}).then(function(fileData){
    results.push(fileData);
    console.log(results.toString());
}).catch(function(error){
    console.error(error.stack);
});

瞬间代码简洁了不少

方案三:使用Generator,co模块和thunkify模块

var co = require('co');// 这里的co版本是4.6.0,旧版本的用法略有不同
var thunkify = require('thunkify');// 几乎所有的node原生模块,以及大量的npm模块,都可以利用TJ的thunkify模块进行封装。
var fs = require('fs');
var readFile = thunkify(fs.readFile);

co(function* (){
    var results = [];
    var ret1 = yield readFile('./test1.txt');
    var ret2 = yield readFile('./test2.txt');
    results.push(ret1.toString());
    results.push(ret2.toString());
    return results;
}).then(function (value) {
  console.log(value);
}, function (err) {
  console.error(err.stack);
});

基本可以使用同步的思路来实现

 

参考 :http://www.ruanyifeng.com/blog/2015/04/generator.html

© 著作权归作者所有

共有 人打赏支持
yjnic
粉丝 0
博文 9
码字总数 4333
作品 0
程序员
[译]JavaScript: Promises 介绍及为何 Async/Await 最终取得胜利

原文地址:JavaScript: Promises and Why Async/Await Wins the Battle 异步函数在JavaScript中有好有坏。好的一面是异步函数是非阻塞的,因此很快 - 特别是在Node.js上下文中。缺点是处理异...

sunshine杨小咩
09/27
0
0
如何使用koa2+es6/7打造高质量Restful API

前言 如今nodejs变得越来越火热,采用nodejs实现前后端分离架构已被多数大公司所采用。 在过去,使用nodejs大家首先想到的是TJ大神写的express.js,而发展到如今,更轻量,性能更好的koa已然...

Jack088
06/12
0
0
ES6之Promise 与 Node.js 8新特性之util.promisify()

2017年五月底Node.js 8正式发布,带来了 很多新特性 。本文讨论下util.promisify()这个方法。 Promise 介绍promisify之前,首先来看下Promise这个API,因为util.promisify()这个方法就是把原...

宛丘之上兮
07/26
0
0
写给 Node.js 学徒的 7 个建议

一些我更愿意在开始就知道东西利用 Node.js 开发是一个非常有趣,和令人满足的过程, 它有3万多个模块可以选择使用,并且所有的模块可以非常容易的集成入现有的应用之中。 无论如何,对于一些...

JayPark不作死
2014/11/05
0
3
Modern JS中的流控制:CallBacks->Promises->Async/Await

今天来聊一聊JS中的异步发展,还有推荐的异步调用写法. 单线程模式 JS运行在一个单处理线程上运行。当你操作一个标签时,其他的JS代码就会等待该操作执行完毕。浏览器的DOM操作不会发生在并行...

含笑666
06/06
0
0

没有更多内容

加载失败,请刷新页面

加载更多

rabbitmq学习(一)

RabbitMQ是目前非常热门的一款消息中间件,具有高可靠、易拓展、高可用及丰富的功能 1.什么是消息中间件 消息是指在应用间传送的数据。包含文本字符串、JSON、内嵌对象 消息队列中间件(消息...

hensemlee
25分钟前
1
0
学习设计模式——原型模式

1. 认识原型模式 1. 定义:用原型实例指定创建对象的种类,并通过拷贝这些原型创建新的对象。 2. 结构: Prototype:声明一个克隆自身的接口,用来约束想要克隆自己的具体实现类,要求这些类...

江左煤郎
31分钟前
1
0
观察者模式

观察者模式的套路 有如下角色: 事件,比如修改,用户点击; 事件队列,触发事件之后,会把事件一个一个放入事件队列 监听器,采用某种方式(一般是轮询,或者io阻塞机制),来判断事件队列是否有新的未...

黄威
34分钟前
1
0
线程安全策略

四个线程安全策略 线程限制: 一个被线程限制的对象,由线程独占,并且只能被占有它的线程修改 共享只读: 一个共享只读的对象,在没有额外同步的情况下,可以被多个线程并发访问,但是任何线...

Ala6
41分钟前
2
0
Dubbo (三)源码分析 —— 架构原理

1 核心功能 首先要了解Dubbo提供的三大核心功能: Remoting:远程通讯 提供对多种NIO框架抽象封装,包括“同步转异步”和“请求-响应”模式的信息交换方式。 Cluster: 服务框架 提供基于接口方...

小刀爱编程
43分钟前
1
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部