【javascript】Promise/A+ 規範簡單實現 非同步流程式控制制思想

来源:http://www.cnblogs.com/ztfjs/archive/2017/06/14/promise.html
-Advertisement-
Play Games

——基於es6：Promise/A+ 規範簡單實現 非同步流程式控制制思想 前言： nodejs強大的非同步處理能力使得它在伺服器端大放異彩，基於它的應用不斷的增加，但是非同步隨之帶來的嵌套、難以理解的代碼讓nodejs看起來並沒有那麼優雅，顯得臃腫。類似於這樣的代碼： 上面的代碼 println中定義了va ...


——基於es6：Promise/A+ 規範簡單實現 非同步流程式控制制思想 

前言：

　　nodejs強大的非同步處理能力使得它在伺服器端大放異彩，基於它的應用不斷的增加，但是非同步隨之帶來的嵌套、難以理解的代碼讓nodejs看起來並沒有那麼優雅，顯得臃腫。類似於這樣的代碼：

function println(name,callback){
    var value = {
        "ztf":"abc",
        "abc":"def",
        "def":1
    }
    setTimeout(function(){
        callback(value[name]);
    },500);
}

println("ztf",function(name){ 
    println(name,function(res){
        console.log(res);//def
        println(res,function(res1){
            console.log(res1);//1
        })
    });
});

上面的代碼 println中定義了value對象，延遲五百秒調用callback傳入相關的值，

首先調用println傳入"ztf",假設下一個執行函數依賴與本次傳回的值，那麼調用就變成了上面的代碼 傳入ztf返回abc ，使用abc返回def，使用def返回1;

因為nodejs是作為服務端使用，必不可少的就是各種資料庫查詢，資料庫查詢擁有更多的依賴，比如我需要查詢某個用戶的許可權，那麼需要三步

　　　　① 通過id查找用戶

　　　　② 通過返回的用戶角色id查找對應的角色

　　　　③ 通過角色找到對應的許可權

　此處便需要三層嵌套關係，代碼也就和上面的差不多了 。

 

promise/A+規範

　　Promise表示一個非同步操作的最終結果。它有三個狀態，分別是 未完成態、完成態（resolve）、失敗態(reject) 狀態不可逆，完成態不能返回未完成，失敗態不能變成完成態

　　 

   與promise主要的交互方式是在它的then方法中傳入回調函數，形成鏈式調用，

　

　　

實現

首先 我們來看Promise/A+規範在具體的應用中的調用方式:

我們可以根據promise規範，將上面的例子改為：

var  printText = function(name){
    var deferred = new Deferred(); //new一個托管函數
        println(name,deferred.callback());//把回調函數托管到Deferred中實現
    return deferred.promise; //返回promise對象實現鏈式調用
}

printText("ztf")
.then(function(name){
    console.log(name);
    return printText(name); //第二次調用依賴第一次調用 返回promise對象  在成功態中判斷
})
.then(function(res){
    console.log(res);//def
    return printText(res);
})
.then(function(res1){
    console.log(res1);//1
});

 

這樣的代碼從某種程度上，改變了非同步代碼不斷嵌套的現狀，通過then()方法的鏈式調用，達到非同步代碼的流程式控制制。

 

//處理回調
var Promise = function(){
    this.queue = []; //存儲的是回調函數的隊列
    this.isPromise = true; 
}
//延遲對象
var Deferred = function(){
    this.promise = new Promise();
}
Deferred.prototype = {
    //托管了callback回調函數
    callback:function(){
        
    },
    //完成態
    resolve:function(){
        
    },
    //失敗態
    reject:function(){
        
    }
}

這裡定義了兩個對象 Promise與Deferred, Promise負責處理函數的分發，Deferred顧名思義，處理了延遲對象。

