文档章节

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

yjnic
 yjnic
发布于 2016/05/16 18:12
字数 613
阅读 42
收藏 0
点赞 2
评论 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
程序员
如何使用koa2+es6/7打造高质量Restful API

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

Jack088 ⋅ 06/12 ⋅ 0

Modern JS中的流控制:CallBacks->Promises->Async/Await

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

含笑666 ⋅ 06/06 ⋅ 0

NodeJS会是昙花一现吗?

在用了一年以后,我感觉node.js有一点不对劲。它很有意思,但是我觉得我应该用另外一个视角去审视它。 网络编程真的可以更容易吗? node.js无疑有一些设计非常好的地方。前段时间我写了一个性...

Kris_zcl ⋅ 2014/11/12 ⋅ 4

拿什么守护你的Node.JS进程: Node出错崩溃了怎么办?

被吐嘈的NodeJS的异常处理 许多人都有这样一种映像,NodeJS比较快; 但是因为其是单线程,所以它不稳定,有点不安全,不适合处理复杂业务; 它比较适合对并发要求比较高,而且简单的业务场景...

myownghost ⋅ 2014/09/16 ⋅ 4

Node出错导致运行崩溃的解决方案

许多人都有这样一种映像,NodeJS比较快; 但是因为其是单线程,所以它不稳定,有点不安全,不适合处理复杂业务; 它比较适合对并发要求比较高,而且简单的业务场景。 在Express的作者的TJ Ho...

黄欣怡 ⋅ 2017/06/13 ⋅ 0

NodeJs异步的终极解决方案Async/Await

Node.js的异步编程方式有效提高了应用性能;然而回调地狱却让人望而生畏,Promise让我们告别回调函数,写出更优雅的异步代码;在实践过程中,却发现Promise并不完美;技术进步是无止境的,这...

卟想苌亣 ⋅ 2017/12/12 ⋅ 0

我为什么不从NodeJS切换到Go

2014年3月26日 我最近研究并玩了一下Go语言,并且我想简短地谈一下为什么我不准备从Node切换到GO。(并且我建议你也不要这么干) 首先,人们在讨论Node.js时会有很多的抱怨: 回调地狱 Promis...

Kris_zcl ⋅ 2014/03/31 ⋅ 6

PromiseClass 0.9.5 发布,Promise 黑魔法

回调恶魔 在目前Javascript技术背景下,当碰到大量异步代码时,会非常头痛。 目前有以下几种手段来解决异步回调问题: 传统异步回调 Promise ES6 Generator ES7 async 远古 对于异步回调,相...

YanisWang ⋅ 2015/11/11 ⋅ 6

Node.js面试题

原文链接 借助Nginx搭建反向代理服务器 JavaScript运行机制详解:再谈Event Loop Nodejs单元测试小结 测试金字塔(Test Pyramid) HTTP框架 1. 什么是错误优先的回调函数? 2. 如何避免回调地...

jedi_knight ⋅ 2015/10/31 ⋅ 0

Node.js 应用性能优化的五个技巧

在这个由软件定义的世界里,企业往往是通过 Web 应用和移动应用程序来提供他们大部分的服务。所以对企业来说,一个非常重要的任务就是要确保用户拥有出色的使用体验。Node.js 正迅速成为时下...

OneAPM蓝海讯通 ⋅ 2015/07/09 ⋅ 0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

火狐浏览器各版本下载及插件httprequest

各版本下载地址:http://ftp.mozilla.org/pub/mozilla.org//firefox/releases/ httprequest插件截至57版本可用

xiaoge2016 ⋅ 11分钟前 ⋅ 0

Java学习路径及练手项目合集

Java学习路径及练手项目合集

颖伙虫 ⋅ 27分钟前 ⋅ 0

Docker系列教程28-实战:使用Docker Compose运行ELK

原文:http://www.itmuch.com/docker/28-docker-compose-in-action-elk/,转载请说明出处。 ElasticSearch【存储】 Logtash【日志聚合器】 Kibana【界面】 答案: version: '2'services: ...

周立_ITMuch ⋅ 52分钟前 ⋅ 0

使用快嘉sdkg极速搭建接口模拟系统

在具体项目研发过程中,一旦前后端双方约定好接口,前端和app同事就会希望后台同事可以尽快提供可供对接的接口方便调试,而对后台同事来说定好接口还仅是个开始、设计流程,实现业务逻辑,编...

fastjrun ⋅ 今天 ⋅ 0

PXE/KickStart 无人值守安装

导言 作为中小公司的运维,经常会遇到一些机械式的重复工作,例如:有时公司同时上线几十甚至上百台服务器,而且需要我们在短时间内完成系统安装。 常规的办法有什么? 光盘安装系统 ===> 一...

kangvcar ⋅ 昨天 ⋅ 0

使用Puppeteer撸一个爬虫

Puppeteer是什么 puppeteer是谷歌chrome团队官方开发的一个无界面(Headless)chrome工具。Chrome Headless将成为web应用自动化测试的行业标杆。所以我们很有必要来了解一下它。所谓的无头浏...

小草先森 ⋅ 昨天 ⋅ 0

Java Done Right

* 表示难度较大或理论性较强。 ** 表示难度更大或理论性更强。 【Java语言本身】 基础语法,面向对象,顺序编程,并发编程,网络编程,泛型,注解,lambda(Java8),module(Java9),var(...

风华神使 ⋅ 昨天 ⋅ 0

Linux系统日志

linux 系统日志 /var/log/messages /etc/logrotate.conf 日志切割配置文件 https://my.oschina.net/u/2000675/blog/908189 logrotate 使用详解 dmesg 命令 /var/log/dmesg 日志 last命令,调......

Linux学习笔记 ⋅ 昨天 ⋅ 0

MVC——统一报文格式的异常处理响应

在我们写controller层的时候,常常会有这样的困惑,如果需要返回一个数据是,可能为了统一回去构造一个类似下列的数据格式: { status:true, msg:"保存成功!", data:[]} 而且在写...

alexzhu592 ⋅ 昨天 ⋅ 0

android -------- 打开本地浏览器或指定浏览器加载,打电话,打开第三方app

开发中常常有打开本地浏览器加载url或者指定浏览器加载, 还有打开第三方app, 如 打开高德地图 百度地图等 在Android程序中我们可以通过发送隐式Intent来启动系统默认的浏览器。 如果手机本身...

切切歆语 ⋅ 昨天 ⋅ 0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

返回顶部
顶部