這期內(nèi)容當中小編將會給大家?guī)碛嘘P(guān)Node中異步編程機制的原理是什么，文章內(nèi)容豐富且以專業(yè)的角度為大家分析和敘述，閱讀完這篇文章希望大家可以有所收獲。

創(chuàng)新互聯(lián)主要從事網(wǎng)站制作、成都網(wǎng)站制作、網(wǎng)頁設(shè)計、企業(yè)做網(wǎng)站、公司建網(wǎng)站等業(yè)務(wù)。立足成都服務(wù)天等,十年網(wǎng)站建設(shè)經(jīng)驗,價格優(yōu)惠、服務(wù)專業(yè),歡迎來電咨詢建站服務(wù):18980820575

目前的異步編程主要解決方案有：

• 事件發(fā)布/訂閱模式

• Promise/Deferred模式

• 流程控制庫

事件發(fā)布/訂閱模式

Node自身提供了events模塊，可以輕松實現(xiàn)事件的發(fā)布/訂閱

//訂閱
emmiter.on("event1",function(message){
  console.log(message);
})
//發(fā)布
emmiter.emit("event1","I am mesaage!")；

偵聽器可以很靈活地添加和刪除，使得事件和具體處理邏輯之間可以很輕松的關(guān)聯(lián)和解耦

事件發(fā)布/訂閱模式常常用來解耦業(yè)務(wù)邏輯，事件發(fā)布者無需關(guān)注訂閱的偵聽器如何實現(xiàn)業(yè)務(wù)邏輯，甚至不用關(guān)注有多少個偵聽器存在，數(shù)據(jù)通過消息的方式可以很靈活的進行傳遞。

下面的HTTP就是典型的應(yīng)用場景

var req = http.request(options,function(res){
  res.on('data',function(chunk){
    console.log('Body:'+ chunk);
  })
  res.on('end',function(){
    //TODO
  })
})

如果一個事件添加了超過10個偵聽器，將會得到一條警告，可以通過調(diào)用emmite.setMaxListeners(0)將這個限制去掉

繼承events模塊

var events = require('events');
function Stream(){
  events.EventEmiiter.call(this);
}
util.inherits(Stream,events.EventEmitter);

利用事件隊列解決雪崩問題

所謂雪崩問題，就是在高訪問量，大并發(fā)量的情況下緩存失效的情況，此時大量的請求同時融入數(shù)據(jù)庫中，數(shù)據(jù)庫無法同時承受如此大的查詢請求，進而往前影響到網(wǎng)站整體的響應(yīng)速度

解決方案：

var proxy = new events.EventEmitter();
var status = "ready"; 
var seletc = function(callback){
  proxy.once("selected",callback);//為每次請求訂閱這個查詢時間，推入事件回調(diào)函數(shù)隊列
  if(status === 'ready'){ 
    status = 'pending';//設(shè)置狀態(tài)為進行中以防止引起多次查詢操作
    db.select("SQL",function(results){
      proxy.emit("selected",results); //查詢操作完成后發(fā)布時間
      status = 'ready';//重新定義為已準備狀態(tài)
    })
  }
}

多異步之間的協(xié)作方案

以上情況事件與偵聽器的關(guān)系都是一對多的，但在異步編程中，也會出現(xiàn)事件與偵聽器多對一的情況。

這里以渲染頁面所需要的模板讀取、數(shù)據(jù)讀取和本地化資源讀取為例簡要介紹一下

var count = 0 ;
var results = {};
var done = function(key,value){
  result[key] = value;
  count++;
  if(count === 3){
    render(results);
  }
}
fs.readFile(template_path,"utf8",function(err,template){
  done('template',template)
})
db.query(sql,function(err,data){
  done('data',data);
})
l10n.get(function(err,resources){
  done('resources',resources)
})

偏函數(shù)方案

var after = function(times,callback){
  var count = 0, result = {};
  return function(key,value){
    results[key] = value;
    count++;
    if(count === times){
      callback(results);
    }
  }
}
var done = after(times,render);
var emitter = new events.Emitter();
emitter.on('done',done);  //一個偵聽器
emitter.on('done',other);  //如果業(yè)務(wù)增長，可以完成多對多的方案

fs.readFile(template_path,"utf8",function(err,template){
  emitter.emit('done','template',template);
})
db.query(sql,function(err,data){
  emitter.emit('done','data',data);
})
l10n.get(function(err,resources){
  emitter.emit('done','resources',resources)
})

引入EventProxy模塊方案