//處理內部操作
var Promise = function(){
    this.queue = []; //存儲的是回調函數的隊列
    this.isPromise = true; 
}
Promise.prototype = {
    //then方法 fulfilledHandler是完成態時執行的回調函數 errorHandler則是失敗態
    then:function(fulfilledHandler,errorHandler){
        var handler = {};
        if(typeof(fulfilledHandler) == "function"){
            handler.fulfilled = fulfilledHandler;
        }
        if(typeof(errorHandler) == "function"){
            handler.errored = errorHandler;
        }
　　　　　this.queue.push(handler); //插入隊列
        return this;
    }
}
//處理外部操作
var Deferred = function(){
    this.promise = new Promise();
}
Deferred.prototype = {
    //托管了callback回調函數
    callback:function(){
        
    },
    //完成態
    resolve:function(){
        
    },
    //失敗態
    reject:function(){
        
    }
}

可以看到Promise.then方法只是將回調插入隊列，一個完成態執行，一個失敗態執行。

為了完成整個流程，還需要在Deferred中定義完成態和失敗態的處理方法：

//處理內部操作
var Promise = function(){
    this.queue = []; //存儲的是回調函數的隊列
    this.isPromise = true; 
}
Promise.prototype = {
    //then方法 fulfilledHandler是完成態時執行的回調函數 errorHandler則是失敗態

　　then:function(fulfilledHandler,errorHandler){
        var handler = {};
        if(typeof(fulfilledHandler) == "function"){
            handler.fulfilled = fulfilledHandler;
        }
        if(typeof(errorHandler) == "function"){
            handler.errored = errorHandler;
        }
　　　　　this.queue.push(handler);
        return this;
    }
 } 
//處理外部操作 
var Deferred = function(){ 
　　this.promise = new Promise(); 
} 
Deferred.prototype = { 
//托管了callback回調函數
  callback:function(){
 }, 
//完成態  
resolve:function(){ 
　　　　var self = this; 
　　　　var promise = self.promise;
　　　　 var args = arguments;
        var handler;
        while((handler = promise.queue.shift())){ //取出待執行隊列中的第一個函數 直到全部執行完畢
            if(handler && handler.fulfilled){
                
                var res = handler.fulfilled.apply(self,args); //調用完成態回調函數
                
                if(res && res.isPromise){ //如果有二次嵌套 則再次執行promise
                    res.queue = promise.queue;
                    self.promise = res;
                    return;
                }
            }
        }
    },
    //失敗態
    reject:function(){
        
    }
}

加入了完成態操作，這段代碼獲取了.then傳入的回調函數集合 promise.queue  while依次調用，傳入當前的arguments

然後 我們需要將完成態在托管回調函數（Deferred.callback()）中，按照邏輯執行：

 

//處理內部操作
var Promise = function(){
    this.queue = []; //存儲的是回調函數的隊列
    this.isPromise = true; 
}
Promise.prototype = {
    //then方法 fulfilledHandler是完成態時執行的回調函數 errorHandler則是失敗態
    then:function(fulfilledHandler,errorHandler){
        var handler = {};
        if(typeof(fulfilledHandler) == "function"){
            handler.fulfilled = fulfilledHandler;
        }
        if(typeof(errorHandler) == "function"){
            handler.errored = errorHandler;
        }
　　　　　this.queue.push(handler);
        return this;
    }
}
//處理外部操作
var Deferred = function(){
    this.promise = new Promise();
}
Deferred.prototype = {
    //托管了callback回調函數
    callback:function(){
        var self = this;
        var args = Array.prototype.slice.call(arguments); //將arguments轉為數組
        return function(err){
            if(err){
                //這裡是失敗態
                
                return;
            }
            args = args.concat(Array.prototype.slice.call(arguments,1)); //合併外部arguments 與內部arguments 去掉err
            //這裡是完成態
            self.resolve.apply(self,args);
            
        }
    },
    //完成態
    resolve:function(){
        var self = this;
        var promise = self.promise;
        var args = arguments;
        var handler;
        while((handler = promise.queue.shift())){ //取出待執行隊列中的第一個函數 直到全部執行完畢
            if(handler && handler.fulfilled){
                
                var res = handler.fulfilled.apply(self,args); //調用完成態回調函數
                
                if(res && res.isPromise){ //如果有二次嵌套 則再次執行promise
                    res.queue = promise.queue;
                    self.promise = res;
                    return;
                }
            }
        }
    },
    //失敗態
    reject:function(){
        
    }
}

