xieye 阅读(145) 评论(0)
node异步进阶系列文章:
node异步进阶(1)-- 回调函数经典写法
node异步进阶(2)-- Promise的连续then写法
node异步进阶(3)-- async写法


继续上回的任务,这次改用promise对象实现。

让我们疯狂的使用then吧
第三版 (串行)
var http = require('http');
var fs = require('fs');

http.createServer(function(req,res){
  if (req.url=='/') {
    getTitles(res);
  }
}).listen(80,function(){
  console.log('server start..');
});

function getTitles(res){
  var titles;
  get_file_content('/tpl/title.json') // 先抓取数据文件
  .then(JSON.parse)  // 这里顺便做一下解析,让我们尽情滥用node的异步吧!!
  .then( function(value){
    titles = value;  // 把局域变量保存到上一层变量。
    return '/tpl/template.html';//给下一个文件请求then传参
  }).then(
    get_file_content             // 再抓取模板文件
  ).then(function (tmpl){ // tmpl是上一个promis的输出
      formatHtml(titles,tmpl, res); // 调用函数全部搞定
    }
  ).catch( function (err) {
    hadError(err, res);          // 调用处理错误的函数。
  });
}

// 这是通用函数,异步读文件
function get_file_content(file)
{
  return new Promise(function (resolve, reject) {
    fs.readFile(__dirname+file, function(err,data){
      if (err) {
        reject(err);
      } else {
        resolve(data.toString() );
      }
    });
  });
}


//这是本程序主要逻辑,模板替换后,输出
function formatHtml(titles,tmpl, res) {
  var html = tmpl.replace('%', ' <li > ' +titles.join('</li > <li >') +' </li > ' );
  res.writeHead(200,{'Content-Type':'text/html;charset=utf-8'});
  res.end(html);
}

// 通用的错误处理函数
function hadError(err, res) {
  console.log(err);
  res.end('server error.');
}


我本人的电脑是windows,node8.9,测试通过,假如故意删除一个模板文件或数据文件,会在html输出程序中给定的错误。

注意到,这种写法的要点,先定义一个返回promise对象的函数,然后每个then里面放入这个函数,也可以不放,会自动被node转换成promise对象的!

这种写法中,一般都希望在一个地方处理错误,只要任意一个地方抛异常,所以就按上面的写法,把catch放在最后即可。

返回promise对象的函数的写法,把正确的输出放在resolve里即可,
每个then的输出,就是下个then的输入,代码很连贯。

尽管如此,本任务无需获取模板文件必须在数据文件后,完全可以同时请求,加快速度,于是有下面的代码:
第四版(并发)
var http = require('http');
var fs = require('fs');

http.createServer(function(req,res){
  if (req.url=='/') {
    getTitles(res);
  }
}).listen(80,function(){
  console.log('server start..');
});

function getTitles(res){
  var files ={
    title_fun: function (){
      return get_file_content('/tpl/title.json').then(JSON.parse);
    },
    template_fun:function(){
      return get_file_content('/tpl/template.html');
    }
  };
  Promise.all([files.title_fun(), files.template_fun()]).then(function (results){
      formatHtml(results[0],results[1], res); // 按照教材说法,这里的结果顺序一定等同all的传入顺序
    }
  ).catch( function (err) {
    hadError(err, res);          // 调用处理错误的函数。
  });
}

// 这是通用函数,异步读文件
function get_file_content(file)
{
  return new Promise(function (resolve, reject) {
    fs.readFile(__dirname+file, function(err,data){
      if (err) {
        reject(err);
      } else {
        resolve(data.toString() );
      }
    });
  });
}


//这是本程序主要逻辑,模板替换后,输出
function formatHtml(titles,tmpl, res) {
  var html = tmpl.replace('%', ' <li > ' +titles.join('</li > <li >') +' </li > ' );
  res.writeHead(200,{'Content-Type':'text/html;charset=utf-8'});
  res.end(html);
}

// 通用的错误处理函数
function hadError(err, res) {
  console.log(err);
  res.end('server error.');
}



可以看到并发请求,速度更快了,更充分利用了node的天生异步特性,充分的利用了计算机的性能。
并发的要点是all(....).then(...)这样的写法。

尽管如此,程序还是比较罗嗦,有没有更简单的写法呢?早就有了。
请继续看下一篇文章