var proxy = new EventProxy();
proxy.all('template','data','resources',function(template,data,resources){
  //TODO
})
fs.readFile(template_path,'utf8',function(err,template){
  proxy.emit('template',template);
})
db.query(sql,function(err,data){
  proxy.emit('data',data);
})
l10n.get(function(err,resources){
  proxy.emit('resources',resources);
})

Promise/Deferred模式

以上使用事件的方式時，執(zhí)行流程都需要被預(yù)先設(shè)定，這是發(fā)布/訂閱模式的運行機制所決定的。

$.get('/api',{
  success:onSuccess,
  err:onError,
  complete:onComplete
})
//需要嚴謹設(shè)置目標

那么是否有一種先執(zhí)行異步調(diào)用，延遲傳遞處理的方式的？接下來要說的就是針對這種情況的方式：Promise/Deferred模式

Promise/A

Promise/A提議對單個異步操作做出了這樣的抽象定義：

• Promise操作只會處在三種狀態(tài)的一種：未完成態(tài)，完成態(tài)和失敗態(tài)。

• Promise的狀態(tài)只會出現(xiàn)從未完成態(tài)向完成態(tài)或失敗態(tài)轉(zhuǎn)化，不能逆反，完成態(tài)和失敗態(tài)不能相互轉(zhuǎn)化

• Promise的狀態(tài)一旦轉(zhuǎn)化，就不能被更改。

一個Promise對象只要具備then()即可

• 接受完成態(tài)、錯誤態(tài)的回調(diào)方法

• 可選地支持progress事件回調(diào)作為第三個方法

• then()方法只接受function對象，其余對象將被忽略

• then()方法繼續(xù)返回Promise對象，以實現(xiàn)鏈式調(diào)用

通過Node的events模塊來模擬一個Promise的實現(xiàn)

var Promise = function(){
  EventEmitter.call(this)
}
util.inherits(Promise,EventEmitter);

Promise.prototype.then = function(fulfilledHandler,errHandler,progeressHandler){
  if(typeof fulfilledHandler === 'function'){
    this.once('success',fulfilledHandler); //實現(xiàn)監(jiān)聽對應(yīng)事件
  }
  if(typeof errorHandler === 'function'){
    this.once('error',errorHandler)
  }
  if(typeof progressHandler === 'function'){
    this.on('progress',progressHandler);
  }
  return this;
}

以上通過then()將回調(diào)函數(shù)存放起來，接下來就是等待success、error、progress事件被觸發(fā)，實現(xiàn)這個功能的對象稱為Deferred對象，即延遲對象。

var Deferred = function(){
  this.state = 'unfulfilled';
  this.promise = new Promise();
}
Deferred.prototype.resolve = function(obj){ //當異步完成后可將resolve作為回調(diào)函數(shù)，觸發(fā)相關(guān)事件
  this.state = 'fulfilled';
  this.promise.emit('success',obj);
}
Deferred.prototype.reject = function(err){
  this.state = 'failed';
  this.promise.emit('error',err);
}
Deferred.prototype.progress = function(data){
  this.promise.emit('progress',data)
}

因此，可以對一個典型的響應(yīng)對象進行封裝