代碼到這裡，主要功能已經完成，只是失敗態還沒有添加，它的實現方式與成功態類似 只是少了二次嵌套:

//處理內部操作
var Promise = function(){
    this.queue = []; //存儲的是回調函數的隊列
    this.isPromise = true; 
}
Promise.prototype = {
    //then方法 fulfilledHandler是完成態時執行的回調函數 errorHandler則是失敗態
    then:function(fulfilledHandler,errorHandler){
        var handler = {};
        if(typeof(fulfilledHandler) == "function"){
            handler.fulfilled = fulfilledHandler;
        }
        if(typeof(errorHandler) == "function"){
            handler.errored = errorHandler;
        }
        this.queue.push(handler);
        return this;
    }
}
//處理外部操作
var Deferred = function(){
    this.promise = new Promise();
}
Deferred.prototype = {
    //托管了callback回調函數
    callback:function(){
        var self = this;
        var args = Array.prototype.slice.call(arguments); //將arguments轉為數組
        return function(err){
            if(err){
                //這裡是失敗態  傳入了error對象
                self.reject.call(self,err);
                return;
            }
            args = args.concat(Array.prototype.slice.call(arguments,1)); //合併外部arguments 與內部arguments 去掉err
            //這裡是完成態
            console.log(args);
            self.resolve.apply(self,args);
            
        }
    },
    //完成態
    resolve:function(){
        var self = this;
        var promise = self.promise;
        var args = arguments;
        var handler;
        
        while((handler = promise.queue.shift())){ //取出待執行隊列中的第一個函數 直到全部執行完畢
            
            if(handler && handler.fulfilled){
                var res = handler.fulfilled.apply(self,args); //調用失敗態回調函數
                if(res && res.isPromise){ //如果有二次嵌套 則再次執行promise
                    res.queue = promise.queue;
                    self.promise = res;
                    return;
                }
            }
        }
    },
    //失敗態
    reject:function(err){
        var self = this;
        var promise = self.promise;
        var args = arguments;
        var handler;
        while((handler = promise.queue.shift())){ //取出待執行隊列中的第一個函數 直到全部執行完畢
            if(handler && handler.errored){
                
                var res = handler.fulfilled.call(self,err); //調用完成態回調函數
                
                
            }
        }
    }
}

 

總結

　　要點：
　　　　①  每個操作都返回一樣的promise對象，保證鏈式操作

　　　　②  函數callback第一個參數總是error對象 無報錯則null

　　　　③ 每個鏈式都通過then方法連接 返回promise對象再次執行

　　實現promise的方法也有很多，這裡只是簡單的介紹了其中一個，例如

q  https://github.com/kriskowal/q 、

async https://github.com/caolan/async

 

參考資料：

https://cnodejs.org/topic/560dbc826a1ed28204a1e7de

http://blog.csdn.net/jaytalent/article/details/51057724

https://segmentfault.com/a/1190000002452115

　　


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • Ajax的簡單封裝
    親測POST和GET都可以正常使用，如果你有更好的建議請指出~ 目前跟jquery的GET和POST一樣效果 一個GET方式的線上DEMO 其他： 關於xhrRequest.readyState請參考MDN：https://developer.mozilla.org/zh-CN/docs/Web/A ...
  • jquery單擊按鈕顯示或隱藏
    jQuery 效果 - toggle() 方法 定義和用法 toggle() 方法切換元素的可見狀態。 如果被選元素可見，則隱藏這些元素，如果被選元素隱藏，則顯示這些元素。 語法 可選。規定元素從可見到隱藏的速度（或者相反）。預設為 "0"。 可能的值： 毫秒 （比如 1500） "slow" "n ...
  • css 相容ie8 rgba()用法
    今天遇到了一個問題，要在一個頁面中設置一個半透明的白色div。這個貌似不是難題，只需要給這個div設置如下的屬性即可： background: rgba(255,255,255,.1); 但是要相容到ie8。這個就有點蛋疼了。因為ie8不支持rgba()函數。下麵我們總結一下rgba()函數的含義。 ...
  • input文字垂直居中和按鈕對齊問題，相容IE8
    1、盒子模型問題：請CSS重置 2、按鈕不對齊：請浮動或者vertical-align:middle;然後計算寬高，使其對齊 ； 3、IE8文本不居中：line-height屬性 註意：IE8不支持font寫法（或者某個樣式不支持） IE瀏覽器測試到IE8，IE5、6、7慎用。 問題原因：盒子模型 ...
  • ExtJs的Ext.Ajax.request實現waitMsg等待提示效果
    一、 fp.form.submit 有waitMsg 屬性來設置等待效果，如下。但是對於Ext.Ajax.request來說 waitMsg 並不起作用。 fp.form.submit({ 一、 fp.form.submit 有waitMsg 屬性來設置等待效果，如下。但是對於Ext.Ajax.re ...
  • ES6-----學習系列十（set-map數據結構）
    一、set數據結構 （使用 new來創建一個set集合 通過add方法添加元素 通過size來獲取set集合的長度） 還有另外一種初始化的方式（通過直接把數組傳遞進去） set裡面的元素不可以重覆（可以通過set的這個特性進行數組去重，註意：轉化過程中不會進行 數據類型轉化） set的一些方法（ad ...
  • 聊聊javascript的null和undefined
    只要是說到js的變數和數據類型，就脫不開null和undefined，這兄弟倆就是js的重要基礎，不可不察，無數的同學們都用過放大鏡多角度多批次地研究過這兄弟倆，真是深受歡迎。^-^ js也真是怪異，有個null不夠，還要折騰出個undefined。 雖然被詬病，但這就是設計。 在c#和java中， ...
  • 5.JS自動生成動態HTML驗證碼頁面，輸入錯誤自動清空輸入框
    驗證碼 ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發（一）：使用.NET MAUI開發第一個安卓APP
    移動開發（一）：使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說，近來想嘗試開發一款安卓APP，考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP，畢竟是使用Visual Studio開發工具，使用起來也比較的順手，結合微軟官方的教程進行了安卓 ...
  • wpf ToggleButton選中效果和一個登錄界面
    前言 QuestPDF 是一個開源 .NET 庫，用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫，它徹底改變了我們生成 PDF 文檔的方 ...
  • 彈幕樹洞項目功能新增篇
    項目地址 項目後端地址： https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址： ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址： http://tree ...
  • 第27篇 sqlserver2022詳細安裝步驟
    話不多說，直接開乾 一.下載 1.官方鏈接下載： https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe，運行開始下載SQL server； 二. ...
  • .NET 開源高性能 MQTT 類庫
    前言 隨著物聯網（IoT）技術的迅猛發展，MQTT（消息隊列遙測傳輸）協議憑藉其輕量級和高效性，已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫，為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog文檔翻譯系列（六） - 可用的接收器、增強器、格式化輸出
    Serilog支持多種接收器用於日誌存儲，增強器用於添加屬性，LogContext管理動態屬性，支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項，適用於不同需求。 ...
  • 警惕 Visual Studio 屬性求值副作用導致邏輯不符合預期
    目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據，爬取信息時需要模擬瀏覽器行為，否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下： 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • [使用目前最新版]HybridCLR6.9.0+YooAsset2.2.4實現純C# Unity熱更新方案 (一)
    1.前言 什麼是熱更新 游戲或者軟體更新時，無需重新下載客戶端進行安裝，而是在應用程式啟動的情況下，在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR，Xlua，ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles，Addressable， ...
  • 在 ASP.NET Core Web API 中使用操作篩選器統一處理通用操作
    本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺，其實像阿裡雲，騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後，它會送 ...
  • 第28篇 如何.net中實現高效可靠數據同步api
    通過以下方式可以高效，並保證數據同步的可靠性 1.API設計 使用RESTful設計，確保API端點明確，並使用適當的HTTP方法（如POST用於創建，PUT用於更新）。 設計清晰的請求和響應模型，以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類