res.setEncoding('utf8');
res.on('data',function(chunk){
  console.log("Body:" + chunk);
})
res.on('end',function(){
  //done
})
res.on('error',function(err){
  //error
}

轉(zhuǎn)換成

res.then(function(){
  //done
},function(err){
  //error
}，function(chunk){
  console.log('Body:' + chunk);
})

要完成上面的轉(zhuǎn)換，首先需要對res對象進行封裝，對data,end,error等事件進行promisify

var promisify = function(res){
  var deferred = new Deferred(); //創(chuàng)建一個延遲對象來在res的異步完成回調(diào)中發(fā)布相關(guān)事件
  var result = ''; //用來在progress中持續(xù)接收數(shù)據(jù)
  res.on('data',function(chunk){ //res的異步操作，回調(diào)中發(fā)布事件
    result += chunk;
    deferred.progress(chunk);
  })
  res.on('end',function(){    
    deferred.resolve(result);
  })
  res.on('error',function(err){
    deferred.reject(err);
  });
  return deferred.promise   //返回deferred.promise，讓外界不能改變deferred的狀態(tài)，只能讓promise的then()方法去接收外界來偵聽相關(guān)事件。
}

promisify(res).then(function(){
  //done
},function(err){
  //error
},function(chunk){
  console.log('Body:' + chunk);
})

以上，它將業(yè)務(wù)中不可變的部分封裝在了Deferred中，將可變的部分交給了Promise

Promise中的多異步協(xié)作

Deferred.prototype.all = function(promises){
  var count = promises.length; //記錄傳進的promise的個數(shù)
  var that = this; //保存調(diào)用all的對象
  var results = [];//存放所有promise完成的結(jié)果
  promises.forEach(function(promise,i){//對promises逐個進行調(diào)用
    promise.then(function(data){//每個promise成功之后，存放結(jié)果到result中，count--，直到所有promise被處理完了，才出發(fā)deferred的resolve方法，發(fā)布事件，傳遞結(jié)果出去
      count--;
      result[i] = data;
      if(count === 0){
        that.resolve(results);
      }
    },function(err){
      that.reject(err);
    });
  });
  return this.promise; //返回promise來讓外界偵聽這個deferred發(fā)布的事件。
}

var promise1 = readFile('foo.txt','utf-8');//這里的文件讀取已經(jīng)經(jīng)過promise化
var promise2 = readFile('bar.txt','utf-8');
var deferred = new Deferred();
deferred.all([promise1,promise2]).thne(function(results){//promise1和promise2的then方法在deferred內(nèi)部的all方法所調(diào)用，用于同步所有的promise
  //TODO
},function(err){
  //TODO
})

支持序列執(zhí)行的Promise

嘗試改造一下代碼以實現(xiàn)鏈式調(diào)用

var Deferred = function(){
  this.promise = new Promise()
}

//完成態(tài)
Deferred.prototype.resolve = function(obj){
  var promise = this.promise;
  var handler;
  while((handler = promise.queue.shift())){
    if(handler && handler.fulfilled){
      var ret = handler.fulfilled(obj);
      if(ret && ret.isPromise){
        ret.queue = promise.queue;
        this.promise = ret;
        return;
      }
    }
  }
}

//失敗態(tài)
Deferred.prototype.reject = function(err){
  var promise = this.promise;
  var handler;
  while((handler = promise.queue.shift())){
    if(handler && handler.error){
      var ret = handler.error(err);
      if(ret && ret.isPromise){
        ret.queue = promise.queue;
        this.promise = ret;
        return
      }
    }
  }
}

//生成回調(diào)函數(shù)
Deferred.prototype.callback = function(){
  var that = this;
  return function(err,file){
    if(err){
      return that.reject(err);
    }
    that.resolve(file)
  }
}

var Promise = function(){
  this.queue = []; //隊列用于存儲待執(zhí)行的回到函數(shù)
  this.isPromise = true;
};
Promise.prototype.then = function(fulfilledHandler,errorHandler,progressHandler){
  var handler = {};
  if(typeof fulfilledHandler === 'function'){
    handler.fulfilled = fulfilledHandler;
  }
  if(typeof errorHandler === 'function'){
    handler.error = errorHandler;
  }
  this.queue.push(handler);
  return this;
}

var readFile1 = function(file,encoding){
  var deferred = new Deferred();
  fs.readFile(file,encoding,deferred.callback());
  return deferred.promise;
}
var readFile2 = function(file,encoding){
  var deferred = new Deferred();
  fs.readFile(file,encoding,deferred.callback());
  return deferred.promise;
}

readFile1('file1.txt','utf8').then(function(file1){
  return readFile2(file1.trim(),'utf8')
}).then(function(file2){
  console.log(file2)
})

上述就是小編為大家分享的Node中異步編程機制的原理是什么了，如果剛好有類似的疑惑，不妨參照上述分析進行理解。如果想知道更多相關(guān)知識，歡迎關(guān)注創(chuàng)新互聯(lián)成都網(wǎng)站設(shè)計公司行業(yè)資訊頻道。

另外有需要云服務(wù)器可以了解下創(chuàng)新互聯(lián)scvps.cn，海內(nèi)外云服務(wù)器15元起步，三天無理由+7*72小時售后在線，公司持有idc許可證，提供“云服務(wù)器、裸金屬服務(wù)器、高防服務(wù)器、香港服務(wù)器、美國服務(wù)器、虛擬主機、免備案服務(wù)器”等云主機租用服務(wù)以及企業(yè)上云的綜合解決方案，具有“安全穩(wěn)定、簡單易用、服務(wù)可用性高、性價比高”等特點與優(yōu)勢，專為企業(yè)上云打造定制，能夠滿足用戶豐富、多元化的應(yīng)用場景需求。

網(wǎng)站欄目：Node中異步編程機制的原理是什么-創(chuàng)新互聯(lián)
本文路徑：http://www.2m8n56k.cn/article18/dhhhdp.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供做網(wǎng)站、ChatGPT、企業(yè)網(wǎng)站制作、搜索引擎優(yōu)化、微信公眾號、移動網(wǎng)站建設(shè)

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：[email protected]。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時需注明來源： 創(chuàng)新互聯(lián)